优化雷达tcp客户端

‘liusuyi’

2023-12-28 1c490ff27a0eeb4327923a9367f3a7c2aaa929b2

 src/main/java/com/ard/utils/netty/tcp/BootNettyChannelInitializer.java

@@ -1,25 +1,20 @@
package com.ard.utils.netty.tcp;

import io.netty.channel.Channel;
import io.netty.channel.ChannelHandler;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.socket.SocketChannel;
import io.netty.handler.codec.string.StringDecoder;
import io.netty.handler.codec.string.StringEncoder;
import io.netty.util.CharsetUtil;

@ChannelHandler.Sharable
public class BootNettyChannelInitializer<SocketChannel> extends ChannelInitializer<Channel> {
 
public class BootNettyChannelInitializer extends ChannelInitializer<SocketChannel> {

    @Override
    protected void initChannel(Channel ch) throws Exception {
 
        ch.pipeline().addLast("encoder", new StringEncoder(CharsetUtil.UTF_8));
        ch.pipeline().addLast("decoder", new StringDecoder(CharsetUtil.UTF_8));
    protected void initChannel(SocketChannel ch){
        //ch.pipeline().addLast("encoder", new StringEncoder(CharsetUtil.UTF_8));
        //ch.pipeline().addLast("decoder", new StringDecoder(CharsetUtil.UTF_8));
        /**
         * 自定义ChannelInboundHandlerAdapter
         */
        ch.pipeline().addLast(new BootNettyChannelInboundHandlerAdapter());
        
    }
 
}