認識Netty的ChannelHandler 和 ChannelPipeline

在我們的應用程序中ChannelHandler是許多方面的核心，或許它作為核心的表現并不明顯。ChannelHandler的用途廣泛，所以我們難以對其進行界定，也正因為如此，在使用它的時候最好是當成一個通用的容器，處理進來的事件（包括數據）并且通過ChannelPipeline。

下圖展示了 ChannelInboundHandler 和 ChannelOutboundHandler 繼承自父接口 ChannelHandler。

Figure 3.3 ChannelHandler class hierarchy

Netty 中有兩個方向的數據流，圖3.4 顯示的入站(ChannelInboundHandler)和出站(ChannelOutboundHandler)之間有一個明顯的區(qū)別：若數據是從用戶應用程序到遠程主機則是“出站(outbound)”，相反若數據時從遠程主機到用戶應用程序則是“入站(inbound)”。

為了使數據從一端到達另一端，一個或多個 ChannelHandler 將以某種方式操作數據。這些 ChannelHandler 會在程序的“引導”階段被添加ChannelPipeline中，并且被添加的順序將決定處理數據的順序。

Figure 3.4 ChannelPipeline with inbound and outbound ChannelHandlers

圖 3.4 同樣展示了進站和出站的處理器都可以被安裝在相同的 pipeline 。本例子中，如果消息或任何其他入站事件被讀到，將從 pipeline 頭部開始，傳遞到第一個 ChannelInboundHandler。該處理器可能會或可能不會實際修改數據，取決于其特定的功能，在這之后 該數據將被傳遞到鏈中的下一個 ChannelInboundHandler。最后，將數據 到達 pipeline 的尾部，此時所有處理結束。

數據的出站運動（即，數據被“寫入”）在概念上是相同的。在這種情況下的數據從尾部流過 ChannelOutboundHandlers 的鏈，直到它到達頭部。超過這點，出站數據將到達的網絡傳輸，在這里顯示為一個 socket。通常，這將觸發(fā)一個寫入操作。

更多 Inbound 、 Outbound Handler

在當前的鏈（chain）中，事件可以通過 ChanneHandlerContext 傳遞給下一個 handler。Netty 為此提供了抽象基類ChannelInboundHandlerAdapter 和 hannelOutboundHandlerAdapter，用來處理你想要的事件。 這些類提供的方法的實現，可以簡單地通過調用 ChannelHandlerContext 上的相應方法將事件傳遞給下一個 handler。在實際應用中，您可以按需覆蓋相應的方法即可。

所以，如果出站和入站操作是不同的，當 ChannelPipeline 中有混合處理器時將發(fā)生什么？雖然入站和出站處理器都擴展了 ChannelHandler，Netty 的 ChannelInboundHandler 的實現 和 ChannelOutboundHandler 之間的是有區(qū)別的，從而保證數據傳遞只從一個處理器到下一個處理器保證正確的類型。

當 ChannelHandler 被添加到的 ChannelPipeline 它得到一個 ChannelHandlerContext，它代表一個 ChannelHandler 和 ChannelPipeline 之間的“綁定”。它通常是安全保存對此對象的引用，除了當協議中的使用的是不面向連接（例如，UDP）。而該對象可以被用來獲得 底層 Channel,它主要是用來寫出站數據。

實際上，在 Netty 發(fā)送消息可以采用兩種方式：直接寫消息給 Channel 或者寫入 ChannelHandlerContext 對象。這兩者主要的區(qū)別是， 前一種方法會導致消息從 ChannelPipeline的尾部開始，而后者導致消息從 ChannelPipeline 下一個處理器開始。