Netty中，addLast的顺序

2024-08-22 14:44

文章标签 顺序 netty addlast

本文主要是介绍Netty中，addLast的顺序，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

在Netty中，addLast方法用于向ChannelPipeline中添加ChannelHandler，这些ChannelHandler会按照被添加到Pipeline的顺序来处理入站（Inbound）和出站（Outbound）事件。然而，需要注意的是，虽然addLast是按照添加顺序来注册Handler的，但入站和出站事件的处理顺序有所不同。

入站事件（`Inbound Events`）

对于入站事件（如读取数据、连接事件等），ChannelHandler会按照它们在Pipeline中被添加的顺序顺序执行。具体来说，如果你按以下顺序添加InboundHandler：

ch.pipeline().addLast(new InboundHandler1());  
ch.pipeline().addLast(new InboundHandler2());  
ch.pipeline().addLast(new InboundHandler3());

那么当入站事件发生时，处理顺序将是：
InboundHandler1 -> InboundHandler2 -> InboundHandler3。

出站事件（`Outbound Events`）

对于出站事件（如写入数据、关闭连接等），ChannelHandler会按照它们在Pipeline中被添加的逆序来执行。这是因为Netty的出站操作是从Pipeline的尾部开始，向前回溯到头部执行的。例如，如果你按以下顺序添加OutboundHandler：

ch.pipeline().addLast(new OutboundHandler1());  
ch.pipeline().addLast(new OutboundHandler2());  
ch.pipeline().addLast(new OutboundHandler3());

并且从某个InboundHandler中触发了一个出站操作（如ctx.writeAndFlush），那么处理顺序将是：
OutboundHandler3 -> OutboundHandler2 -> OutboundHandler1。

注意事项

顺序执行：入站Handler按照添加顺序顺序执行，而出站Handler按照添加顺序的逆序执行。
传递机制：
入站Handler之间通过调用ctx.fireChannelRead(msg)将消息传递给下一个InboundHandler。
出站操作通常通过ctx.write(msg)触发，并需要在之后调用ctx.flush()来确保消息被发送出去。
调用writeAndFlush：
ctx.writeAndFlush()会从当前Handler开始，逆序向前执行出站Handler。
ctx.channel().writeAndFlush()会从Pipeline的尾部开始，逆序向前执行出站Handler。
确保OutboundHandler的调用：为了让所有的出站Handler都能被执行到，需要确保在添加InboundHandler之前添加OutboundHandler。