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


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

查看所有标签

猜你喜欢:

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

Beginning iPhone and iPad Web Apps

Beginning iPhone and iPad Web Apps

Chris Apers、Daniel Paterson / Apress / 2010-12-15 / USD 39.99

It seems that everyone and her sister has developed an iPhone App—everyone except you, the hard-working web professional. And now with the introduction of the iPad, you may even feel farther behind. B......一起来看看 《Beginning iPhone and iPad Web Apps》 这本书的介绍吧!

在线进制转换器
在线进制转换器

各进制数互转换器

图片转BASE64编码
图片转BASE64编码

在线图片转Base64编码工具

XML 在线格式化
XML 在线格式化

在线 XML 格式化压缩工具