Netty:Channel

来源:https://www.cnblogs.com/iou123lg/archive/2020/04/10/12676413.html
-Advertisement-
Play Games

上一篇我們通過一個簡單的Netty代碼瞭解到了Netty中的核心組件,這一篇我們將圍繞核心組件中的Channel來展開學習。 Channel的簡介 Channel代表著與網路套接字或者能夠進行IO操作(read、write、connect或者bind)的組件的聯繫,一個Channel向用戶提供瞭如下 ...


上一篇我們通過一個簡單的Netty代碼瞭解到了Netty中的核心組件,這一篇我們將圍繞核心組件中的Channel來展開學習。

Channel的簡介

Channel代表著與網路套接字或者能夠進行IO操作(read、write、connect或者bind)的組件的聯繫,一個Channel向用戶提供瞭如下內容:

1、Channel當前的狀態,比如是否打開、是否連接;

2、Channel的配置參數,比如接收緩衝區的大小;

3、Channel支持的IO操作(read、write、connect或者bind);

4、用於支持處理與Channel關聯的所有IO事件和請求的ChannelPipeline組件。

Netty中的所有IO操作都是非同步的。這意味著任何IO調用都將立即返回,而不能保證所請求的IO操作在調用結束時完成。相反,將返回一個帶有ChannelFuture的實例,該實例將在請求的IO操作成功、失敗或取消時通知應用。

Channel可以具有父級,具體取決於其創建方式。例如,SocketChannel在ServerSocketChannel接受它時,通過parent()方法將ServerSocketChannel作為它的父級返回。層次結構的語義取決於Channel所屬的傳輸實現。例如,可以編寫一個新的Channel實現,以創建共用一個套接字連接的子通道,就像BEEP和SSH一樣。

某些傳輸公開了特定於該傳輸的其他操作,可以將Channel向下轉換為子類型以調用此類操作。例如,對於舊的IO數據報傳輸,DatagramChannel提供了join /leave操作。

一旦使用完Channel,調用close()或close(ChannelPromise)釋放資源就顯得尤為重要,這樣做可以確保以適當的方式(即文件句柄)釋放所有資源。

 

Channel的方法

學習Channel提供的方法,其實可以結合上述簡介部分來看。

比如,有關Channel的狀態,我們可以看到這幾個方法:

 

 是否打開看isOpen方法,是否註冊到EventLoop看isRegistered方法,是否連接看isActive方法。

Channel的配置參數方法可以看config方法:

 該方法返回了ChannelConfig對象,這個介面定義了Channel的配置參數集合,但是在實際應用中,需結合實際的傳輸協議來設置具體的ChannelConfig,比如對於TCP/IP協議,需要具體被設置的對象就是SocketChannelConfig。

 通過pipeline()方法,可以獲取到Channel的ChannelPipeline對象,正如上文所述,ChannelPipeline也是Netty的核心組件,它可以理解為是ChannelHandler的容器,用於處理Channel的所有事件。

簡介中提到了Netty非同步操作會返回ChannelFuture對象,那麼在Channel所提供的方法中是如何體現和這個對象的交互的呢?答案就是我們可以從closeFuture()方法中看到ChannelFuture對象,這個方法告訴我們Channel關閉時將返回用於通知的ChannelFuture,只有Channel真正的被關閉完成後,才會通過ChannelFuture回調通知到應用。

 關於ChannelPipeline、ChannelHandler和ChannelFuture,我們將在後續的文章中學習。

除了上述方法,Channel還有很多方法,比如:

 每一個Channel都可以有自己的id,ChannelId有2個主要的方法,asShortText()會返回短的但是全局不唯一的標識符,asLongText()會返回長的同時全局唯一的標識符。

eventLoop()會返回Channel所註冊之上的EventLoop,EventLoop也是Netty的核心組件,我們也將在後續的文章中學習。

parent()會返回Channel的父級,如果沒有父級則返回null。

另外Channel中還有一個內部類Unsafe,這個類的方法不建議外部使用,僅限於Netty內部使用。

源碼流程

以服務端為例,在我們服務端DEMO中,可以看到代碼中並未顯式的創建Channel和將Channel註冊到EventLoop,那麼服務端啟動時是如何創建Channel及將Channel註冊到EventLoop呢?讓我們一起來看下啟動的源代碼,一窺究竟。

 首先,在Server中調用的是bind方法,bind裡面調用的是doBind。

 在doBind中,進入了啟動的核心邏輯initAndRegister。

 initAndRegister,顧名思義,就是初始化和註冊,初始化前就有Channel的創建,註冊裡面包含了Channel註冊到EventLoop的過程。

 讓我們繼續看Channel是如何創建的,調用了ReflectiveChannelFactory的newChannel方法,是通過反射的方式來創建的Channel。

 進入到我們的DemoServer中的NioServerSocketChannel,繼續查看它的構造方法。

 

 

 

 

 經過一步一步的跟進,可以在AbstractChannel看到Channel的構造過程,在這個方法中,我們可以看到熟悉的id、parent、unsafe和pipeline,這些都是Channel中的關鍵屬性或者對象。

 

 

 創建完成後,先忽略初始化,咱們再來看下Channel是如何註冊的?我們來看config().group().register(channel)。

 先來看下next()方法返回的是什麼?

 

 

 最後可以發現next()方法返回的是SingleThreadEventLoop,其實到這一步我們也可以知道Netty中的MultithreadEventLoopGroup裡面可以獲取到很多SingleThreadEventLoop,而SingleThreadEventLoop是一個單線程任務執行的事件迴圈,在它的父類SingleThreadEventExecutor中我們可以找到這個Thread。

