hadoop27---netty中handler的执行顺序
生活随笔
收集整理的這篇文章主要介紹了
hadoop27---netty中handler的执行顺序
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
Netty是基于Java NIO的網絡應用框架.Netty是一個NIO client-server(客戶端服務器)框架,使用Netty可以快速開發網絡應用,例如服務器和客戶端協議。Netty提供了一種新的方式來使開發網絡應用程序,這種新的方式使得它很容易使用和有很強的擴展性。Netty的內部實現時很復雜的,但是Netty提供了簡單易用的api從網絡處理代碼中解耦業務邏輯。Netty是完全基于NIO實現的,所以整個Netty都是異步的。網絡應用程序通常需要有較高的可擴展性,無論是Netty還是其他的基于Java NIO的框架,都會提供可擴展性的解決方案。Netty中一個關鍵組成部分是它的異步特性. 2.1.1.下載netty包
? 下載netty包,下載地址http://netty.io/ 2.1.1.netty中handler的執行順序
2.1.2.簡介
Handler在netty中,無疑占據著非常重要的地位。Handler與Servlet中的filter很像,通過Handler可以完成通訊報文的解碼編碼、攔截指定的報文、統一對日志錯誤進行處理、統一對請求進行計數、控制Handler執行與否。。Netty中的所有handler都實現自ChannelHandler接口。按照輸出輸出來分,分為ChannelInboundHandler、ChannelOutboundHandler兩大類。ChannelInboundHandler對從客戶端發往服務器的報文進行處理,一般用來執行解碼、讀取客戶端數據、進行業務處理等;ChannelOutboundHandler對從服務器發往客戶端的報文進行處理,一般用來進行編碼、發送報文到客戶端。Netty中,可以注冊多個handler。ChannelInboundHandler按照注冊的先后順序執行;ChannelOutboundHandler按照注冊的先后順序逆序執行,如下圖所示,按照注冊的先后順序對Handler進行排序,request進入Netty后的執行順序為:
?
在使用Handler的過程中,需要注意:
1、ChannelInboundHandler之間的傳遞,通過調用 ctx.fireChannelRead(msg) 傳遞到下一個ChannelInboundHandler;調用ctx.write(msg) 將傳遞到下一個ChannelOutboundHandler。
2、ctx.write()方法執行后,需要調用flush()方法才能令它立即執行。
3、流水線pipeline中outhandler不能放在最后,否則不生效
4、Handler的消費處理放在最后一個處理。
?
使用netty可以實現一個hadoop。netty是高性能的服務端框架。
轉載于:https://www.cnblogs.com/yaowen/p/9031488.html
創作挑戰賽新人創作獎勵來咯,堅持創作打卡瓜分現金大獎總結
以上是生活随笔為你收集整理的hadoop27---netty中handler的执行顺序的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: python:实现简单购物车增加商品、删
- 下一篇: 正则化、交叉验证、泛化能力