AIO是什么

异步非阻塞，服务器实现模式为一个有效请求一个线程，客户端的I/O请求都是由OS先完成了再通知服务器应用去启动线程进行处理，每个线程不必亲自处理io，而是委派os来处理，并且也不需要等待io完成了，如果完成后，os会通知的。

本文所说的AIO特指Java环境下的AIO。AIO是java中IO模型的一种，作为NIO的改进和增强随JDK1.7版本更新被集成在JDK的nio包中，因此AIO也被称作是NIO2.0。区别于传统的BIO(Blocking IO,同步阻塞式模型,JDK1.4之前就存在于JDK中，NIO于JDK1.4版本发布更新)的阻塞式读写，AIO提供了从建立连接到读、写的全异步操作。AIO可用于异步的文件读写和网络通信。本文将介绍如何使用AIO实现一个简单的网络通信以及AIO的一些比较关键的API。

AIO流程

AIO主要API详解

实现一个最简单的AIO socket通信server、client，主要需要这些相关的类和接口：

此外，还有可选的用于异步通道资源共享的AsynchronousChannelGroup类，接下来将一一介绍这些类的主要接口及使用。

3.1.1 AsynchronousServerSocketChannel

AsynchronousServerSocketChannel是一个流式监听套接字的异步通道。

AsynchronousServerSocketChannel的使用需要经过三个步骤：创建/打开通道、绑定地址和端口和监听客户端连接请求。

一、创建/打开通道：简单地，可以通过调用
AsynchronousServerSocketChannel的静态方法open()来创建
AsynchronousServerSocketChannel实例：

try {
  AsynchronousServerSocketChannel serverSocketChannel = AsynchronousServerSocketChannel.open();
} catch (IOException e) {
  e.printStackTrace();
}

当打开通道失败时，会抛出一个IOException异常。
AsynchronousServerSocketChannel提供了设置通道分组(AsynchronousChannelGroup)的功能，以实现组内通道资源共享。可以调用open(AsynchronousChannelGroup)重载方法创建指定分组的通道：

try {
  ExecutorService pool = Executors.newCachedThreadPool();
  AsynchronousChannelGroup group = AsynchronousChannelGroup.withCachedThreadPool(pool, 10);
  AsynchronousServerSocketChannel serverSocketChannel = AsynchronousServerSocketChannel.open(group);
} catch (IOException e) {
  e.printStackTrace();
}

AsynchronousChannelGroup封装了处理由绑定到组的异步通道所触发的I/O操作完成所需的机制。每个AsynchronousChannelGroup关联了一个被用于提交处理I/O事件和分发消费在组内通道上执行的异步操作结果的completion-handlers的线程池。除了处理I/O事件，该线程池还有可能处理其他一些用于支持完成异步I/O操作的任务。从上面例子可以看到，通过指定AsynchronousChannelGroup的方式打开
AsynchronousServerSocketChannel，可以定制server channel执行的线程池。有关AsynchronousChannelGroup的详细介绍可以查看官方文档注释。如果不指定AsynchronousChannelGroup，则
AsynchronousServerSocketChannel会归类到一个默认的分组中。

二、绑定地址和端口：通过调用
AsynchronousServerSocketChannel.bind(SocketAddress)方法来绑定监听地址和端口：

// 构建一个InetSocketAddress实例以指定监听的地址和端口，如果需要指定ip，则调用InetSocketAddress(ip,port)构造方法创建即可
serverSocketChannel.bind(new InetSocketAddress(port));

三、监听和接收客户端连接请求：

监听客户端连接请求，主要通过调用
AsynchronousServerSocketChannel.accept()方法完成。accept()有两个重载方法：

public abstract  void accept(A,CompletionHandler);
public abstract Future accept();

这两个重载方法的行为方式完全相同，事实上，AIO的很多异步API都封装了诸如此类的重载方法：提供CompletionHandle回调参数或者返回一个Future类型变量。用过Feture接口的都知道，可以调用Feture.get()方法阻塞等待调用结果。以第一个重载方法为例，当接受一个新的客户端连接，或者accept操作发生异常时，会通过CompletionHandler将结果返回给用户处理：

serverSocketChannel
.accept(serverSocketChannel, new CompletionHandler() {
          @Override
          public void completed(final AsynchronousSocketChannel result,
                                final AsynchronousServerSocketChannel attachment) {
            // 接收到新的客户端连接时回调
            // result即和该客户端的连接会话
            // 此时可以通过result与客户端进行交互
          }

          @Override
          public void failed(final Throwable exc, final AsynchronousServerSocketChannel attachment) {
            // accept失败时回调
          }
        });

需要注意的是，
AsynchronousServerSocketChannel是线程安全的，但在任何时候同一时间内只能允许有一个accept操作。因此，必须得等待前一个accept操作完成之后才能启动下一个accept：

