java - Netty 管道中的多个 ChannelInboundHandlerAdapter

Question

我对 netty 很陌生，我想创建一个 TCP 服务器，它在实例化连接时执行自定义应用层握手。握手后，我想将消息 (ByteBuf) 传递到队列，以便其他线程可以处理它们。

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

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

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 将消息传递到队列。我的逻辑正确吗？如果不是应该怎么办？

非常感谢。

Answer 1

ChannelInboundHandlerAdapter 是 ChannelInBoundHandler 接口(interface)的适配器类。开始时，您可以使用 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