数据如何通过管道从处理程序传递到处理程序 netty

Question

我试图通过“网络在行动”这本书来掌握网络概念。

在我看来，有几个概念解释得不太好或太模糊。因此，我想我会来这里就这些话题做一些明确的解释。

渠道管道:

所以我有一个这样的渠道管道：

@Override
    protected void initChannel(SocketChannel ch) throws Exception {
        ChannelPipeline pipeline = ch.pipeline();

        pipeline.addLast("decoder", new decodeHandler());
        pipeline.addLast("encoder", new encodeHandler());
        pipeline.addLast("timeout", new IdleStateHandler(60, 0, 0));
        pipeline.addLast("handler", handler);
    }

对于channelInitializer，从概念上讲，我会假设该过程将按以下顺序进行:

解码器 -

为什么处理程序在管道的最后？这是因为编码器对消息进行编码，处理程序对其进行处理并将其推送到上游/客户端吗？

频道处理程序:

对我来说，这是整个网络中最令人困惑的部分。因此，使用解码器，netty 书对解码参数的解释如下：

这是您必须实现的唯一抽象方法。使用包含传入数据的ByteBuf和添加解码消息的List调用decode（）。重复此调用，直到确定没有新项添加到List或ByteBuf中没有更多字节可读。然后，如果List不为空，则将其内容传递给管道中的下一个处理程序。

这一切对我来说都是有道理的。但是，令人困惑的部分是最后一句话。内容究竟如何传递到下一个处理程序？例如，我看到通道处理程序上下文写入数据，如下所示：

ctx.channel().alloc().write(response)

然而，然后我们也这样做

out.add(new Response());

我不知道为什么我们直接写入通道，有时会将可读对象添加到out列表变量中。

所以我的问题是，我们什么时候写入绑定到上下文的通道（即ctx.channel（）. write（），而不是通过out变量传递数据。因为我在代码中看不到out变量被传递到下一个处理程序的位置。它只是将对象添加到其中，仅此而已。留档没有显示它是如何传递的。我知道管道是一个双向链接列表。所以什么代码语句会增加管道中的指针。例如，我想应该是这样的。

decode(){
   //decode message
   //increment pointer of pipeline and pass out variable to next handler (or new pointer location)
}

任何帮助和澄清都将不胜感激。




Answer 1

匿名用户

< li >第一个问题。什么决定了管道中处理程序的顺序？< br >当您调用< code>pipeline.addlast()向管道添加处理程序时，该处理程序将被添加到处理程序链的最后。也就是说，处理程序在链中的顺序取决于您添加它们的顺序。因此，在您的示例中，处理程序链是这样的:< br> decode -