serverSocketChannel
.accept(serverSocketChannel, new CompletionHandler() {
          @Override
          public void completed(final AsynchronousSocketChannel result,
                                final AsynchronousServerSocketChannel attachment) {
            // 接收到新的客户端连接，此时本次accept已经完成
            // 继续监听下一个客户端连接到来
            serverSocketChannel.accept(serverSocketChannel,this);
            // result即和该客户端的连接会话
            // 此时可以通过result与客户端进行交互
          }
          ...
        });

此外，还可以通过以下方法获取和设置
AsynchronousServerSocketChannel的socket选项：

// 设置socket选项
serverSocketChannel.setOption(StandardSocketOptions.SO_KEEPALIVE,true);
// 获取socket选项设置
boolean keepAlive = serverSocketChannel.getOption(StandardSocketOptions.SO_KEEPALIVE);

其中StandardSocketOptions类封装了常用的socket设置选项。

获取本地地址：

InetSocketAddress address = (InetSocketAddress) serverSocketChannel.getLocalAddress();

3.1.2 AsynchronousSocketChannel

AsynchronousSocketChannel是一个流式连接套接字的异步通道。

AsynchronousSocketChannel表示服务端与客户端之间的连接通道。客户端可以通过调用AsynchronousSocketChannel静态方法open()创建，而服务端则通过调用
AsynchronousServerSocketChannel.accept()方法后由AIO内部在合适的时候创建。下面以客户端实现为例，介绍AsynchronousSocketChannel。

一、创建AsynchronousSocketChannel并连接到服务端：需要通过open()创建和打开一个AsynchronousSocketChannel实例，再调用其connect()方法连接到服务端，接着才可以与服务端交互：

// 打开一个socket通道
AsynchronousSocketChannel socketChannel = AsynchronousSocketChannel.open();
// 阻塞等待连接成功
socketChannel.connect(new InetSocketAddress(ip,port)).get();
// 连接成功，接下来可以进行read、write操作

同
AsynchronousServerSocketChannel，AsynchronousSocketChannel也提供了open(AsynchronousChannelGroup)方法用于指定通道分组和定制线程池。socketChannel.connect()也提供了CompletionHandler回调和Future返回值两个重载方法，上面例子使用带Future返回值的重载，并调用get()方法阻塞等待连接建立完成。

二、发送消息：

可以构建一个ByteBuffer对象并调用socketChannel.write(ByteBuffer)方法异步发送消息，并通过CompletionHandler回调接收处理发送结果：

ByteBuffer writeBuf = ByteBuffer.wrap("From socketChannel:Hello i am socketChannel".getBytes());
socketChannel.write(writeBuf, null, new CompletionHandler() {
  @Override
  public void completed(final Integer result, final Object attachment) {
    // 发送完成，result：总共写入的字节数
  }

  @Override
  public void failed(final Throwable exc, final Object attachment) {
    // 发送失败
  }
});

三、读取消息：

构建一个指定接收长度的ByteBuffer用于接收数据，调用socketChannel.read()方法读取消息并通过CompletionHandler处理读取结果：

ByteBuffer readBuffer = ByteBuffer.allocate(128);
socketChannel.read(readBuffer, null, new CompletionHandler() {
  @Override
  public void completed(final Integer result, final Object attachment) {
    // 读取完成,result:实际读取的字节数。如果通道中没有数据可读则result=-1。
  }

  @Override
  public void failed(final Throwable exc, final Object attachment) {
    // 读取失败
  }
});

此外，AsynchronousSocketChannel也封装了设置/获取socket选项的方法：

// 设置socket选项
socketChannel.setOption(StandardSocketOptions.SO_KEEPALIVE,true);
// 获取socket选项设置
boolean keepAlive = socketChannel.getOption(StandardSocketOptions.SO_KEEPALIVE);

3.1.3 CompletionHandler

CompletionHandler是一个用于消费异步I/O操作结果的处理器。

AIO中定义的异步通道允许指定一个CompletionHandler处理器消费一个异步操作的结果。从上文中也可以看到，AIO中大部分的异步I/O操作接口都封装了一个带CompletionHandler类型参数的重载方法，使用CompletionHandler可以很方便地处理AIO中的异步I/O操作结果。CompletionHandler是一个具有两个泛型类型参数的接口,声明了两个接口方法：

public interface CompletionHandler {
    void completed(V result, A attachment);
    void failed(Throwable exc, A attachment);
}

其中，泛型V表示I/O操作的结果类型，通过该类型参数消费I/O操作的结果；泛型A为附加到I/O操作中的对象类型，可以通过该类型参数将需要的变量传入到CompletionHandler实现中使用。因此，AIO中大部分的异步I/O操作都有一个类似这样的重载方法：

 void ioOperate(params,A attachment,CompletionHandler handler);

例如，
AsynchronousServerSocketChannel.accept()方法：

public abstract  void accept(A attachment,CompletionHandler handler);

AsynchronousSocketChannel.write()方法等:

public final  void write(ByteBuffer src,A attachment,CompletionHandler handler)

当I/O操作成功完成时，会回调到completed方法，failed方法则在I/O操作失败时被回调。需要注意的是：在CompletionHandler的实现中应当即使处理操作结果，以避免一直占用调用线程而不能分发其他的CompletionHandler处理器。