如何實(shí)現(xiàn)Netty的服務(wù)端Channel不支持寫操作

發(fā)布時(shí)間：2021-12-28 17:47:44 來源：億速云閱讀：159 作者：小新欄目：大數(shù)據(jù)

小編給大家分享一下如何實(shí)現(xiàn)Netty的服務(wù)端Channel不支持寫操作，相信大部分人都還不怎么了解，因此分享這篇文章給大家參考一下，希望大家閱讀完這篇文章后大有收獲，下面讓我們一起去了解一下吧！

作為Netty的服務(wù)端Channel,即NioServerSocketChannel,它的職責(zé)就是負(fù)責(zé)監(jiān)聽ACCEPT事件,當(dāng)有客戶端連接到服務(wù)端時(shí),NioServerSocketChannel負(fù)責(zé)讀取這個(gè)ACCEPT請求.

既然作為一個(gè)Channel,都是支持讀和寫操作的.那么這個(gè) NioServerSocketChannel是不支持寫操作的,當(dāng)你想通過這個(gè)NioServerSocketChannel向外部寫數(shù)據(jù)的時(shí)候,會(huì)在Netty內(nèi)部拋出一個(gè)異常,Netty也會(huì)捕獲這個(gè)異常,并不會(huì)把這個(gè)異常拋出給程序.

@Overridepublic void channelActive(ChannelHandlerContext ctx) throws Exception {    ctx.writeAndFlush("this is test1");    super.channelActive(ctx);}

以上代碼,當(dāng)NioServerSocketChannel完成端口綁定之后,會(huì)回調(diào)channelActive,我們在此方法中調(diào)用writeAndFlush方法,向外部寫數(shù)據(jù),當(dāng)然此時(shí)并沒有任何外部的連接,但是也不影響我們向外部寫數(shù)據(jù).

最終這個(gè)寫操作會(huì)調(diào)用到HeadContext中的write方法

@Overridepublic void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) {    unsafe.write(msg, promise);}

繼續(xù)調(diào)用到unsafe.write方法

如何實(shí)現(xiàn)Netty的服務(wù)端Channel不支持寫操作

而NioServerSocketChanenl重寫了filterOutboundMessage方法

如何實(shí)現(xiàn)Netty的服務(wù)端Channel不支持寫操作

直接拋出異常,不允許寫操作.

以上是“如何實(shí)現(xiàn)Netty的服務(wù)端Channel不支持寫操作”這篇文章的所有內(nèi)容，感謝各位的閱讀！相信大家都有了一定的了解，希望分享的內(nèi)容對大家有所幫助，如果還想學(xué)習(xí)更多知識，歡迎關(guān)注億速云行業(yè)資訊頻道！

向AI問一下細(xì)節(jié)

如何實(shí)現(xiàn)Netty的服務(wù)端Channel不支持寫操作

猜你喜歡

最新資訊

相關(guān)推薦

相關(guān)標(biāo)簽