Netty TCPServer初始化添加Channel Handler后消息接收日志无触发排查

我通过Netty创建了TCP服务器，在doOnChannelInit()方法中为Channel添加ChannelHandler处理嵌入式设备的字节数据。目前能正常建立连接，但发送消息时没有任何反应，channelRead0()中的日志语句未触发，求排查思路。

我的代码 #

NettyServer代码 #

@Component
@RequiredArgsConstructor
public class NettyServer {

    Logger log = LoggerFactory.getLogger(NettyServer.class);

    private final NettyProperties nettyProperties;

    private final NettyServerHandler nettyServerHandler;

    private TcpServer server;

    public void run() {
        server = TcpServer
                .create()
                .host("localhost")
                .port(nettyProperties.getTcpPort())
                .doOnChannelInit((connectionObserver, channel, remoteAddress) -> {
                    log.info("Connection from " + remoteAddress);
                    channel.pipeline()
                            .addLast("idleStateHandler", new IdleStateHandler(0, 0, 4, TimeUnit.MINUTES))
                            .addLast(new ByteArrayDecoder())
                            .addLast(new ByteArrayEncoder())
                            .addLast(nettyServerHandler);
                });

        server.bindNow();
        log.info("Server running");
    }

}

ChannelHandler代码 #

@Component
@RequiredArgsConstructor
@ChannelHandler.Sharable
public class NettyServerHandler extends SimpleChannelInboundHandler<byte[]> {

    Logger log = LoggerFactory.getLogger(NettyServerHandler.class);

    private final AttributeKey<byte[]> dataKey = AttributeKey.valueOf("dataBuf");

    private final AttributeKey<Integer> dataLen = AttributeKey.valueOf("dataBufLen");


    @Override
    public void channelActive(ChannelHandlerContext ctx) throws Exception {
        log.info("New Meter connection from : " + ctx.channel());
    }

    @Override
    public void channelInactive(ChannelHandlerContext ctx) throws Exception {
        if (ctx.channel() != null) {
            log.info(String.format("Meter/Client Disconnected. No: %s ; Channel : %s", meterNo, ctx.channel()));

        }
        ctx.close();

    }

    @Override
    protected void channelRead0(ChannelHandlerContext ctx, byte[] msg) throws Exception {

        log.info("Message received: " + new String(msg));
        ctx.channel().read();
    }
}

排查方向及修复建议 #

• 修正Handler的消息类型适配问题：从代码里的TcpServer判断你用的是Reactor Netty，它默认的入站消息类型是ByteBuf，而你用了传统Netty的ByteArrayDecoder，这个Handler在Reactor Netty环境下可能无法正确转换数据。建议移除ByteArrayDecoder，同时修改NettyServerHandler的泛型为ByteBuf，在channelRead0中手动转换为字节数组：

  @Override
  protected void channelRead0(ChannelHandlerContext ctx, ByteBuf msg) throws Exception {
      byte[] bytes = new byte[msg.readableBytes()];
      msg.readBytes(bytes);
      log.info("Message received: " + new String(bytes));
  }
  

• 移除冗余的手动读操作：Reactor Netty默认是自动读模式，ctx.channel().read()属于多余操作，会干扰正常数据流，直接删除即可。
• 修复未定义变量错误：channelInactive方法里的meterNo变量未定义，这会导致编译异常，先补全变量定义或移除该占位符，避免Handler因初始化失败无法工作。
• 调整Handler顺序并清理不必要组件：ByteArrayEncoder是出站Handler，如果你不需要主动发送byte[]类型数据，可以移除；IdleStateHandler放在最前是正确的，确保心跳检测优先执行。
• 开启Netty调试日志：在日志配置中把io.netty的日志级别设为DEBUG，查看数据到达时的流转细节，确认消息是否真的传递到了NettyServerHandler。

内容的提问来源于stack exchange，提问作者TiOLUWA