# 總覽
我們已經知道,ChannelHandler 實現可以串聯在一起,以構建ChannelPipeline 的處理邏輯。我們先前解釋說,這個設計方法支持潛在的復雜的分解處理成小和可重用的組件,其中每個一個定義良好的處理任務或步驟。在這一章里,我們將展示它簡化了測試。
Netty 的促進 ChannelHandler 的測試通過的所謂“嵌入式”傳輸。這是由一個特殊 Channel 實現,EmbeddedChannel,它提供了一個簡單的方法通過管道傳遞事件。
想法很簡單:你入站或出站數據寫入一個E mbeddedChannel 然后檢查是否達到 ChannelPipeline 的結束。這樣你可以確定消息編碼或解碼和ChannelHandler 是否操作被觸發。
在表10.1中列出了相關方法。
| 名稱 | 職責 |
|-----|-----|
| writeInbound | 寫一個入站消息到 EmbeddedChannel。 如果數據能從 EmbeddedChannel 通過 readInbound() 讀到,則返回 true |
| readInbound | 從 EmbeddedChannel 讀到入站消息。任何返回遍歷整個ChannelPipeline。如果讀取還沒有準備,則此方法返回 null |
| writeOutbound | 寫一個出站消息到 EmbeddedChannel。 如果數據能從 EmbeddedChannel 通過 readOutbound() 讀到,則返回 true |
| readOutbound | 從 EmbeddedChannel 讀到出站消息。任何返回遍歷整個ChannelPipeline。如果讀取還沒有準備,則此方法返回 null |
| Finish | 如果從入站或者出站中能讀到數據,標記 EmbeddedChannel 完成并且返回。這同時會調用 EmbeddedChannel 的關閉方法 |
*測試入站和出站數據*
*處理入站數據由 ChannelInboundHandler 處理并且表示數據從遠端讀取。出站數據由 ChannelOutboundHandler 處理并且表示數據寫入遠端。根據 ChannelHandler 測試你會選擇 writeInbound(),writeOutbound(), 或者兩者都有。*
圖10.1顯示了數據流如何通過 ChannelPipeline 使用 EmbeddedChannel 的方法。

Figure 10.1 EmbeddedChannel data flow
如上圖所示,使用 writeOutbound() 寫消息到 Channel,消息在出站方法通過 ChannelPipeline,之后就可以使用 readOutbound() 讀取消息。著同樣使用與入站,使用 writeInbound() 和 readInbound()。處在
每種情況下,消息是通過 ChannelPipeline 并被有關ChannelInboundHandler 或 ChannelOutboundHandler 進行處理。如果消息是不消耗您可以使用 readInbound() 或 readOutbound() 適當的讀到 Channel 處理后的消息。
讓我們仔細看一下這兩個場景,看看他們如何適用于測試您的應用程序邏輯。
- 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