Netty 推荐 addListener 回调异步执行

[jiangxinlingdu]

说明

Netty 推荐使用 addListener 的方式来回调异步执行的结果，这种方式优于 Future.get ，能够更精确地把握异步执行结束的时间。

错误理解使用 addListener 的方式

代码如下：

代码运行结果：

**疑惑：**很疑惑啊，按照上面 Netty 推荐使用 addListener 的方式来回调异步执行的结果，这种方式优于 Future.get ，能够更精确地把握异步执行结束的时间。而且也停顿了 5s 了，为什么还是顺序执行的呢？

感谢闪电侠、芋艿、晓峰的热心解答。

分析

这段代码 怎么执行都是顺序执行，不阻塞 最后，reactor 线程里面都是同步的。

我们来跟踪代码进行查看：

关键在这里，执行完成 write 之后返回 promise。

如果是 reactor 那么就顺序执行，否则就加入队列等待后续执行（如果是顺序的就是等执行完成返回，如果是加入队列就是异步）

这里重点不在 writeAndFlush，先分析同步是执行的情况，异步的下面正确方式会分析，如果是同步方式：

也就是设置了值，之后 promise 之后返回。

那么：

所有就变成了 java 里面最普通的代码，一个线程代码从上到下执行。也解释了为什么没有走异步情况了。

正确理解使用 addListener 的方式

不在 reactor 线程里面执行，就可以做到最开始提到的：Netty 推荐使用 addListener 的方式来回调异步执行的结果，这种方式优于 Future.get ，能够更精确地把握异步执行结束的时间。

执行效果如下：

继续进行分析：

关键在这里，执行完成 write 之后返回 promise。

由于是异步直接返回，其实 isDone 为 false，之后 addListener 就很快添加完成，就执行下面语句了。

这里也可以看到是 writeAndFlush 执行完成之后调用回调事件，这样才是真正做到了异步执行。

总结

由于之前理解不深刻，感谢闪电侠、芋艿、晓峰的热心解答，现在开朗多了，Netty 继续学习中……，希望今天文章对你有所有收获！！！

文章 github 源代码地址：nettydemo，或者公号回复“ Netty ”获取源码地址。

---

如果读完觉得有收获的话，欢迎点赞、关注、加公众号 [匠心零度] ，查阅更多精彩历史！！！