摘要:支持很多協(xié)議,并且提供用于數(shù)據(jù)處理的容器。我們已經(jīng)知道由特定事件觸發(fā)??蓪S糜趲缀跛械膭幼?,包括將一個(gè)對象轉(zhuǎn)為字節(jié)或相反,執(zhí)行過程中拋出的異常處理。提供了一個(gè)容器給鏈并提供了一個(gè)用于管理沿著鏈入站和出站事件的流動。子類通過進(jìn)行注冊。
前兩天寫了一點(diǎn)netty相關(guān)的知識,并寫了一個(gè)demo,但是對其原理還是沒有深入,今天我們來做一次研究吧
首先讓我們來認(rèn)識一下netty的幾個(gè)核心人物吧
BOOTSTRAPNetty 應(yīng)用程序通過設(shè)置 bootstrap(引導(dǎo))類的開始,該類提供了一個(gè) 用于應(yīng)用程序網(wǎng)絡(luò)層配置的容器。
ServerChannel實(shí)現(xiàn)負(fù)責(zé)創(chuàng)建子 Channel,它代表接受連接
在調(diào)用 bind() 或 connect() 之后,Bootstrap 類負(fù)責(zé)創(chuàng)建管道給客戶或應(yīng)用程序,
CHANNEL底層網(wǎng)絡(luò)傳輸 API 必須提供給應(yīng)用 I/O操作的接口,如讀,寫,連接,綁定等等。對于我們來說,這層結(jié)構(gòu)幾乎總是會成為一個(gè)“socket”。 Netty 中的接口 Channel 定義了與 socket 豐富交互的操作集:bind, close, config, connect, isActive, isOpen, isWritable, read, write 等等。 Netty 提供大量的 Channel 實(shí)現(xiàn)來專門使用。這些包括 AbstractChannel,AbstractNioByteChannel,AbstractNioChannel,EmbeddedChannel, LocalServerChannel,NioSocketChannel 等等。
CHANNELHANDLERChannelHandler支持很多協(xié)議,并且提供用于數(shù)據(jù)處理的容器。我們已經(jīng)知道 ChannelHandler 由特定事件觸發(fā)。 ChannelHandler 可專用于幾乎所有的動作,包括將一個(gè)對象轉(zhuǎn)為字節(jié)(或相反),執(zhí)行過程中拋出的異常處理。
常用的一個(gè)接口是 ChannelInboundHandler,這個(gè)類型接收到入站事件(包括接收到的數(shù)據(jù))可以處理應(yīng)用程序邏輯。當(dāng)你需要提供響應(yīng)時(shí),你也可以從 ChannelInboundHandler 沖刷數(shù)據(jù)。一句話,業(yè)務(wù)邏輯經(jīng)常存活于一個(gè)或者多個(gè) ChannelInboundHandler。
ChannelPipeline 提供了一個(gè)容器給 ChannelHandler 鏈并提供了一個(gè)API 用于管理沿著鏈入站和出站事件的流動。每個(gè) Channel 都有自己的ChannelPipeline,當(dāng) Channel 創(chuàng)建時(shí)自動創(chuàng)建的。 ChannelHandler 是如何安裝在 ChannelPipeline? 主要是實(shí)現(xiàn)了ChannelHandler 的抽象 ChannelInitializer。ChannelInitializer子類 通過 ServerBootstrap 進(jìn)行注冊。當(dāng)它的方法 initChannel() 被調(diào)用時(shí),這個(gè)對象將安裝自定義的 ChannelHandler 集到 pipeline。當(dāng)這個(gè)操作完成時(shí),ChannelInitializer 子類則 從 ChannelPipeline 自動刪除自身。
1.Channel 綁定到 ChannelPipeline
2.ChannelPipeline 綁定到 包含 ChannelHandler 的 Channel
3.ChannelHandler
4.當(dāng)添加 ChannelHandler 到 ChannelPipeline 時(shí),ChannelHandlerContext 被創(chuàng)建
EventLoop 用于處理 Channel 的 I/O 操作。一個(gè)單一的 EventLoop通常會處理多個(gè) Channel 事件。一個(gè) EventLoopGroup 可以含有多于一個(gè)的 EventLoop 和 提供了一種迭代用于檢索清單中的下一個(gè)。
簡單點(diǎn)來說,EventLoopGroup 是一個(gè)線程池,EventLoop是其中一個(gè)線程
但netty并不僅限于此
一旦 Channel 是分配給一個(gè) EventLoop,它將使用這個(gè) EventLoop 在它的生命周期里和同樣的線程。你可以,也應(yīng)該,依靠這個(gè),因?yàn)樗梢源_保你不需要擔(dān)心同步(包括線程安全、可見性和同步)在你 ChannelHandler實(shí)現(xiàn)。
Netty 所有的 I/O 操作都是異步。因?yàn)橐粋€(gè)操作可能無法立即返回,我們需要有一種方法在以后確定它的結(jié)果。出于這個(gè)目的,Netty 提供了接口 ChannelFuture,它的 addListener 方法注冊了一個(gè) ChannelFutureListener ,當(dāng)操作完成時(shí),可以被通知(不管成功與否)。
文章版權(quán)歸作者所有,未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為,您可以聯(lián)系管理員刪除。
轉(zhuǎn)載請注明本文地址:http://systransis.cn/yun/66351.html
摘要:是一個(gè)高性能事件驅(qū)動的異步的非堵塞的框架,用于建立等底層的連接,基于可以建立高性能的服務(wù)器。在中提供了兩套,一套是針對標(biāo)準(zhǔn)輸入輸出,另一套就是網(wǎng)絡(luò)編程。和是標(biāo)準(zhǔn)中的核心對象是對原中流的模擬,任何來源和目的數(shù)據(jù)都必須通過一個(gè)對象。 Netty是一個(gè)高性能 事件驅(qū)動的異步的非堵塞的IO(NIO)框架,用于建立TCP等底層的連接,基于Netty可以建立高性能的Http服務(wù)器。1、首先來復(fù)習(xí)下...
摘要:前提好幾周沒更新博客了,對不斷支持我博客的童鞋們說聲抱歉了。熟悉我的人都知道我寫博客的時(shí)間比較早,而且堅(jiān)持的時(shí)間也比較久,一直到現(xiàn)在也是一直保持著更新狀態(tài)。 showImg(https://segmentfault.com/img/remote/1460000014076586?w=1920&h=1080); 前提 好幾周沒更新博客了,對不斷支持我博客的童鞋們說聲:抱歉了!。自己這段時(shí)...
摘要:背景在工作中雖然我經(jīng)常使用到庫但是很多時(shí)候?qū)Φ囊恍└拍钸€是處于知其然不知其所以然的狀態(tài)因此就萌生了學(xué)習(xí)源碼的想法剛開始看源碼的時(shí)候自然是比較痛苦的主要原因有兩個(gè)第一網(wǎng)上沒有找到讓我滿意的詳盡的源碼分析的教程第二我也是第一次系統(tǒng)地學(xué)習(xí)這么大代 背景 在工作中, 雖然我經(jīng)常使用到 Netty 庫, 但是很多時(shí)候?qū)?Netty 的一些概念還是處于知其然, 不知其所以然的狀態(tài), 因此就萌生了學(xué)...
摘要:零前期準(zhǔn)備文章異常啰嗦且繞彎。二是底層真正起作用的類,并且提供了大量的靜態(tài)方法。在普通的線程中,這個(gè)對象由于本身沒有的原生支持,所以只能附著在對象當(dāng)中。同一個(gè)線程中如果創(chuàng)建多個(gè)對象,獲取到的是同一個(gè)。 零 前期準(zhǔn)備 0 FBI WARNING 文章異常啰嗦且繞彎。 1 版本 JDK 版本 : OpenJDK 11.0.1 IDE : idea 2018.3 Netty 版本 : net...
摘要:它使用了事件通知以確定在一組非阻塞套接字中有哪些已經(jīng)就緒能夠進(jìn)行相關(guān)的操作。目前,可以把看作是傳入入站或者傳出出站數(shù)據(jù)的載體。出站事件是未來將會觸發(fā)的某個(gè)動作的操作結(jié)果,這些動作包括打開或者關(guān)閉到遠(yuǎn)程節(jié)點(diǎn)的連接將數(shù)據(jù)寫到或者沖刷到套接字。 netty的概念 定義 Netty 是一款異步的事件驅(qū)動的網(wǎng)絡(luò)應(yīng)用程序框架,支持快速地開發(fā)可維護(hù)的高性能的面向協(xié)議的服務(wù)器和客戶端。我們可以很簡單的...
閱讀 1236·2021-11-11 16:54
閱讀 1749·2021-10-13 09:40
閱讀 946·2021-10-08 10:05
閱讀 3511·2021-09-22 15:50
閱讀 3714·2021-09-22 15:41
閱讀 1812·2021-09-22 15:08
閱讀 2352·2021-09-07 10:24
閱讀 3583·2019-08-30 12:52