Netty原理(四)Netty异步模型

Netty原理(四)Netty异步模型,第1张

异步的概念和同步相对。当一个异步过程调用发出后,调用者不能立刻得到结果。实际处理这个调

用的组件在完成后,通过状态、通知和回调来通知调用

Netty 中的 I/O 操作是异步的,包括 Bind、Write、Connect 等操作会简单的返回一个

ChannelFuture。调用者并不能立刻获得结果,而是通过 Future-Listener 机制,用户可以方便的主动获

取或者通过通知机制获得IO 操作结果. Netty 的异步模型是建立在 future 和 callback 的之上的。

callback 就是回调。重点说 Future,它的核心思想是:假设一个方法 fun,计算过程可能非常耗时,等

待 fun 返回显然不合适。那么可以在调用 fun 的时候,立马返回一个 Future,后续可以通过 Future 去

监控方法 fun 的处理过程(即 : Future-Listener 机制)

表示异步的执行结果, 可以通过它提供的方法来检测执行是否完成,ChannelFuture 是他的一

个子接口. ChannelFuture 是一个接口 ,可以添加监听器,当监听的事件发生时,就会通知到监听器

当 Future 对象刚刚创建时,处于非完成状态,调用者可以通过返回的 ChannelFuture 来获取

操作执行的状态, 注册监听函数来执行完成后的操作。

常用方法有:

·sync 方法, 阻塞等待程序结果反回

·isDone 方法来判断当前操作是否完成;

·isSuccess 方法来判断已完成的当前操作是否成功;

·getCause 方法来获取已完成的当前操作失败的原因;

·isCancelled 方法来判断已完成的当前操作是否被取消;

addListener 方法来注册监听器,当操作已完成(isDone 方法返回完成),将会通知指定的监听

器;如果Future 对象已完成,则通知指定的监听器

给Future添加监听器,监听操作结果

1)阻塞I/O(blocking I/O)

2)非阻塞I/O (nonblocking I/O)

3) I/O复用(select 和poll) (I/O multiplexing)

4)信号驱动I/O (signal driven I/O (SIGIO))

5)异步I/O (asynchronous I/O (the POSIX aio_functions))

其中前4种都是同步,最后一种才是异步。

ajax主要功能就是提供与服务器的异步交互,

比如需要你输入一个用户名,在你输送完毕之后,没有确认提交,ajax可以通过异步提交来实现仅仅将你输入的用户名发送到服务器数据库进行检测,然后告诉你是否重复。

而同步提交就像你注册完毕,帮你将信息存储到数据库后告诉你注册成功。


欢迎分享,转载请注明来源:夏雨云

原文地址:https://www.xiayuyun.com/zonghe/483397.html

(0)
打赏 微信扫一扫微信扫一扫 支付宝扫一扫支付宝扫一扫
上一篇 2023-06-09
下一篇2023-06-09

发表评论

登录后才能评论

评论列表(0条)

    保存