在 Netty 示例中使用 ctx.read() 与 ctx.channel.read()

Question

Netty 的流水线（即ctx.foo() vs ctx.channel.foo()）之前在 StackOverflow 上已经解释过两次：

1. Any difference between ctx.write() and ctx.channel().write() in netty?
2. In Netty 4, what's the difference between ctx.close and ctx.channel.close?

但是，我不明白 Netty 的示例背后的直觉是什么时候使用不同的方法：

public void channelActive(ChannelHandlerContext ctx) {
    ctx.read(); // <----- HERE
}

public void channelRead(final ChannelHandlerContext ctx, Object msg) {
    inboundChannel.writeAndFlush(msg).addListener(new ChannelFutureListener() {
        public void operationComplete(ChannelFuture future) {
            if (future.isSuccess()) {
                ctx.channel().read(); // <----- HERE
            } else {
                future.channel().close();
            }
        }
    });
}

View source on GitHub

---

为什么在代理impl的channelActive处理程序中使用'从这个处理程序向下'样式read，而在channelRead中使用'从顶部'样式read？

Answer 1

当使用ChannelHandlerContext.read() 时，它将从ChannelPipeline 中ChannelHandler 所在的点开始。当您使用Channel.read() 时，它将从ChannelPipeline 的尾部开始，因此需要遍历整个ChannelPipeline 以进行更糟糕的转换。

此示例在channelActive(...) 中使用ctx.read() 而在ChannelFutureListener 中使用channel.read() 的原因是因为ChannelFutureListener 不是ChannelHandler 的一部分，因此它需要从尾部开始ChannelPipeline。还要注意Channels 在这里是不同的。