再探ChannelPipeline 的初始化
前面我們已經(jīng)對(duì)ChannelPipeline 的初始化有了一個(gè)大致的了解,不過(guò)當(dāng)時(shí)重點(diǎn)沒(méi)有關(guān)注ChannelPipeline,因此沒(méi)有深入地分析它的初始化過(guò)程。那么下面我們就來(lái)看一下具體的ChannelPipeline 的初始化都做了哪些工作吧。先回顧一下,在實(shí)例化一個(gè)Channel 時(shí),會(huì)伴隨著一個(gè)ChannelPipeline 的實(shí)例化,并且此Channel 會(huì)與這個(gè)ChannelPipeline相互關(guān)聯(lián),這一點(diǎn)可以通過(guò)NioSocketChannel 的父類AbstractChannel 的構(gòu)造器予以佐證:
protected AbstractChannel(Channel parent) {this.parent = parent;id = newId();unsafe = newUnsafe();pipeline = newChannelPipeline(); }當(dāng)實(shí)例化一個(gè)NioSocketChannel 是,其pipeline 字段就是我們新創(chuàng)建的DefaultChannelPipeline 對(duì)象,那么我們就來(lái)看一下DefaultChannelPipeline 的構(gòu)造方法。
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 的構(gòu)造方法中,將傳入的channel 賦值給字段this.channel,接著又實(shí)例化了兩個(gè)特殊的字段:tail 與head,這兩個(gè)字段是一個(gè)雙向鏈表的頭和尾。其實(shí)在DefaultChannelPipeline 中,維護(hù)了一個(gè)以AbstractChannelHandlerContext 為節(jié)點(diǎn)的雙向鏈表,這個(gè)鏈表是Netty 實(shí)現(xiàn)Pipeline 機(jī)制的關(guān)鍵。再回顧一下head和tail 的類層次結(jié)構(gòu):
從類層次結(jié)構(gòu)圖中可以很清楚地看到,head 實(shí)現(xiàn)了ChannelInboundHandler,而tail 實(shí)現(xiàn)了ChannelOutboundHandler 接口,并且它們都實(shí)現(xiàn)了ChannelHandlerContext 接口, 因此可以說(shuō)head 和tail 即是一個(gè)ChannelHandler,又是一個(gè)ChannelHandlerContext。接著看HeadContext 構(gòu)造器中的代碼:
HeadContext(DefaultChannelPipeline pipeline) {super(pipeline, null, HEAD_NAME, false, true);unsafe = pipeline.channel().unsafe();setAddComplete(); }它調(diào)用了父類AbstractChannelHandlerContext 的構(gòu)造器,并傳入?yún)?shù)inbound = false,outbound = true。而TailContext 的構(gòu)造器與HeadContext 正好相反,它調(diào)用了父類AbstractChannelHandlerContext 的構(gòu)造器,并傳入?yún)?shù)inbound = true,outbound = false。也就是說(shuō)header 是一個(gè)OutBoundHandler,而tail 是一個(gè)InboundHandler,關(guān)于這一點(diǎn),大家要特別注意,因?yàn)樵诤竺娴姆治鲋?#xff0c;我們會(huì)反復(fù)用到inbound 和outbound 這兩個(gè)屬性。
?
總結(jié)
以上是生活随笔為你收集整理的再探ChannelPipeline 的初始化的全部?jī)?nèi)容,希望文章能夠幫你解決所遇到的問(wèn)題。
- 上一篇: Channel 与ChannelPipe
- 下一篇: ChannelInitializer 的