Netty源码分析（七）：初识ChannelPipeline

ChannelPipeline单看名称就能够知道Channel的管道。本篇将结合它的默认实现类DefaultChannelPipeline来对它作一个简单的介绍。

示例图

上图是官方提供的 ChannelPipeline的事例图。IO请求经由 ChannelOutboundHandler中 ChannelOutboundHandler处理以后写出到服务端，服务接收到读入后，由 ChannelInboundHandler依次处理。 下面来看下 DefaultChannelPipeline的类图：

DefaultChannelPipeline实现了 ChannelPipeline接口，而 ChannelPipeline又继承了 ChannelInboundInvoker、 ChannelOutboundInvoker和 Iterable。 ChannelInboundInvoker:发起对 ChannelPipeline中下一个 ChannelInboundHandler的方法的调用。 ChannelOutboundInvoker:发起对 ChannelPipeline中下一个 ChannelOutboundHandler的方法的调用。 Iterable：可遍历 ChannelPipeline中的 ChannelHandler。 NioEventLoop继承自 SingleThreadEventLoop,而 SingleThreadEventLoop又继承自 SingleThreadEventExecutor。 SingleThreadEventExecutor内部持有一个Thread对象，是 Netty多线程的基础。 能够认为, 一个 NioEventLoop与一个特定的线程进行了绑定,而且在其生命周期内,绑定的线程都不会再改变。

DefaultChannelPipeline

DefaultChannelPipeline的主要工做就是对ChannelHandler的管理，包括ChannelHandler的增减，事件的触发等。

ChannelHandler的增减

以addFirst方法为例:

public final ChannelPipeline addFirst(EventExecutorGroup group, String name, ChannelHandler handler) {
        final AbstractChannelHandlerContext newCtx;
        synchronized (this) {
            // 检查handler是否能够共享
            checkMultiplicity(handler);
            // 给AbstractChannelHandlerContext起个独立的名字
            name = filterName(name, handler);
            // 建立DefaultChannelHandlerContext
            newCtx = newContext(group, name, handler);
            // 执行实际的添加操做
            addFirst0(newCtx);
            // channel还没有注册到eventloop
            if (!registered) {
                // 设置newCtx的状态为ADD_PENDING
                newCtx.setAddPending();
                // 设置过一会回调ChannelHandler的handlerAdded方法
                callHandlerCallbackLater(newCtx, true);
                return this;
            }
            EventExecutor executor = newCtx.executor();
            if (!executor.inEventLoop()) {
                newCtx.setAddPending();
                executor.execute(new Runnable() {
                    @Override
                    public void run() {
                        callHandlerAdded0(newCtx);
                    }
                });
                return this;
            }
        }
        callHandlerAdded0(newCtx);
        return this;
    }
复制代码

addFirst方法先检查添加的ChannelHandler是否能够共享（判断共享的方法是对于每一个channel当前ChannelHandler是否须要不一样的状态），再建立ChannelHandler的上下文关系，使ChannelHandler以链表方式存在于ChannelPipeline中。当ChannelHandler添加成功后，再调用ChannelHandler的handlerAdded方法。其它的添加方式和addFirst相似。

事件触发

以fireChannelActive方法为例：

public final ChannelPipeline fireChannelActive() {
        AbstractChannelHandlerContext.invokeChannelActive(head);
        return this;
    }
复制代码

从HeadContext的head开始，依次触发下一个ChannelHandler的channelActive方法。

本篇简单介绍了ChannelPipeline的相关概念，当ChannelHandler介绍完后，再具体介绍ChannelPipeline中的HeadContext和TailContext。

文中帖的代码注释全在：KAMIJYOUDOUMA， 有兴趣的童鞋能够关注一下。

---

本篇到此结束，若是读完以为有收获的话，欢迎点赞、关注、加公众号【贰级天災】，查阅更多精彩历史！！！