[netty5笔记-总体流程分析3-ChannelHandlerContext](http://blog.csdn.net/youaremoon/article/details/50449867) [Netty4学习笔记（1）-- ChannelPipeline](http://blog.csdn.net/zxhoo/article/details/17264263) 处理链处理写操作流程、Pipeline，Context和Handler的协作处理。 netty核心的概念：Channel、Buffer、Selecter ## Channel Channel是核心的一个接口，表示一个联络Socket的通道。通过Channel，可以对Socket进行各种操作。 ## ChannelHandler 在实际程序实现中，很少直接操作Channel，而是通过ChannelHandler来间接操纵Channel。（使用策略模式？） ### ChannelHandler的种类: ChannelHandler接口的子接口 - ChannelInboundHandler - ChannelOutboundHandler > 5.0.0.Alpha1 版本已经没有了这两个接口，why。4.1.5存在。 ## ChannelPipeline ChannelPipeline里有一个双向链表，使用HashMap存放节点。节点类型为：ChannelHandlerContext。 是一个ChandlerHandler的链表。当需要对Channel进行某种处理的时候，Pipeline负责依次调用每一个Handler进行处理。（责任链模式？） > 每个Channel都有一个属于自己的Pipeline.(一对一关系) ChannelPipeline的方法有很多，其中一部分是用来管理ChannelHandler的，如下面这些： ``` ChannelPipeline addFirst(String name, ChannelHandler handler); ChannelPipeline addLast(String name, ChannelHandler handler); ChannelPipeline addBefore(String baseName, String name, ChannelHandler handler); ChannelPipeline addAfter(String baseName, String name, ChannelHandler handler); ChannelPipeline remove(ChannelHandler handler); ChannelHandler remove(String name); ChannelHandler removeFirst(); ChannelHandler removeLast(); ChannelPipeline replace(ChannelHandler oldHandler, String newName, ChannelHandler newHandler); ChannelHandler replace(String oldName, String newName, ChannelHandler newHandler); ChannelHandler first(); ChannelHandler last(); ChannelHandler get(String name); ``` ### 事件的传播 为了搞清楚事件如何在Pipeline里传播， - 让我们从Channel的抽象子类AbstractChannel开始： ``` public abstract class AbstractChannel extends DefaultAttributeMap implements Channel { // ... @Override public Channel write(Object msg) { return pipeline.write(msg); } // ... } ``` - 再看DefaultChannelPipeline的write()方法实现 ``` final class DefaultChannelPipeline implements ChannelPipeline { // ... @Override public ChannelFuture write(Object msg) { return tail.write(msg); } // ... } ``` 因为write是个outbound事件，所以DefaultChannelPipeline直接找到tail部分的context，调用其write()方法 - 接着看DefaultChannelHandlerContext的write()方法 ``` final class DefaultChannelHandlerContext extends DefaultAttributeMap implements ChannelHandlerContext { // ... @Override public ChannelFuture write(Object msg) { return write(msg, newPromise()); } @Override public ChannelFuture write(final Object msg, final ChannelPromise promise) { if (msg == null) { throw new NullPointerException("msg"); } validatePromise(promise, true); write(msg, false, promise); return promise; } private void write(Object msg, boolean flush, ChannelPromise promise) { DefaultChannelHandlerContext next = findContextOutbound(); next.invokeWrite(msg, promise); if (flush) { next.invokeFlush(); } } private DefaultChannelHandlerContext findContextOutbound() { DefaultChannelHandlerContext ctx = this; do { ctx = ctx.prev; } while (!ctx.outbound); return ctx; } private void invokeWrite(Object msg, ChannelPromise promise) { try { ((ChannelOutboundHandler) handler).write(this, msg, promise); } catch (Throwable t) { notifyOutboundHandlerException(t, promise); } } // ... } ``` context的write()方法沿着context链往前找，直至找到一个outbound类型的context为止，然后调用其invokeWrite()方法 invokeWrite()接着调用handler的write()方法： ## ChannelHandlerContext ChannelPipeline并不是直接管理ChannelHandler，而是通过ChannelHandlerContext来间接管理，这一点通过ChannelPipeline的默认实现DefaultChannelPipeline可以看出来。 调用ChannelHandlerContext#channel()方法可以得到和Context绑定的Channel，调用ChannelHandlerContext#handler()方法可以得到和Context绑定的Handler。 > 一个ChannelHandlerContext只能对应一个ChannelHander，只对应一个Channel，而一个ChannelHander则可以对应多个ChannelHandlerContext