AIO用于文件处理还是比较快乐的，但用AIO来写网络消息处理服务器端与客户端是比较麻烦的事情，当然这只是我个人意见，主要是有几点原因：
一是AIO需要操作系统支持，还好Windows与Linux(模拟)都支持；
二是AIO同时使用递归调用和异步调用容易把程序员搞晕，代码容易出错；
三是CompletionHandler会使用单独的线程跑，容易出现多线程问题，频繁线程上下文切换比较消耗资源；
四是异步写要创建队列来缓存需要写入的数据，否则肯定会遇到WritePendingException。
相对来说，NIO比较清楚直白，容易控制。
另外，笔者使用多线程模拟多个客户场景失败，代码在run方法中调用AsynchronousSocketChannel.connect()没返回，没连接上服务器，不知道为何，请大侠指教，最后只好使用多个进程模拟多个客户端，写个类似下面代码的bat文件，同时运行多个。
java -classpath .\ com.stevex.app.aio.Client 1
?
java -classpath .\ com.stevex.app.aio.Client 1
?
pause
服务器代码：
package com.stevex.app.aio;
?
import java.io.IOException;
import java.net.InetSocketAddress;
import java.net.StandardSocketOptions;
import java.nio.ByteBuffer;
import java.nio.CharBuffer;
import java.nio.channels.AsynchronousChannelGroup;
import java.nio.channels.AsynchronousServerSocketChannel;
import java.nio.channels.AsynchronousSocketChannel;
import java.nio.channels.CompletionHandler;
//import java.nio.channels.WritePendingException;
import java.nio.charset.CharacterCodingException;
import java.nio.charset.Charset;
import java.util.LinkedList;
import java.util.Queue;
import java.util.concurrent.Executors;
?
public class XiaoNa {
? ? private final AsynchronousServerSocketChannel server;
? ? //写队列，因为当前一个异步写调用还没完成之前，调用异步写会抛WritePendingException
? ? //所以需要一个写队列来缓存要写入的数据，这是AIO比较坑的地方
? ? private final Queue queue = new LinkedList();
? ? private boolean writing = false;
? ?
? ? public static void main(String[] args) throws IOException{
? ? ? ? XiaoNa xiaona = new XiaoNa();
? ? ? ? xiaona.listen();
? ? }
?
? ? public XiaoNa() throws IOException{
? ? ? ? //设置线程数为CPU核数
? ? ? ? AsynchronousChannelGroup channelGroup = AsynchronousChannelGroup.withFixedThreadPool(Runtime.getRuntime().availableProcessors(), Executors.defaultThreadFactory());
? ? ? ? server = AsynchronousServerSocketChannel.open(channelGroup);
? ? ? ? //重用端口
? ? ? ? server.setOption(StandardSocketOptions.SO_REUSEADDR, true);
? ? ? ? //绑定端口并设置连接请求队列长度
? ? ? ? server.bind(new InetSocketAddress(8383), 80);? ?
? ? }
?
? ? public void listen() {
? ? ? ? System.out.println(Thread.currentThread().getName() + ": run in listen method" );
? ? ? ? //开始接受第一个连接请求
? ? ? ? server.accept(null, new CompletionHandler(){? ? ? ? ? ? ? ? ? ? ? ?
? ? ? ? ? ? @Override
? ? ? ? ? ? public void completed(AsynchronousSocketChannel channel,
? ? ? ? ? ? ? ? ? ? Object attachment) {
? ? ? ? ? ? ? ? System.out.println(Thread.currentThread().getName() + ": run in accept completed method" );
? ? ? ? ? ? ? ?
? ? ? ? ? ? ? ? //先安排处理下一个连接请求，异步非阻塞调用，所以不用担心挂住了
? ? ? ? ? ? ? ? //这里传入this是个地雷，小心多线程
? ? ? ? ? ? ? ? server.accept(null, this);
? ? ? ? ? ? ? ? //处理连接读写
? ? ? ? ? ? ? ? handle(channel);
? ? ? ? ? ? }
?
? ? ? ? ? ? private void handle(final AsynchronousSocketChannel channel) {
? ? ? ? ? ? ? ? System.out.println(Thread.currentThread().getName() + ": run in handle method" );
? ? ? ? ? ? ? ? //每个AsynchronousSocketChannel，分配一个缓冲区
? ? ? ? ? ? ? ? final ByteBuffer readBuffer = ByteBuffer.allocateDirect(1024);
? ? ? ? ? ? ? ? readBuffer.clear();
? ? ? ? ? ? ? ? channel.read(readBuffer, null, new CompletionHandler(){
?
? ? ? ? ? ? ? ? ? ? @Override
? ? ? ? ? ? ? ? ? ? public void completed(Integer count, Object attachment) {
? ? ? ? ? ? ? ? ? ? ? ? System.out.println(Thread.currentThread().getName() + ": run in read completed method" );?
? ? ? ? ? ? ? ? ? ? ? ?
? ? ? ? ? ? ? ? ? ? ? ? if(count > 0){
? ? ? ? ? ? ? ? ? ? ? ? ? ? try{
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? readBuffer.flip();
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? //CharBuffer charB