文档章节

ChannelFuture的用法

刺猬一号
 刺猬一号
发布于 2017/03/23 21:17
字数 967
阅读 345
收藏 0

综述

ChannelFuture的作用是用来保存Channel异步操作的结果。

我们知道,在Netty中所有的I/O操作都是异步的。这意味着任何的I/O调用都将立即返回,而不保证这些被请求的I/O操作在调用结束的时候已经完成。取而代之地,你会得到一个返回的ChannelFuture实例,这个实例将给你一些关于I/O操作结果或者状态的信息。

对于一个ChannelFuture可能已经完成,也可能未完成。当一个I/O操作开始的时候,一个新的future对象就会被创建。在开始的时候,新的future是未完成的状态--它既非成功失败,也非被取消,因为I/O操作还没有结束。如果I/O操作以成功失败或者被取消中的任何一种状态结束了,那么这个future将会被标记为已完成,并包含更多详细的信息(例如:失败的原因)。请注意,即使是失败被取消的状态,也是属于已完成的状态。

下面这张图来自于官方文档,用于说明各种状态的关系:

ChannelFuture状态关系

各种各样的方法被提供,用来检查I/O操作是否已完成、等待完成,并寻回I/O操作的结果。它同样允许你添加ChannelFutureListener,以便于在I/O操作完成的时候,你能够获得通知。

优先使用addListener(GenericFutureListener),而非await()

当做了一个I/O操作并有任何后续任务的时候,推荐优先使用addListener(GenericFutureListener)的方式来获得通知,而非await()。

addListener(GenericFutureListener)是非阻塞的。它会把特定的ChannelFutureListener添加到ChannelFuture中,然后I/O线程会在I/O操作相关的future完成的时候通知监听器。ChannelFutureListener会利于最佳的性能和资源的利用,因为它一点阻塞都没有。然而,如果你不使用基于事件驱动的编程方式,去实现一个后续式的逻辑会变得诡异和难于理解。

对比来看,await()是一个阻塞的操作。一旦被调用,调用者线程会阻塞,直到操作完成。使用await()来实现一个后续式的逻辑会更容易,但是调用者线程会非常没必要的阻塞直到I/O操作完成,并且内部的线程通知是相对来说代价昂贵的。更有甚者,在一些特定的情况下会产生死锁,下面是对这种情况的描述:

 // BAD - NEVER DO THIS
 @Override
 public void channelRead(ChannelHandlerContext ctx, GoodByeMessage msg) {
     ChannelFuture future = ctx.channel().close();
     future.awaitUninterruptibly();
     // Perform post-closure operation
     // ...
 }

 // GOOD
 @Override
 public void channelRead(ChannelHandlerContext ctx,  GoodByeMessage msg) {
     ChannelFuture future = ctx.channel().close();
     future.addListener(new ChannelFutureListener() {
         public void operationComplete(ChannelFuture future) {
             // Perform post-closure operation
             // ...
         }
     });
 }

撇开上面提到的缺点不谈,确实还是有一些情况在调用await()的时候会更方便的。在这种情况下,请确保你不是在一个I/O线程中调用的await()。否则,为了避免死锁的情况,BlockingOperationException将被提出。

不要混淆I/O timeout和await timeout

你在使用Future.await(long), Future.await(long, TimeUnit),Future.awaitUninterruptibly(long),或者Future.awaitUninterruptibly(long, TimeUnit)的时候,指定的timeout的值和I/O timeout一点关系都没有。如果一个操作超时了,future将会被标记为已完成-失败,就像上面的图中描述的那样。例如,连接超时应当通过一个传输特定的选项来配置:

 // BAD - NEVER DO THIS
 Bootstrap b = ...;
 ChannelFuture f = b.connect(...);
 f.awaitUninterruptibly(10, TimeUnit.SECONDS);
 if (f.isCancelled()) {
     // Connection attempt cancelled by user
 } else if (!f.isSuccess()) {
     // You might get a NullPointerException here because the future
     // might not be completed yet.
     f.cause().printStackTrace();
 } else {
     // Connection established successfully
 }

 // GOOD
 Bootstrap b = ...;
 // Configure the connect timeout option.
 b.option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 10000);
 ChannelFuture f = b.connect(...);
 f.awaitUninterruptibly();

 // Now we are sure the future is completed.
 assert f.isDone();

 if (f.isCancelled()) {
     // Connection attempt cancelled by user
 } else if (!f.isSuccess()) {
     f.cause().printStackTrace();
 } else {
     // Connection established successfully
 }

