中文字幕av专区_日韩电影在线播放_精品国产精品久久一区免费式_av在线免费观看网站

溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

Netty的異步通知機制

發布時間:2021-08-16 11:19:55 來源:億速云 閱讀:202 作者:chen 欄目:大數據

本篇內容介紹了“Netty的異步通知機制”的有關知識,在實際案例的操作過程中,不少人都會遇到這樣的困境,接下來就讓小編帶領大家學習一下如何處理這些情況吧!希望大家仔細閱讀,能夠學有所成!

前言

前面的文章分析了Channel實例化、初始化、注冊機制,本文分析下異步結果的通知,也就是回調,同時梳理下Future、Promise、ChannelFuture、ChannelPromise的關系。

一、異步通知代碼走查

 

在Channel注冊到Selector后,會返回ChannelFuture。如果注冊未完成,會通過增加Listener來進行異步通知注冊結果,接下來看下是如何回調的。


代碼塊

Netty的異步通知機制

備注:上面代碼塊中在注冊完Channel后返回ChannelFuture,在ChannelFuture注冊了ChannelFutureListener,通過異步通知的方式獲取注冊結果。


代碼塊 

Netty的異步通知機制

備注:構建DefaultChannelPromise綁定了EventLoop和Channel,上面注冊的ChannelFutureListener實際注冊到了DefaultChannelPromise。


代碼塊

Netty的異步通知機制

備注:通過ChannelPromise標記Channel注冊成功。


代碼塊

Netty的異步通知機制

備注:在DefaultPromise中通過cas設置Channel注冊結果,并回調加在其身上的Listener。


Netty的異步通知機制

Netty的異步通知機制

備注:將注冊的所有Listener,通過回調GenericFutureListener的operationComplete方法,完成結果的通知。



二、異步通知流程圖


下面以channel注冊為例,勾勒異步回調流程圖。Future/Promise作為結果載體與執行Listener的執行主體。


Netty的異步通知機制


三、Future/Promise關系圖譜


以下類圖中展現了Future/Promise的類圖結構,Netty中Future繼承Java中的Future并`增加了基于Listener的異步通知機制`。

Promise允許在標志某個操作結果后再回調Listener(比如:在注冊成功后調用Promise#trySuccess將成功結果在Promise中標記,并回調Listener)。

ChannelFuture與特定的Channel綁定,ChannelPromise繼承ChannelFuture與Promise即擁有綁定特定Channel與標記操作結果回調Listener的能力。 


Netty的異步通知機制

“Netty的異步通知機制”的內容就介紹到這里了,感謝大家的閱讀。如果想了解更多行業相關的知識可以關注億速云網站,小編將為大家輸出更多高質量的實用文章!

向AI問一下細節

免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。

AI

岑溪市| 蒙自县| 贵定县| 拜城县| 柳林县| 天津市| 鹤庆县| 天气| 封丘县| 保康县| 安仁县| 土默特左旗| 山东省| 昭苏县| 涡阳县| 宜州市| 香港| 临湘市| 基隆市| 济南市| 康定县| 大荔县| 蚌埠市| 胶州市| 望江县| 章丘市| 长宁区| 平潭县| 大名县| 葵青区| 岚皋县| 平邑县| 东海县| 乌鲁木齐市| 肃宁县| 浮山县| 嘉禾县| 西城区| 贺兰县| 龙游县| 察雅县|