关于#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);
    }
}

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

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

不知道你这个问题是否已经解决, 如果还没有解决的话:

如果你已经解决了该问题, 非常希望你能够分享一下解决方案, 写成博客, 将相关链接放在评论区, 以帮助更多的人 ^-^