© 著作权归作者所有

上一篇: Netty的ChannelFuture
下一篇: NIO-Selector类详解
刺猬一号
粉丝 12
博文 373
码字总数 616361
作品 0
深圳
私信 提问
Netty in Action ——— ChannelHandler 和 ChannelPipeline

本文是Netty文集中“Netty in action”系列的文章。主要是对Norman Maurer and Marvin Allen Wolfthal 的 《Netty in action》一书简要翻译,同时对重要点加上一些自己补充和扩展。 概要 Ch...

tomas家的小拨浪鼓
2017/10/30
0
0
大众点评Cat源码阅读(七)——客户端选择server的机制

一、概要思路 客户端跟服务端连接建立,分两步: 初始ChannelMananger的时候 ; ChannelManager异步线程,每隔10秒做一次检查。 1.1 初始ChannelMananger的时候 实例化ChannelManager的时候,...

liangxiao
2017/12/21
32
0
netty io.netty.channel 简介1

Interface AddressedEnvelope<M,A extends SocketAddress> 此接口将一个消息、发送地址和接收地址封装到了一起 Interface Channel 此接口表示到网络socket或者组件(component)的一个连接,...

andyyuan5546
2015/08/12
665
0
Netty之Future和ChannelFuture

Future,在Netty中所有的IO操作都是异步的,因此,你不能立刻得知消息是否被正确处理,但是我们可以过一会等它执行完成或者直接注册一个监听,具体的实现就是通过Future和ChannelFuture,他们...

秋风醉了
2014/06/12
1K
0
Netty源码分析 服务器端1

Netty是由JBOSS提供的一个java开源框架。Netty提供异步的、事件驱动的网络应用程序框架和工具,用以快速开发高性能、高可靠性的网络服务器和客户端程序。 做过NIO开发的人都遇到很多难以解决...

hyssop
2015/11/25
82
0

没有更多内容

加载失败,请刷新页面

加载更多

PostgreSQL 11.3 locking

rudi
今天
5
0
Mybatis Plus sql注入器

一、继承AbstractMethod /** * @author beth * @data 2019-10-23 20:39 */public class DeleteAllMethod extends AbstractMethod { @Override public MappedStatement injectMap......

一个yuanbeth
今天
10
1
一次写shell脚本的经历记录——特殊字符惹的祸

本文首发于微信公众号“我的小碗汤”,扫码文末二维码即可关注,欢迎一起交流! redis在容器化的过程中,涉及到纵向扩pod实例cpu、内存以及redis实例的maxmemory值,statefulset管理的pod需要...

码农实战
今天
4
0
为什么阿里巴巴Java开发手册中不建议在循环体中使用+进行字符串拼接?

之前在阅读《阿里巴巴Java开发手册》时,发现有一条是关于循环体中字符串拼接的建议,具体内容如下: 那么我们首先来用例子来看看在循环体中用 + 或者用 StringBuilder 进行字符串拼接的效率...

武培轩
今天
8
0
队列-链式(c/c++实现)

队列是在线性表功能稍作修改形成的,在生活中排队是不能插队的吧,先排队先得到对待,慢来得排在最后面,这样来就形成了”先进先出“的队列。作用就是通过伟大的程序员来实现算法解决现实生活...

白客C
今天
81
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部