介绍

netty+springboot打造高性能TCP+JSON/XML接口 使用tcp协议接口大大的提升了接口性能

软件架构

软件架构说明 SpringBoot2.1.5 + Netty 4.1.37

安装教程

下载源码

启动NettyApp使用Jemter或其他TCP工具发送JSON/XML流式数据访问接口

使用说明

Netty配置几乎都在yml/properties中可灵活配置，详见配置文件说明

下有

2、 主要类说明

Netty服务启动类：cn.com.bsfit.netty.server.NettySocketServer数据接收处理器：cn.com.bsfit.netty.handler.SocketReceiveDataHandler，支持默认可接受最大数据1M，可自行配置业务逻辑处理器：cn.com.bsfit.netty.handler.SocketRequestHandler，其父类使用模板方法完成固定流程，让业务处理类专注于业务数据返回处理器：cn.com.bsfit.netty.handler.SocketResponseHandler请求数据转化为通用格式Map处理类：cn.com.bsfit.netty.req.ReqData2MapFacade可配置化文件类：cn.com.bsfit.netty.config.properties.BaseNettyServerProperties

3、如需了解更多，请查看源码以及doc文件夹下详细文档<<项目介绍.doc>>

4、使用说明

1、依赖引入

<dependencies>    <!--依赖hdl-netty-->    <dependency>        <groupId>com.hdl</groupId>        <artifactId>hdl-netty</artifactId>        <version>0.0.1-SNAPSHOT</version>    </dependency></dependencies>

2、业务接口实现并声明为Bean

