再探ChannelPipeline 的初始化
前面我們已經對ChannelPipeline 的初始化有了一個大致的了解,不過當時重點沒有關注ChannelPipeline,因此沒有深入地分析它的初始化過程。那么下面我們就來看一下具體的ChannelPipeline 的初始化都做了哪些工作吧。先回顧一下,在實例化一個Channel 時,會伴隨著一個ChannelPipeline 的實例化,并且此Channel 會與這個ChannelPipeline相互關聯,這一點可以通過NioSocketChannel 的父類AbstractChannel 的構造器予以佐證:
protected AbstractChannel(Channel parent) {this.parent = parent;id = newId();unsafe = newUnsafe();pipeline = newChannelPipeline(); }當實例化一個NioSocketChannel 是,其pipeline 字段就是我們新創建的DefaultChannelPipeline 對象,那么我們就來看一下DefaultChannelPipeline 的構造方法。
protected DefaultChannelPipeline(Channel channel) {this.channel = ObjectUtil.checkNotNull(channel, "channel");succeededFuture = new SucceededChannelFuture(channel, null);voidPromise = new VoidChannelPromise(channel, true);tail = new TailContext(this);head = new HeadContext(this);head.next = tail;tail.prev = head; }可以看到,在DefaultChannelPipeline 的構造方法中,將傳入的channel 賦值給字段this.channel,接著又實例化了兩個特殊的字段:tail 與head,這兩個字段是一個雙向鏈表的頭和尾。其實在DefaultChannelPipeline 中,維護了一個以AbstractChannelHandlerContext 為節點的雙向鏈表,這個鏈表是Netty 實現Pipeline 機制的關鍵。再回顧一下head和tail 的類層次結構:
從類層次結構圖中可以很清楚地看到,head 實現了ChannelInboundHandler,而tail 實現了ChannelOutboundHandler 接口,并且它們都實現了ChannelHandlerContext 接口, 因此可以說head 和tail 即是一個ChannelHandler,又是一個ChannelHandlerContext。接著看HeadContext 構造器中的代碼:
HeadContext(DefaultChannelPipeline pipeline) {super(pipeline, null, HEAD_NAME, false, true);unsafe = pipeline.channel().unsafe();setAddComplete(); }它調用了父類AbstractChannelHandlerContext 的構造器,并傳入參數inbound = false,outbound = true。而TailContext 的構造器與HeadContext 正好相反,它調用了父類AbstractChannelHandlerContext 的構造器,并傳入參數inbound = true,outbound = false。也就是說header 是一個OutBoundHandler,而tail 是一個InboundHandler,關于這一點,大家要特別注意,因為在后面的分析中,我們會反復用到inbound 和outbound 這兩個屬性。
?
總結
以上是生活随笔為你收集整理的再探ChannelPipeline 的初始化的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: Channel 与ChannelPipe
- 下一篇: ChannelInitializer 的