ChannelPipeline 是 ChannelHandler 鏈的容器。
在許多方面的 ChannelHandler 是在您的應用程序的核心,盡管有時它 可能并不明顯。ChannelHandler 支持廣泛的用途,使它難以界定。因此,最好是把它當作一個通用的容器,處理進來的事件(包括數據)并且通過ChannelPipeline。下圖展示了 ChannelInboundHandler 和 ChannelOutboundHandler 繼承自父接口 ChannelHandler。
Figure 3.3 ChannelHandler class hierarchy
[](https://github.com/waylau/essential-netty-in-action/blob/master/images/Figure%203.3%20ChannelHandler%20class%20hierarchy.jpg)
Netty 中有兩個方向的數據流,圖3.4 顯示的入站(ChannelInboundHandler)和出站(ChannelOutboundHandler)之間有一個明顯的區別:若數據是從用戶應用程序到遠程主機則是“出站(outbound)”,相反若數據時從遠程主機到用戶應用程序則是“入站(inbound)”。
為了使數據從一端到達另一端,一個或多個 ChannelHandler 將以某種方式操作數據。這些 ChannelHandler 會在程序的“引導”階段被添加ChannelPipeline中,并且被添加的順序將決定處理數據的順序。
Figure 3.4 ChannelPipeline with inbound and outbound ChannelHandlers
[](https://github.com/waylau/essential-netty-in-action/blob/master/images/Figure%203.4%20ChannelPipeline%20with%20inbound%20and%20outbound%20ChannelHandlers.jpg)
圖 3.4 同樣展示了進站和出站的處理器都可以被安裝在相同的 pipeline 。本例子中,如果消息或任何其他入站事件被讀到,將從 pipeline 頭部開始,傳遞到第一個 ChannelInboundHandler。該處理器可能會或可能不會實際修改數據,取決于其特定的功能,在這之后 該數據將被傳遞到鏈中的下一個 ChannelInboundHandler。最后,將數據 到達 pipeline 的尾部,此時所有處理結束。
數據的出站運動(即,數據被“寫入”)在概念上是相同的。在這種情況下的數據從尾部流過 ChannelOutboundHandlers 的鏈,直到它到達頭部。超過這點,出站數據將到達的網絡傳輸,在這里顯示為一個 socket。通常,這將觸發一個寫入操作。
*更多 Inbound 、 Outbound Handler*
*一個事件可以通過使用 ChanneHandlerContext 被轉發到下一個處理器中的當前鏈傳遞到每個方法。因為這是你通常想要的而不是 Netty 提供的抽象基類 ChannelInboundHandlerAdapter 和ChannelOutboundHandlerAdapter。 每個這些提供了一個方法的實現和簡單地通過調用 ChannelHandlerContext 的方法來傳遞事件到下一個處理器。然后,您可以根據實際需求重寫方法。*
所以,如果出站和入站操作是不同的,當 ChannelPipeline 中有混合處理器時將發生什么?雖然入站和出站處理器都擴展了 ChannelHandler,Netty 的 ChannelInboundHandler 的實現 和 ChannelOutboundHandler 之間的是有區別的,從而保證數據傳遞只從一個處理器到下一個處理器保證正確的類型。
當 ChannelHandler 被添加到的 ChannelPipeline 它得到一個 ChannelHandlerContext,它代表一個 ChannelHandler 和 ChannelPipeline 之間的“綁定”。它通常是安全保存對此對象的引用,除了當協議中的使用的是不面向連接(例如,UDP)。而該對象可以被用來獲得 底層 Channel,它主要是用來寫出站數據。
還有,實際上,在 Netty 發送消息有兩種方式。您可以直接寫消息給 Channel 或寫入 ChannelHandlerContext 對象。主要的區別是, 前一種方法會導致消息從 ChannelPipeline的尾部開始,而 后者導致消息從 ChannelPipeline 下一個處理器開始。
- Introduction
- 開始
- Netty-異步和數據驅動
- Netty 介紹
- 構成部分
- 關于本書
- 第一個 Netty 應用
- 設置開發環境
- Netty 客戶端/服務端 總覽
- 寫一個 echo 服務器
- 寫一個 echo 客戶端
- 編譯和運行 Echo 服務器和客戶端
- 總結
- Netty 總覽
- Netty 快速入門
- Channel, Event 和 I/O
- 什么是 Bootstrapping 為什么要用
- ChannelHandler 和 ChannelPipeline
- 近距離觀察 ChannelHandler
- 總結
- 核心功能
- Transport(傳輸)
- 案例研究:Transport 的遷移
- Transport API
- 包含的 Transport
- Transport 使用情況
- 總結
- Buffer(緩沖)
- Buffer API
- ByteBuf - 字節數據的容器
- 字節級別的操作
- ByteBufHolder
- ByteBuf 分配
- 總結
- ChannelHandler 和 ChannelPipeline
- ChannelHandler 家族
- ChannelPipeline
- ChannelHandlerContext
- 總結
- Codec 框架
- 什么是 Codec
- Decoder(解碼器)
- Encoder(編碼器)
- 抽象 Codec(編解碼器)類
- 總結
- 提供了的 ChannelHandler 和 Codec
- 使用 SSL/TLS 加密 Netty 程序
- 構建 Netty HTTP/HTTPS 應用
- 空閑連接以及超時
- 解碼分隔符和基于長度的協議
- 編寫大型數據
- 序列化數據
- 總結
- Bootstrap 類型
- 引導客戶端和無連接協議
- 引導服務器
- 從 Channel 引導客戶端
- 在一個引導中添加多個 ChannelHandler
- 使用Netty 的 ChannelOption 和屬性
- 關閉之前已經引導的客戶端或服務器
- 總結
- 引導
- Bootstrap 類型
- 引導客戶端和無連接協議
- 引導服務器
- 從 Channel 引導客戶端
- 在一個引導中添加多個 ChannelHandler
- 使用Netty 的 ChannelOption 和屬性
- 關閉之前已經引導的客戶端或服務器
- 總結
- NETTY BY EXAMPLE
- 單元測試
- 總覽
- 測試 ChannelHandler
- 測試異常處理
- 總結
- WebSocket
- WebSocket 程序示例
- 添加 WebSocket 支持
- 測試程序
- 總結
- SPDY
- SPDY 背景
- 示例程序
- 實現
- 啟動 SpdyServer 并測試
- 總結
- 通過 UDP 廣播事件
- UDP 基礎
- UDP 廣播
- UDP 示例
- EventLog 的 POJO
- 寫廣播器
- 寫監視器
- 運行 LogEventBroadcaster 和 LogEventMonitor
- 總結
- 高級主題
- 實現自定義的編解碼器
- 編解碼器的范圍
- 實現 Memcached 編解碼器
- 了解 Memcached 二進制協議
- Netty 編碼器和解碼器
- 測試編解碼器
- EventLoop 和線程模型
- 線程模型的總覽
- EventLoop
- EventLoop
- I/O EventLoop/Thread 分配細節
- 總結
- 用例1:Droplr Firebase 和 Urban Airship
- 用例2:Facebook 和 Twitter