我們已經了解過了，為了能夠構建 ChannelPipeline 的處理邏輯，可以將 ChannelHandler 實現(xiàn)串聯(lián)在一起。之前我們也解釋過了，支持有可能存在的復雜的分解處理成小的和可以重用的組件，其中的每一個定義良好的處理任務或步驟。本章將展示它簡化了測試。

Netty 的促進 ChannelHandler 的測試使用的是的所謂“嵌入式”傳輸。這是由一個特殊 Channel 實現(xiàn)，EmbeddedChannel提供了一個簡單的方法通過管道傳遞事件。

這種想法很簡單：你把入站或者出站的數(shù)據(jù)寫入一個EmbeddedChannel 然后檢查是否能夠達到 ChannelPipeline 的結束。以此來確定消息編碼或解碼和 ChannelHandler 是否操作被觸發(fā)。

在表10.1中列出了相關方法。

測試入站和出站數(shù)據(jù)

處理入站數(shù)據(jù)由 ChannelInboundHandler 處理并且表示數(shù)據(jù)從遠端讀取。出站數(shù)據(jù)由 ChannelOutboundHandler 處理并且表示數(shù)據(jù)寫入遠端。 根據(jù) ChannelHandler 測試你會選擇 writeInbound(),writeOutbound(), 或者兩者都有。

圖10.1顯示了數(shù)據(jù)流如何通過 ChannelPipeline 使用 EmbeddedChannel 的方法。

Figure 10.1 EmbeddedChannel data flow

如上圖所示，使用 writeOutbound() 寫消息到 Channel，消息在出站方法通過 ChannelPipeline，之后就可以使用 readOutbound() 讀取消息。著同樣使用與入站，使用 writeInbound() 和 readInbound()。處在

每種情況下,消息是通過 ChannelPipeline 并被有關ChannelInboundHandler 或 ChannelOutboundHandler 進行處理。如果消息是不消耗您可以使用 readInbound() 或 readOutbound() 適當?shù)淖x到 Channel 處理后的消息。

讓我們仔細看一下這兩個場景,看看他們如何適用于測試您的應用程序邏輯。