Netty出站处理程序未被调用

Question

我正在使用Netty 4.1.0.final，但我面临一个问题，即消息不能通过出站处理程序传递。我发布了一个示例程序，其中有一个入站和一个出站处理程序。入站处理程序在ChannelHandlerContext中使用writeAndFlush，我的理解是它应该将消息转发到管道中可用的第一个出站处理程序。为了简单起见，忽略了内存管理。

引导代码

EventLoopGroup bossGroup = new NioEventLoopGroup();
EventLoopGroup workerGroup = new NioEventLoopGroup();
ServerBootstrap bootstrap = new ServerBootstrap();
bootstrap.group(bossGroup, workerGroup)
             .channel(NioServerSocketChannel.class)
             .localAddress(12021)
             .childHandler(new ChannelInitializer<SocketChannel>() {
                 @Override
                 protected void initChannel(SocketChannel ch) throws Exception {
                     ch.pipeline().addLast(new TestHandler1(), new TestOutHandler1());
                 }
             });
ChannelFuture future = bootstrap.bind().sync();
System.out.println("Server Started...");
    future.channel().closeFuture().sync();
    bossGroup.shutdownGracefully();
    workerGroup.shutdownGracefully();
    System.out.println("Server Shutdown");

入站处理程序代码

public class TestHandler1 extends ChannelInboundHandlerAdapter {


private static Log logger = LogFactory.getLog(TestHandler1.class);

@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
    logger.info("channelRead");
    ctx.writeAndFlush(msg);
}

}

出站处理程序代码

public class TestOutHandler1 extends ChannelOutboundHandlerAdapter {

private static Log logger = LogFactory.getLog(TestOutHandler1.class);

@Override
public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) throws Exception {
    logger.info("write");
    ctx.writeAndFlush(msg);
}

}

输出

信息TestHandler1:channelRead

如果我在channel上执行writeAndFlush（）而不是ChannelHandlerContext来更改入站处理程序（如下所示），我将得到预期的输出

修改的入站汉德勒

public class TestHandler1 extends ChannelInboundHandlerAdapter {

private static Log logger = LogFactory.getLog(TestHandler1.class);

@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
    logger.info("channelRead");
    ctx.channel().writeAndFlush(msg);
}

}

输出

信息TestHandler1:channelRead

INFO TestOutHandler1:写入

根据Norman在下面链接中的解释，我理解为ChannelHandlerContext.Write（...）应该通过它前面的ChannelOutboundHandlers，在我的示例中，它是唯一的出站处理程序。

诺曼解释

如果我的理解是错误的，或者我遗漏了什么，请告诉我。

Answer 1

前面的回答很好，我想解释一下问题的另一个方面：调用CTX.WriteAndFlush()和CTX.Channel.WriteAndFlush()得到的不同结果

1. CTX.WriteAndFlush()
   查找当前CTX之前的第一个OutboundHandler。在你的频道里，什么也找不到。因此只打印一个信息。
2. ctx.channel.writeandflush()
   实际上，ctx.channel.writeandflush()将调用pipeline.tail.writeandflush()。这等于在您的通道中的尾部ctx上调用writeandflush()。这样，将找到TestOutHandler1，并调用TestOutHandler1.write()。然后打印两个信息。