繼續看register方法。

 最後會進入到真正的執行註冊的AbstractUnsafe類的register0方法中。

 進一步跟進,調用doRegister方法。

 

 最終會進入到AbstractNioChannel的doRegister方法。在這裡我們可以看到NIO的身影,比如SelectionKey、Selector等。到這裡,我們就可以看到Channel是如何註冊到NioEventLoop,它的底層本質也就是NIO中的Channel註冊到Selector,因為在NioEventLoop中集成了一個Selector。

 

 至此,我們已經知道了Channel的創建和註冊的過程。

 

 

最後總結一下:

1、服務端這塊,Channel創建的過程是通過反射來創建的,最終是進入到了AbstractChannel的構造函數中;

2、服務端這塊,Channel註冊到EventLoop的過程,本質上也就是NIO中的Channel註冊到Selector的過程;

3、看源碼的過程中,其實還有很多有意思的細節,比如創建Channel的同時其實ChannelPipeline也創建好了,註冊的時候其實會判斷註冊線程和當前線程是不是一個線程來看是立即註冊還是新起線程註冊?這些後面再來進一步的學習和分析。


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 鏡像用法 修改 composer 的全局配置文件(推薦方式) 打開命令行視窗(windows用戶)或控制台(Linux、Mac 用戶)並執行如下命令: composer config -g repo.packagist composer https://packagist.phpcomposer.c ...
  • 緩衝區的出現提高了對數據的讀寫效率。 緩衝區要結合流才可以使用。 在流的基礎上對流的功能進行了增強。 該緩衝區提供了跨平臺的換行符。newLine(); public class BufferedWriterDemo { public static void main(String[] args) ...
  • 作者: "DeppWang" 、 "原文地址" 人生在世,誰不面試。單例模式:一個搞懂不加分,不搞懂減分的知識點 又一篇一抓一大把的博文,可是你真的的搞懂了嗎?點開看看。。事後,你也來一篇。 單例模式是面試中非常喜歡問的了,我們往往自認為已經完全理解了,沒什麼問題了。但要把它手寫出來的時候,可能出現 ...
  • 使用 pip 安裝 pipenv pip install pipenv 拋出錯誤異常 連接超時 time out 解決方案 更換國內資源 操作: 在C:\Users\Administrator\下新建pip文件夾,在創建pip.ini文件,拷貝下麵代碼進去,保存 切換下載源地址為 [global] ...
  • 通俗理解spring源碼(一)—— 容器的基本實現 大家都知道spring的主要功能就是將本來由我們程式員new出來的對象,交給spring管理。這個管理不僅包括實例化的過程,還包括依賴註入等整個bean生命周期的管理。而spring是通過一個容器,來管理所有bean的。 spring容器的概念,和 ...
  • public class CopyText { public static void main(String[] args) { copy_1(); } public static void copy_1() { FileWriter fw = null; FileReader fr = null; ...
  • 垃圾回收器的發展歷程 背景 01、 解決的問題 垃圾回收器是 年正式提出, 開始正式支持,在 年作為 預設的垃圾處理器。 在 年的時候, 程式堆的記憶體越來越大,從而導致程式中可存活的活對象越來越多,因此 的`STW G1 STW`帶來的停頓時間太長了 。 在此之前效率也很高,但活對象數量一多, 時間 ...
  • 雖然目前越來越多的國產優秀技術產品走出了國門,但是對於眾領域的開發者來說,依然對於國外的各種基礎資源依賴還是非常的強。所以,一些網路基本技能一直都是我們需要掌握的,但是速度與穩定性問題一直也都有困擾著大家。 所以,今天就給眾 Java 開發者推薦兩個提速神器:Maven的國內鏡像和Spring的國內 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發(一):使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說,近來想嘗試開發一款安卓APP,考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP,畢竟是使用Visual Studio開發工具,使用起來也比較的順手,結合微軟官方的教程進行了安卓 ...
  • 前言 QuestPDF 是一個開源 .NET 庫,用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫,它徹底改變了我們生成 PDF 文檔的方 ...
  • 項目地址 項目後端地址: https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址: ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址: http://tree ...
  • 話不多說,直接開乾 一.下載 1.官方鏈接下載: https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe,運行開始下載SQL server; 二. ...
  • 前言 隨著物聯網(IoT)技術的迅猛發展,MQTT(消息隊列遙測傳輸)協議憑藉其輕量級和高效性,已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫,為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog支持多種接收器用於日誌存儲,增強器用於添加屬性,LogContext管理動態屬性,支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項,適用於不同需求。 ...
  • 目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據,爬取信息時需要模擬瀏覽器行為,否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下: 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • 1.前言 什麼是熱更新 游戲或者軟體更新時,無需重新下載客戶端進行安裝,而是在應用程式啟動的情況下,在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR,Xlua,ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles,Addressable, ...
  • 本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺,其實像阿裡雲,騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後,它會送 ...
  • 通過以下方式可以高效,並保證數據同步的可靠性 1.API設計 使用RESTful設計,確保API端點明確,並使用適當的HTTP方法(如POST用於創建,PUT用於更新)。 設計清晰的請求和響應模型,以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...