netty - Netty重写SimpleChannelInboundHandler后的ChannelRead0方法从未被调用？

Question

Netty重写SimpleChannelInboundHandler后的ChannelRead0方法从未被调用？

public class RequestHandler extends SimpleChannelInboundHandler<MessageProtocol<MessageRequest>> {@Override    protected void channelRead0(ChannelHandlerContext channelHandlerContext, MessageProtocol<MessageRequest> protocol)            throws Exception {// 请求过来这里的代码从未被调用// 业务代码....}}

// ..........childHandler(new ChannelInitializer<SocketChannel>() {                        @Override                        protected void initChannel(SocketChannel socketChannel) {                            socketChannel.pipeline()                                    // 协议编码                                    .addLast(new StringEncoder())                                    // 协议解码                                    .addLast(new StringDecoder())                                    // 请求处理器                                    .addLast(new RequestHandler());                        }                    }).childOption(ChannelOption.SO_KEEPALIVE, true);// .........

希望结果：重写后的方法【RpcRequestHandler#channelRead0】每次有新请求都被调用

Answer 1

首先，我们需要确保RequestHandler实例被正确添加到了ChannelPipeline中。从你提供的代码片段来看，RequestHandler实例被正确添加到了ChannelPipeline中。

如果channelRead0方法从未被调用，可能的原因有以下几点：

1. 请求数据的问题：检查发送到服务器的请求数据是否正确，是否能够被StringDecoder解码。如果请求数据有问题，那么StringDecoder可能无法正确解码请求，导致后续的处理器（包括你的RequestHandler）不会被调用。
2. 处理器顺序问题：在ChannelPipeline中，处理器的顺序很重要。确保你的处理器顺序是正确的，特别是解码器和编码器应该在你的处理器之前。在你的代码中，StringDecoder在RequestHandler之前，这是正确的。
3. ChannelHandler的状态：确保你的RequestHandler实例没有被添加到ChannelPipeline两次或者多次。如果一个ChannelHandler已经被添加到了ChannelPipeline，再次添加会导致之前的实例被覆盖。
4. 异常处理：检查是否有任何异常在处理过程中被抛出。如果有异常，那么后续的处理器将不会被调用。
5. Netty版本问题：确保你使用的Netty版本是最新的，或者至少是一个已知稳定的版本。有些旧版本的Netty可能存在已知的问题。
6. 调试：你可以使用Netty的调试功能来检查请求和响应是否按照预期在各个处理器之间传递。你可以在启动服务器时添加一些调试参数来启用这个功能。

希望这些建议能帮助你解决问题。如果问题仍然存在，你可能需要提供更多的信息来帮助定位问题，例如请求数据、服务器日志、Netty版本等。