/** * 类名 DemoService * 描述 样例，实现接口BusinessService，返回业务逻辑返回的数据 * 默认是返回在body对象中 * 返回格式 { "message": {"head": {}, "body": {}} } * 该这个标签格式可自定义实现 * * @author hedonglin * @version 1.0 * @date 2020/4/27 9:48 */@Servicepublic class DemoService implements BusinessService {    @Override    public Map<String, Object> reqHandler(Map<String, Object> reqMap, ReqData2MapFacade reqData2MapFacade) throws Exception {        Map<String, Object> data = Maps.newHashMap();        data.put("name", "hedonglin");        // 获取facade中的数据        boolean b = reqData2MapFacade.isJson();        data.put("isJson", b);        return BaseResponse.builder().success(data);    }    /**     * 自定义异常返回结果（可重写，不重写返回默认错误数据结构BaseResponse#error方法）     * @param errMsg 错误信息     * @return 统一异常返回结果     */    @Override    public Map<String, Object> getBaseResponseError(String errMsg) {        Map<String, Object> result = Maps.newHashMap();        result.put("code", "500");        result.put("errMsg", errMsg);        return result;    }}

3、配置文件

######################################## Netty Server Config#######################################netty:  server:    # netty功能启动开关， 默认为false    enable: true    # netty 主线程池(接受数据的线程池)大小，默认值为1    bosses: 4    # netty 工作线程池大小，默认值为1    workers: 4    # 数据格式转换线程池大小，默认转换JSON和XML两种格式，大小为2    data-trans-poll-size: 2    # 启动端口    port: 8010    # 启动延时，默认1000ms    start-delay-time: 1000    # 接受数据的缓冲区大小配置，单位是字节    recbuf:      # 最小值默认1KB      min-size: 1024      # 初始值默认为10K      initial: 10240      # 最大值默认为1M      max-size: 1048576    json-response:      # JSON返回是否包含顶层字段（如果有顶层字段该配置才生效）,默认是false      contains-top: false      # JSON返回是否包含Head字段（如果有Head字段该配置才生效）,默认是true      contains-head: false      # JSON返回是否包含Body字段（如果有Body字段该配置才生效）,默认是true      contains-body: false    xml-response:      # Xml返回是否包含顶层字段(XML有顶层标签，所以这里只能设置为true),默认是true      contains-top: true    # 限制支持的顶层字段    top-fields: Message,message    # 限制支持的首部字段，与主体部分一段一一对应，默认支持配置Head    head-fields: Head,head,HEAD    # 限制支持的主体字段，与首部部分一段一一对应，默认支持配置Body    body-fields: Body,body,BODY

4、入口程序类编写

package com.hdl.demo;/** * 类名 DemoApplication * 描述 TODO * * @author hedonglin * @version 1.0 * @date 2020/4/27 9:54 */import cn.com.bsfit.netty.NettyApp;import cn.com.bsfit.netty.config.base.BaseConfigurable;import lombok.extern.slf4j.Slf4j;import org.springframework.boot.Banner;import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.EnableAutoConfiguration;import org.springframework.boot.builder.SpringApplicationBuilder;import org.springframework.context.annotation.ComponentScan;import org.springframework.context.annotation.FilterType;/** * 类名 NettyApp * 描述 主程序启动类 * * @author hedonglin * @version 1.0 * @date 2019/9/29 9:43 */@Slf4j@EnableAutoConfiguration@ComponentScan(basePackages = {"cn.*", "com.*", "net.*"},        // 不适用默认的过滤器        useDefaultFilters = false,        //includeFilters 只扫描指定的类        includeFilters = {                // 只有实现了BaseConfigurable接口的类才回被扫描                @ComponentScan.Filter(value = {BaseConfigurable.class},                        // 过滤类型为指定的类型，比如某个类                        type = FilterType.ASSIGNABLE_TYPE)}         ,        // 不扫描NettyApp.class(重要)        excludeFilters = {                @ComponentScan.Filter(classes = NettyApp.class)        })public class DemoApplication {    public static void main(String[] args) {        try {            SpringApplication app = new SpringApplicationBuilder().bannerMode(Banner.Mode.OFF).sources(NettyApp.class).build();            app.run(args);        } catch (Exception e) {            log.error("请确认已正确配置该应用，请检查是否正确配置");        }    }}

5、启动DemoApplication

12:36:12.691 [main] INFO  com.hdl.demo.DemoApplication - No active profile set, falling back to default profiles: default12:36:16.537 [main] INFO  o.s.b.w.e.tomcat.TomcatWebServer - Tomcat initialized with port(s): 8080 (http)12:36:16.559 [main] INFO  o.a.coyote.http11.Http11NioProtocol - Initializing ProtocolHandler ["http-nio-8080"]12:36:16.575 [main] INFO  o.a.catalina.core.StandardService - Starting service [Tomcat]12:36:16.576 [main] INFO  o.a.catalina.core.StandardEngine - Starting Servlet engine: [Apache Tomcat/9.0.19]12:36:16.754 [main] INFO  o.a.c.c.C.[Tomcat].[localhost].[/] - Initializing Spring embedded WebApplicationContext12:36:16.754 [main] INFO  o.s.web.context.ContextLoader - Root WebApplicationContext: initialization completed in 3971 ms12:36:16.997 [main] INFO  c.c.bsfit.netty.utils.SpringBeanUtil - ---------------------------------------------------------------------12:36:16.997 [main] INFO  c.c.bsfit.netty.utils.SpringBeanUtil - ========ApplicationContext配置成功========12:36:16.997 [main] INFO  c.c.bsfit.netty.utils.SpringBeanUtil - ---------------------------------------------------------------------12:36:17.443 [main] INFO  c.c.b.netty.server.NettySocketServer - netty application starting12:36:17.446 [main] INFO  o.a.coyote.http11.Http11NioProtocol - Starting ProtocolHandler ["http-nio-8080"]12:36:17.469 [main] INFO  o.s.b.w.e.tomcat.TomcatWebServer - Tomcat started on port(s): 8080 (http) with context path ''12:36:17.474 [main] INFO  com.hdl.demo.DemoApplication - Started DemoApplication in 5.645 seconds (JVM running for 7.472)**12:36:18.941 [netty主线程-0] INFO  c.c.b.netty.server.NettySocketServer - Socket server bound successfully,the port is 8010**

6、重要配置详解

    json-response:      # JSON返回是否包含顶层字段（如果有顶层字段该配置才生效）,默认是false      contains-top: false      # JSON返回是否包含Head字段（如果有Head字段该配置才生效）,默认是true      contains-head: false      # JSON返回是否包含Body字段（如果有Body字段该配置才生效）,默认是true      contains-body: false    xml-response:      # Xml返回是否包含顶层字段(XML有顶层标签，所以这里只能设置为true),默认是true      contains-top: true    # 限制支持的顶层字段    top-fields: Message,message    # 限制支持的首部字段，与主体部分一段一一对应，默认支持配置Head    head-fields: Head,head,HEAD    # 限制支持的主体字段，与首部部分一段一一对应，默认支持配置Body    body-fields: Body,body,BODY

如果是JSON请求，且需要格式请求和响应格式，如

{   "Message": {    "Head": {        "headKey": "测试头"    },     "Body": {        "bodyKey": "测试体"    }  }}

Message, Head, Body 都可以后台配置，并且可以使用开关关闭。

使用jmeter发送TCP请求 注意：

1、jmeter默认TCP的编码格式不是UTF-8, 需要在bin/jmeter.properties中修改tcp编码。    2、jmeter发送tcp请求时，需要关闭连接(选中close connection)，因为实现的时短连接。    3、如果时XML请求，则必须存在顶层标签

原文地址：

作者：hedonglin