java - Netty管道中的多个ChannelInboundHandlerAdapter

我是netty的新手，我想创建一个TCP服务器，该服务器在实例化连接时会执行自定义应用程序层握手。握手之后，我想将消息（ByteBuf）传递到队列，以便可以由其他一些线程处理它们。

我的问题是，通道管道中可以有多个ChannelInboundHandlerAdapter吗？一个用于应用程序层握手协议，另一个用于将消息传递到队列。此外，我想知道消息如何通过管道流动。如果在一个处理程序（或解码器/编码器）处收到一条消息，该消息如何传递给另一处理程序。

具体来说，如果我从here更改EchoServer并添加另一个ChannelInboundHandlerAdapter，则回显服务器处理程序将停止接收任何消息。

ServerBootstrap b = new ServerBootstrap();
            b.group(group)
             .channel(NioServerSocketChannel.class)
             .localAddress(new InetSocketAddress(port))
             .childHandler(new ChannelInitializer<SocketChannel>() {
                 @Override
                 public void initChannel(SocketChannel ch)
                     throws Exception {
                 ch.pipeline().addLast(new ChannelInboundHandlerAdapter() {
                     @Override
                     public void channelRead(ChannelHandlerContext ctx,
                          Object msg) {
                           }
                          });

                  ch.pipeline().addLast(
                       new EchoServerHandler());
                 }
                 });

我的逻辑是：有2个ChannelInboundHandlerAdapter，然后与第一个处理程序进行握手，如果不符合握手条件，则丢弃数据包，然后通过第二个ChannelInboundHandlerAdapter将消息传递到队列。我的逻辑正确吗？如果没有，应该怎么办？

非常感谢你。

最佳答案

ChannelInboundHandlerAdapter是ChannelInBoundHandler接口的适配器类。首先，您可以使用SimpleChannelInboundHandler（或更复杂的是，您可以扩展适配器类，编写自己的扩展了ChannelInboundHandlerAdapter的处理程序）。
SimpleCHannelInboundHandler在channelRead()之后自动释放消息（从而将其传递到ChannelPipeline中的下一个处理程序）。

有关使用更简单的SimpleChannelInboundHandler的信息，请参见此线程Netty hello world example not working

所以代替这个ch.pipeline().addLast(new ChannelInboundHandlerAdapter() {}

您必须编写一个扩展SimpleChannelInboundHandler的新类，例如

public class MyHandler extends SimpleChannelInboundHandler{


    @Override
    protected void channelRead0(ChannelHandlerContext ctx, Object msg) throws Exception {


        try {
            System.out.println(in.toString(io.netty.util.CharsetUtil.US_ASCII));
        } finally {
            in.release();
        }


    }
}

并像这样调用它

public void initChannel(SocketChannel ch) throws Exception {
                        ch.pipeline().addLast(new MyHandler());
                    }

如上所述，SimpleCHannelInboundHandler在channelRead（）之后自动释放消息（从而将其传递到ChannelPipeline中的下一个处理程序）。

如果使用ChannelInboundHandlerAdapter，则必须自己实现将消息/事件传递给下一个处理程序

处理程序必须调用ChannelHandlerContext ctx中的事件传播方法，以将事件转发到其下一个处理程序。 （在SimpleChannelInboundHandler类中，此方法尚未实现）

 public class MyInboundHandler extends ChannelInboundHandlerAdapter {
   @Override
   public void channelActive(ChannelHandlerContext ctx) {
       System.out.println("Connected!");
       ctx.fireChannelActive();
    }
 }

看到这个http://netty.io/4.0/api/io/netty/channel/ChannelPipeline.html