Netty:數據處理流程

来源:http://www.cnblogs.com/f1194361820/archive/2016/07/09/5656440.html
-Advertisement-
Play Games

Netty作為非同步的、事件驅動一個網路通信框架,使用它可以幫助我們快速開發高性能高可靠性的網路服務。 為了更好的使用Netty來解決開發中的問題,學習Netty是很有必要的。 Netty現在主流有三個版本:Netty3、Netty4、Netty5。這三個版本中,變化最大的要數線程模型了,各版本的線程 ...


Netty作為非同步的、事件驅動一個網路通信框架,使用它可以幫助我們快速開發高性能高可靠性的網路服務。

         為了更好的使用Netty來解決開發中的問題,學習Netty是很有必要的。

         Netty現在主流有三個版本:Netty3、Netty4、Netty5。這三個版本中,變化最大的要數線程模型了,各版本的線程模型均不相同。但是有一點是變化不大的,那就是Channel模型,因而數據處理流程也不會有太大的變化。所以本篇就來說一下Netty的數據處理流程,各版本的線程模型會後續說明。

 

Channel 模型

         關於Netty Channel的模型,做了一個簡易圖:

 

 

一個Channel中包括一個Socket、一個ChannelPipeline。一個ChannelPipeline中有一個ChannelSink和多個ChannelHandler。ChannelHandler分為兩種:UpstremHandler、DownstreamHandler。

 

不論是讀數據還是寫數據都要經過Channel中的ChannelPipeline。讀數據的過程是從Socket到ChannelPipeline,由ChannelPipeline交給裡面的UpstreamHandler(或者叫做InBoundHandler)從下到上依次處理 。寫數據時,由要經過ChannelPipeline裡面在DownStreamHandler(或者是OutBoundHandler)由上到下依次處理。

 

 

Channel的創建

Channel主要分為兩種:ServerSocketChannel、SocketSocketChannel。這裡不對是否是NIO作區分。

ServerSocketChannel的創建在bind時自動完成,SocketChannel的創建由Netty幫助完成。不論是客戶端在創建連接時, 還是服務端接收到客戶端連接時,SocketChannel的創建都是由Netty幫助完成

         在創建Channel時,就會自動調用相應的ChannelPipeline創建器來創建了。在創建ChannelPipeline時,可以由用戶配置相關的ChannelHandler。ServerSocketChannel可以由用戶定製一個ChannelHandler,SocketChannel則可以由用戶定製多個ChannelHandler。

 

在各版本中用於定製的方法可能是不同的。

 

 

 

ChannelSink

這個組件主要見於V3

ChannelSink的有2個作用:

1、當出現異常時,通過exceptionCaught向沿著Pipeline上傳遞ExceptionEvent,(channel.getPipeline().sendUpsteam(new DefaultExceptionEv ent(channel,ex)));

2、當一個Message或者一個Events沿著Pipeline從上到下執行完所有的ChannelHandler處理後,進入ChannelSink的eventSunk方法。

 

 

下麵就說一下Server端、Client端的Sink的作用:

ServerSocketPipelineSink eventSunk:

  • 當創建ServerSocket時,提交Boss任務。
  • 當接收到Socket時,創建SocketChannel,並將一個Worker任務交給Worker Executor。

 

ClientSocketPipelineSink eventSunk:

1)當在Pipeline上流轉的是ChannelEvent時:

·如果是創建連接的event,將一個worker任務交給worker executor

·如果是興趣event,則註冊興趣事件。

2)當在Pipeline上流轉的是message時:

  將要寫的數據放到寫隊列中,然後調用NioWorker的writeFromUserCode方法。

 

 

ChannelHandler

Netty是由事件驅動的框架,任何操作操作都是由事件來驅動的。

ChannelHandler就是一個Event Hander(事件處理器),它的作用是:

·處理IO事件(讀寫),例如讀取數據,並解碼。

         ·處理興趣事件。

         ·交給下一個ChannelHandler處理。

 

 

寫數據有兩種方式可以觸發

 

 

 

 

上述呢,簡單了說了一下Channel中各組件的作用以及處理流程,知道這些東西,已經可以幫助我們理解並使用Netty了。

 


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

-Advertisement-
Play Games
更多相關文章
  • public class SuperClass{ public void printA(){ System.out.print("SuperClass-printA"); printB(); } public void printB(){ System.out.print("SuperClass-p ...
  • 最近打算寫個簡單的配置中心,考慮到實現便捷性,語言選擇了go,由於其中計劃用到zk,就調研了下golang的zk客戶端,並實現了個簡單的分散式server。 ...
  • ...
  • * 1、繼承自抽象類 AbstractSet,實現介面 Set、Cloneable、Serializable; * 2、元素無順序; * 3、元素不可重覆; * 4、採用哈希演算法插入數據,插入速度快; * 5、非線程安全,輕量級; * 6、由於實現了介面 Cloneable,故此可以被覆制; * 7 ...
  • 按照一般的學習慣例,第一個程式自然就是"Hello World"。 運行結果如上圖。代碼: 在主函數中只需4句話即可創建一個新的視窗,併在其中顯示文字。 第1~2行:包含頭文件。 在Qt中,每一個類都有一個與該類同名的頭文件。 例如主函數中的QApplication類,它的頭文件就是,QLabel類... ...
  • 好久沒有寫博文了,寫個簡單的東西熱熱身,分享給大家。 jdbc相信大家都不陌生,只要是個搞java的,最初接觸j2ee的時候都是要學習這麼個東西的,誰叫程式得和資料庫打交道呢!而jdbc就是和資料庫打交道非常基礎的一個知識,也是比較接近底層的,在實際的工作中大家用得更多的其實還是比較成熟的框架,例如 ...
  • 1.包 package pack; /*定義包,放在程式的第一行,包名所以字母小寫*/class PackageDemo{ public static void main(String[] args) { packa.DemoA a=new packa.DemoA(); /*編譯時將會出現兩個錯誤, ...
  • 以上代碼中,s1和s2引用的是相同的地址,故而第四行列印出的結果是true;而s3雖然只與s1,s2相等,但是s3時通過new String("123")創建的,重新開闢了記憶體空間,因引用的地址不同,所以第5行列印出false;intern方法返回的是String對象在常亮池中的引用,所以最後一行打 ...
一周排行
    -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.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...