一、Channel
Channel是一個(gè)接口,而且是一個(gè)很大的接口,我們稱之為“大而全”,囊括了server端及client端接口所需要的接口。
Channel是一個(gè)門(mén)面,封裝了包括網(wǎng)絡(luò)I/O及相關(guān)的所有操作。
Channel聚合了包括網(wǎng)絡(luò)讀寫(xiě)、鏈路管理、網(wǎng)絡(luò)連接信息、獲取EventLoop、Pipeline等相關(guān)功能類;統(tǒng)一分配,調(diào)度實(shí)現(xiàn)相應(yīng)場(chǎng)景的功能。
一個(gè)Channel 對(duì)應(yīng)一個(gè)物理連接,是基于物理連接上的操作包裝。
二、EventLoop
EventLoop,Event意為事件、Loop意為環(huán),EventLoo即為事件環(huán)。
EventLoop是一種程序設(shè)計(jì)結(jié)構(gòu),等待以及分發(fā)事件。
NioEventLoop,是一個(gè)Netty工作線程,又不僅僅是一個(gè)Netty工作線程。
標(biāo)準(zhǔn)的netty線程模型 中我們講過(guò)Netty的標(biāo)準(zhǔn)線程池模型,池子里的每個(gè)線程對(duì)象就是一個(gè)NioEventLoop對(duì)象。或負(fù)責(zé)接受連接,或負(fù)責(zé)網(wǎng)絡(luò)I/O。
說(shuō)它不僅僅是一個(gè)Netty線程,因?yàn)樗鼘?shí)現(xiàn)了很多功能,我們可以看下它的繼承圖:
它的上方有兩個(gè)枝丫,一個(gè)線程屬性,一個(gè)EventLoop,它是Netty的Reactor線程。
既然是Reactor線程,那么首先我們需要一個(gè)多路復(fù)用器。在Netty NioEventLoop中,包就含一個(gè) Selector,它的操作對(duì)象是Channel。
NioEventLoop的主要邏輯在它的run()方法,方法體內(nèi)是一個(gè)無(wú)限循環(huán) for (;;),循環(huán)體內(nèi)實(shí)現(xiàn)Loop功能。這也是通用的NIO線程實(shí)現(xiàn)方式。
Loop 從任務(wù)隊(duì)列里獲取任務(wù),然后檢查多路復(fù)用器中就緒的Channel進(jìn)行處理。
三、Unsafe
Netty中的Unsafe,一個(gè)Channel內(nèi)部聚合接口,用以處理實(shí)際的網(wǎng)絡(luò)I/O讀寫(xiě)。當(dāng)然,取Unsafe命名,源碼中釋義:提供的網(wǎng)絡(luò)相關(guān)的操作方法,永遠(yuǎn)不應(yīng)該被開(kāi)發(fā)人員操作使用。
它是Channel的一個(gè)輔助接口,主要方法:
1、register:注冊(cè)Channel
2、deregister:取消注冊(cè)
3、bind:綁定地址,服務(wù)端綁定監(jiān)聽(tīng)特定端口;客戶端指定本地綁定Socket地址。
4、connect:建立連接
5、disconnect:斷開(kāi)連接
6、close:關(guān)閉連接
7、write:調(diào)度寫(xiě),將數(shù)據(jù)寫(xiě)入buffer,并未真正進(jìn)入Channel
8、flush:將緩沖區(qū)中的數(shù)據(jù)寫(xiě)入Channel
四、AdaptiveRecvByteBufAllocator
動(dòng)態(tài)緩沖區(qū)分配器,源碼說(shuō)明:根據(jù)實(shí)時(shí)的反饋動(dòng)態(tài)的增加或者減少預(yù)需的緩沖區(qū)大小。
如果上一次分配的緩沖區(qū)被填滿了,則調(diào)高下一次分配的緩沖區(qū)大小。
如果連續(xù)兩次實(shí)際使用的容量低于分配的緩沖區(qū)大小特定比例,則減小下一次分配的緩沖區(qū)大小。
其它情景,保持分配大小不變。
Netty的這種“智能化”處理,可以說(shuō)是相當(dāng)有用的:
1、首先,實(shí)際的應(yīng)用場(chǎng)景千差萬(wàn)別,同一場(chǎng)景下不同時(shí)刻的緩沖區(qū)需求也是實(shí)時(shí)變化(一句話可以是一個(gè)字,也可能是1000個(gè)字),這就需要Netty動(dòng)態(tài)調(diào)整緩沖分配大小以適應(yīng)不同的業(yè)務(wù)場(chǎng)景,時(shí)刻場(chǎng)景。
2、其次,過(guò)大的不必要的內(nèi)存分配,會(huì)導(dǎo)致Buffer處理性能下降;過(guò)小的內(nèi)存分配,則會(huì)導(dǎo)致頻繁的分配釋放。這都是一個(gè)優(yōu)良的網(wǎng)絡(luò)框架不應(yīng)該有的。
3、最后,動(dòng)態(tài)的調(diào)整最直接的好處就是內(nèi)存的的高效使用,一定程度上做到了按需分配。
五、ChannelPipeline
Pipeline 管道,Channel的數(shù)據(jù)流通管道,在這個(gè)管道中,可以做很多事情。
ChannelPipeline 是一種職責(zé)鏈,可以對(duì)其中流動(dòng)的數(shù)據(jù)進(jìn)行過(guò)濾、攔截處理,是一種插拔式的鏈路裝配器。
1、ChannelPipline是一個(gè)容器
支持查詢、添加、刪除、替換等容器操作。
2、ChannelPipline支持動(dòng)態(tài)的添加和刪除 Handler
ChannelPipline的這種特性給了我們相當(dāng)?shù)南胂罂臻g,例如動(dòng)態(tài)的添加系統(tǒng)擁塞保護(hù)Handler,敏感數(shù)據(jù)過(guò)濾Handler、日志記錄Handler、性能統(tǒng)計(jì)Handler等。
3、ChannelPipline 是線程安全的
ChannelPipline使用 synchronized 實(shí)現(xiàn)線程安全,業(yè)務(wù)線程可以并發(fā)的操作ChannelPipline。但需要注意的是,Handler是非線程安全的。
六、HandlerAdapter
Adapter是一種適配器,對(duì)于用戶自定義的Handler,可以通過(guò)繼承HandlerAdapter,來(lái)規(guī)避不必要的接口實(shí)現(xiàn)。
作者:WindWant
來(lái)源:
https://www.cnblogs.com/niejunlei/p/13155554.html