网状管道中的多通道边界HandlerAdapter's

Question

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

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

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

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

我必须提醒大家：

只能将一个SimpleChannelInboundHandler扩展添加到管道链。因为SimpleChannelInboundHandler有一个finally代码块，所以将释放所有消息。

@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
    boolean release = true;
    try {
        if (acceptInboundMessage(msg)) {
            @SuppressWarnings("unchecked")
            I imsg = (I) msg;
            channelRead0(ctx, imsg);
        } else {
            release = false;
            ctx.fireChannelRead(msg);
        }
    } finally {
        if (autoRelease && release) {
            //release all handled messages,so the next handler won't be executed
            ReferenceCountUtil.release(msg);**
        }
    }
}

改用ChannelInboundHandlerAdapter：

public class CustomizeChannelInboundHandler extends ChannelInboundHandlerAdapter {
  @Override
  public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
    System.out.println("do something you like!")

    super.channelRead(ctx, msg);
  }

}

Answer 2

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

要使用更简单的SimpleChannelInboundHandler请参阅此线程Netty hello world示例不工作

因此，不要使用这个ch.pipeline（）。addLast（新ChannelInboundHandlerAdapter（）{}

您必须编写一个新类来扩展SimpleChannelInboundHandlerlike

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());
                    }

如上所述，在channelRead（）之后，SimpleCHannelInundHandler会自动释放消息（从而将其传递给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