当前位置: 代码迷 >> 综合 >> Netty的深入浅出--65.Future、ChannelFuture、ChannelPromise之间的联系
  详细解决方案

Netty的深入浅出--65.Future、ChannelFuture、ChannelPromise之间的联系

热度:96   发布时间:2023-11-29 21:47:40.0

我们回过头来分析一下Future,在java并发包下就存在了一种异步执行的支持类future,但是由于它的get()方法是阻塞的,所以导致了这个方法在异步处理上存在很大的弊端。

 Netty在继承concurrent包下的Future对象的基础上实现了自己的Future。

 在并发包下的isDone()方法,不管成功失败与否都会创建一个返回一个完成状态,这样的话,使用者无法知道,该进程到底是成功了还是失败了。

 在Netty中对于以上那个问题,创建了一个单独的方法,来判断是否是成功了。

 我们可以看到在netty中采用了观察者模式

ChannelFuture ,它进一步继承了Future,多了一个channel()方法,相对来说都是读方法

ChannelPromise有进一步继承了ChannelFuture,增加了写方法

 

总结:

 在netty的ChannelFuture中通过listener来不断监听Future里面的事件,而且listener里面保存了相关channel对象,可以直接通过listener获取相关channel。

  相关解决方案