Springboot整合Netty，自定义协议实现

2023-10-03 13:33

短信预约 -IT技能 免费直播动态提醒

Springboot整合Netty，自定义协议实现

Springboot整合Netty

新建springboot项目，并在项目以来中导入netty包，用fastjson包处理jsonStr。

                            io.netty            netty-all            4.1.42.Final                                    com.alibaba.fastjson2            fastjson2            2.0.16

创建netty相关配置信息文件

yml配置文件——application.yml

# netty 配置netty:  # boss线程数量  boss: 4  # worker线程数量  worker: 2  # 连接超时时间  timeout: 6000  # 服务器主端口  port: 18023  # 服务器备用端口  portSalve: 18026  # 服务器地址  host: 127.0.0.1

netty配置实体类——NettyProperties与yml配置文件绑定通过@ConfigurationProperties(prefix = "netty")注解读取配置文件中的netty配置，通过反射注入值，需要在实体类中提供对应的setter和getter方法。

@ConfigurationProperties(prefix = "netty")对应的实体类属性名称不要求一定相同，只需保证“set”字符串拼接配置文件的属性和setter方法名相同即可。

@Configuration@ConfigurationProperties(prefix = "netty")public class NettyProperties {        private Integer boss;        private Integer worker;        private Integer timeout = 30000;        private Integer port = 18023;        private Integer portSalve = 18026;        private String host = "127.0.0.1";        // setter、getter 。。。。}

对netty进行配置，绑定netty相关配置设置 Netty通常由一个Bootstrap开始，主要作用是配置整个Netty程序，串联各个组件，Netty中Bootstrap类是客户端程序的启动引导类，ServerBootstrap是服务端启动引导类。

@Configuration@EnableConfigurationPropertiespublic class NettyConfig {    final NettyProperties nettyProperties;    public NettyConfig(NettyProperties nettyProperties) {        this.nettyProperties = nettyProperties;    }        @Bean    public NioEventLoopGroup boosGroup() {        return new NioEventLoopGroup(nettyProperties.getBoss());    }        @Bean    public NioEventLoopGroup workerGroup() {        return new NioEventLoopGroup(nettyProperties.getWorker());    }        @Bean    public ServerBootstrap serverBootstrap() {        ServerBootstrap serverBootstrap = new ServerBootstrap()                // 指定使用的线程组                .group(boosGroup(), workerGroup())                // 指定使用的通道                .channel(NioServerSocketChannel.class)                // 指定连接超时时间                .option(ChannelOption.CONNECT_TIMEOUT_MILLIS, nettyProperties.getTimeout())                // 指定worker处理器                .childHandler(new NettyServerHandler());        return serverBootstrap;    }}

worker处理器，初始化通道以及配置对应管道的处理器自定义了##@##分割符，通过DelimiterBasedFrameDecoder来处理拆包沾包问题；通过MessageDecodeHandler将接收消息解码处理成对象实例；通过MessageEncodeHandler将发送消息增加分割符后并编码；最后通过ServerListenerHandler根据消息类型对应处理不同消息。

public class NettyServerHandler extends ChannelInitializer {    @Override    protected void initChannel(SocketChannel socketChannel) throws Exception {        // 数据分割符        String delimiterStr = "##@##";        ByteBuf delimiter = Unpooled.copiedBuffer(delimiterStr.getBytes());        ChannelPipeline pipeline = socketChannel.pipeline();        // 使用自定义处理拆包/沾包，并且每次查找的最大长度为1024字节        pipeline.addLast(new DelimiterBasedFrameDecoder(1024, delimiter));        // 将上一步解码后的数据转码为Message实例        pipeline.addLast(new MessageDecodeHandler());        // 对发送客户端的数据进行编码，并添加数据分隔符        pipeline.addLast(new MessageEncodeHandler(delimiterStr));        // 对数据进行最终处理        pipeline.addLast(new ServerListenerHandler());    }}

数据解码数据解码和编码都采用UTF8格式

public class MessageDecodeHandler extends ByteToMessageDecoder {    @Override    protected void decode(ChannelHandlerContext channelHandlerContext, ByteBuf in, List