迅捷的软件产品制作专家 2023-07-28 17:42 采纳率: 29.4%
浏览 23

关于#nettychannelRead#的问题,如何解决?

netty 的channelRead 方法不执行,但是channelReadComplete 方法执行了:


public class MessageForwardInboundHandler extends ChannelInboundHandlerAdapter {
    @Autowired
    BusinessConfig businessConfig;
    @Autowired
    CommonHandlerFactory handlerFactory;

    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        Message message = (Message)msg;
        log.info(">>>>>>>>>>>>>>>>>>>>>>>>>>>channelRead执行>>>>>>>>>>>>>>>>>>");
        if(null == handlerFactory.getHandler((int)message.getMsgHead().getMsgId())){
            log.warn("暂不支持此类型消息:" + ByteArrayUtil.short2HexStr(message.getMsgHead().getMsgId()));
            return;
        }
        handlerFactory.getHandler((int)message.getMsgHead().getMsgId()).handler(ctx,message);
}

    @Override
    public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
        log.info("数据读取完成");
        super.channelReadComplete(ctx);
    }
}
  • 写回答

2条回答 默认 最新

  • 家有娇妻张兔兔 优质创作者: Java技术领域 2023-07-28 17:55
    关注

    检查代码中是否存在以下情况:

    数据读取时发生了错误,导致数据读取不完整,这种情况下 channelRead() 方法不会被调用。
    数据在读取之前就已经被处理完成,这种情况下 channelRead() 方法也不会被调用。

    评论

报告相同问题?

问题事件

  • 创建了问题 7月28日