Channel 与ChannelPipeline
相信大家都已經(jīng)知道,在Netty 中每個(gè)Channel 都有且僅有一個(gè)ChannelPipeline 與之對(duì)應(yīng),它們的組成關(guān)系如下:
通過上圖我們可以看到, 一個(gè)Channel 包含了一個(gè)ChannelPipeline , 而ChannelPipeline 中又維護(hù)了一個(gè)由ChannelHandlerContext 組成的雙向鏈表。這個(gè)鏈表的頭是HeadContext,鏈表的尾是TailContext,并且每個(gè)ChannelHandlerContext 中又關(guān)聯(lián)著一個(gè)ChannelHandler。
上面的圖示給了我們一個(gè)對(duì)ChannelPipeline 的直觀認(rèn)識(shí),但是實(shí)際上Netty 實(shí)現(xiàn)的Channel 是否真的是這樣的呢?我們繼續(xù)用源碼說話。在前我們已經(jīng)知道了一個(gè)Channel 的初始化的基本過程,下面我們?cè)倩仡櫼幌隆O旅娴拇a是AbstractChannel 構(gòu)造器:
protected AbstractChannel(Channel parent) {this.parent = parent;id = newId();unsafe = newUnsafe();pipeline = newChannelPipeline(); }AbstractChannel 有一個(gè)pipeline 字段,在構(gòu)造器中會(huì)初始化它為DefaultChannelPipeline 的實(shí)例。這里的代碼就印證了一點(diǎn):每個(gè)Channel 都有一個(gè)ChannelPipeline。接著我們跟蹤一下DefaultChannelPipeline 的初始化過程,首先進(jìn)入到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)造器中, 首先將與之關(guān)聯(lián)的Channel 保存到字段channel 中。然后實(shí)例化兩個(gè)ChannelHandlerContext:一個(gè)是HeadContext 實(shí)例head,另一個(gè)是TailContext 實(shí)例tail。接著將head 和tail 互相指向, 構(gòu)成一個(gè)雙向鏈表。
特別注意的是:我們?cè)陂_始的示意圖中head 和tail 并沒有包含ChannelHandler,這是因?yàn)镠eadContext 和TailContext繼承于AbstractChannelHandlerContext 的同時(shí)也實(shí)現(xiàn)了ChannelHandler 接口了,因此它們有Context 和Handler的雙重屬性。
?
總結(jié)
以上是生活随笔為你收集整理的Channel 与ChannelPipeline的全部?jī)?nèi)容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: RPC实现Consumer 远程调用
- 下一篇: 再探ChannelPipeline 的初