Netty 之异步通知机制

栏目: IT技术 · 发布时间: 4年前

内容简介:一、异步通知代码走查在Channel注册到Selector后,会返回ChannelFuture。如果注册未完成,会通过增加Listener来进行异步通知注册结果,接下来看下是如何回调的。代码块

一、异步通知代码走查

在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 之异步通知机制

作者丨梁勇

来源丨瓜农老梁(ID:

gh_01130ae30a83)

欢迎关注公众号“瓜农老梁”

「瓜农老梁  学习同行」     

Netty 之异步通知机制


以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持 码农网

查看所有标签

猜你喜欢:

本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们

Letting Go of the Words

Letting Go of the Words

Janice (Ginny) Redish / Morgan Kaufmann / 2007-06-11 / USD 49.95

"Redish has done her homework and created a thorough overview of the issues in writing for the Web. Ironically, I must recommend that you read her every word so that you can find out why your customer......一起来看看 《Letting Go of the Words》 这本书的介绍吧!

JSON 在线解析
JSON 在线解析

在线 JSON 格式化工具

html转js在线工具
html转js在线工具

html转js在线工具