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， 有興趣的童鞋能夠關注一下。

---

本篇到此結束，若是讀完以爲有收穫的話，歡迎點贊、關注、加公衆號【貳級天災】，查閱更多精彩歷史！！！