Netty是基于Java NIO的網(wǎng)絡(luò)應(yīng)用框架.Netty是一個(gè)NIO client-server(客戶端服務(wù)器)框架，使用Netty可以快速開(kāi)發(fā)網(wǎng)絡(luò)應(yīng)用，例如服務(wù)器和客戶端協(xié)議。Netty提供了一種新的方式來(lái)使開(kāi)發(fā)網(wǎng)絡(luò)應(yīng)用程序，這種新的方式使得它很容易使用和有很強(qiáng)的擴(kuò)展性。Netty的內(nèi)部實(shí)現(xiàn)時(shí)很復(fù)雜的，但是Netty提供了簡(jiǎn)單易用的api從網(wǎng)絡(luò)處理代碼中解耦業(yè)務(wù)邏輯。Netty是完全基于NIO實(shí)現(xiàn)的，所以整個(gè)Netty都是異步的。網(wǎng)絡(luò)應(yīng)用程序通常需要有較高的可擴(kuò)展性，無(wú)論是Netty還是其他的基于Java NIO的框架，都會(huì)提供可擴(kuò)展性的解決方案。Netty中一個(gè)關(guān)鍵組成部分是它的異步特性. 2.1.1.下載netty包 ? 下載netty包，下載地址http://netty.io/ 2.1.1.netty中handler的執(zhí)行順序 2.1.2.簡(jiǎn)介 Handler在netty中，無(wú)疑占據(jù)著非常重要的地位。Handler與Servlet中的filter很像，通過(guò)Handler可以完成通訊報(bào)文的解碼編碼、攔截指定的報(bào)文、統(tǒng)一對(duì)日志錯(cuò)誤進(jìn)行處理、統(tǒng)一對(duì)請(qǐng)求進(jìn)行計(jì)數(shù)、控制Handler執(zhí)行與否。。Netty中的所有handler都實(shí)現(xiàn)自ChannelHandler接口。按照輸出輸出來(lái)分，分為ChannelInboundHandler、ChannelOutboundHandler兩大類。ChannelInboundHandler對(duì)從客戶端發(fā)往服務(wù)器的報(bào)文進(jìn)行處理，一般用來(lái)執(zhí)行解碼、讀取客戶端數(shù)據(jù)、進(jìn)行業(yè)務(wù)處理等；ChannelOutboundHandler對(duì)從服務(wù)器發(fā)往客戶端的報(bào)文進(jìn)行處理，一般用來(lái)進(jìn)行編碼、發(fā)送報(bào)文到客戶端。Netty中，可以注冊(cè)多個(gè)handler。ChannelInboundHandler按照注冊(cè)的先后順序執(zhí)行；ChannelOutboundHandler按照注冊(cè)的先后順序逆序執(zhí)行，如下圖所示，按照注冊(cè)的先后順序?qū)andler進(jìn)行排序，request進(jìn)入Netty后的執(zhí)行順序?yàn)?#xff1a;

?

在使用Handler的過(guò)程中，需要注意：

1、ChannelInboundHandler之間的傳遞，通過(guò)調(diào)用 ctx.fireChannelRead(msg) 傳遞到下一個(gè)ChannelInboundHandler；調(diào)用ctx.write(msg) 將傳遞到下一個(gè)ChannelOutboundHandler。

2、ctx.write()方法執(zhí)行后，需要調(diào)用flush()方法才能令它立即執(zhí)行。

3、流水線pipeline中outhandler不能放在最后，否則不生效

4、Handler的消費(fèi)處理放在最后一個(gè)處理。

?

使用netty可以實(shí)現(xiàn)一個(gè)hadoop。netty是高性能的服務(wù)端框架。

轉(zhuǎn)載于:https://www.cnblogs.com/yaowen/p/9031488.html

創(chuàng)作挑戰(zhàn)賽新人創(chuàng)作獎(jiǎng)勵(lì)來(lái)咯，堅(jiān)持創(chuàng)作打卡瓜分現(xiàn)金大獎(jiǎng)

總結(jié)

以上是生活随笔為你收集整理的hadoop27---netty中handler的执行顺序的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。