ChannelFuture的用法

综述

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
 }