Netty学习笔记（番外篇） - ChannelHandler、ChannelPipeline和ChannelHandlerContext的联系 (5)

通过调用一系列重载的 write 方法后，通过 findContextOutbound 方法在双向链表里向前寻找最近的实现了 write 或 writeAndFlush 方法的 ChannelHandlerContext，调用它的 invokeWrite 或 invokeWriteAndFlush 方法。

// AbstractChannelHandlerContext.java // 省略代码 void invokeWrite(Object msg, ChannelPromise promise) { if (invokeHandler()) { invokeWrite0(msg, promise); } else { write(msg, promise); } } private void invokeWrite0(Object msg, ChannelPromise promise) { try { ((ChannelOutboundHandler) handler()).write(this, msg, promise); } catch (Throwable t) { notifyOutboundHandlerException(t, promise); } } // 省略代码

同理于读取消息，这里经过 invokeHandler 方法检查通过后调用找到的 ChannelHandlerContext 的 ChannelHandler，没有通过检查，则继续向前传递写入事件。当写入消息传递到头部，调用 HeadContext 的 write 方法

// DefaultChannelPipeline.java final class HeadContext extends AbstractChannelHandlerContext implements ChannelOutboundHandler, ChannelInboundHandler { private final Unsafe unsafe; // 省略代码 @Override public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) { unsafe.write(msg, promise); } @Override public void flush(ChannelHandlerContext ctx) { unsafe.flush(); } // 省略代码 }

最终通过调用 unsafe 的 write 方法写入消息。
最后，从上面的实现里可以发现，在将 ChannelHandler 加入到 ChannelPipeline 时，要把 ChannelOutBoundHandler 类型的 ChannelHandler 进来添加在前面，否则在 ChannelInBoundHandler 写入消息时，在它后面的 ChannelOutBoundHandler 将无法获取到事件。