Proactor: send(msg) -> 消息队列是否为空，如果为空,发起read异步调用，并注册CompletionHandler，然后返回。 -> 操作系统负责将你的消息写入，并返回结果（写入的字节数）给Proactor -> Proactor派发CompletionHandler。可见，写入的工作是操作系统在处理，无需用户线程参与。事实上在aio的API 中,AsynchronousChannelGroup就扮演了Proactor的角色。

CompletionHandler有三个方法，分别对应于处理成功、失败、被取消（通过返回的Future)情况下的回调处理：

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

Java AIO初探(异步网络IO)(2)

其中的泛型参数V表示IO调用的结果，而A是发起调用时传入的attchment。

在初步介绍完aio引入的类和接口后，我们看看一个典型的tcp服务端是怎么启动的，怎么接受连接并处理读和写，这里引用的代码都是yanf4j 的aio分支中的代码，可以从svn checkout，svn地址: http://yanf4j.googlecode.com/svn/branches/yanf4j-aio

第一步，创建一个AsynchronousServerSocketChannel，创建之前先创建一个 AsynchronousChannelGroup，上文提到AsynchronousServerSocketChannel可以绑定一个 AsynchronousChannelGroup，那么通过这个AsynchronousServerSocketChannel建立的连接都将同属于一个AsynchronousChannelGroup并共享资源：

this.asynchronousChannelGroup　=　AsynchronousChannelGroup 　　　　　　　　　　　　　　　　　　　　 .withCachedThreadPool(Executors.newCachedThreadPool(), 　　　　　　　　　　　　　　　　　　　　　　　　　　　　 this.threadPoolSize);

然后初始化一个AsynchronousServerSocketChannel，通过open方法：

this.serverSocketChannel　=　AsynchronousServerSocketChannel 　　　　　　　　　　　　　　　　 .open(this.asynchronousChannelGroup);

通过nio 2.0引入的SocketOption类设置一些TCP选项：

this.serverSocketChannel 　　　　　　　　　　　　　　　　　　　　 .setOption( 　　　　　　　　　　　　　　　　　　　　　　　　　　　　 StandardSocketOption.SO_REUSEADDR,true); this.serverSocketChannel 　　　　　　　　　　　　　　　　　　　　 .setOption( 　　　　　　　　　　　　　　　　　　　　　　　　　　　　 StandardSocketOption.SO_RCVBUF,16*1024);

绑定本地地址：

this.serverSocketChannel 　　　　　　　　　　　　　　　　　　　　 .bind(new　InetSocketAddress("localhost",8080),　100);

其中的100用于指定等待连接的队列大小(backlog)。完了吗？还没有，最重要的监听工作还没开始，监听端口是为了等待连接上来以便accept产生一个AsynchronousSocketChannel来表示一个新建立的连接，因此需要发起一个accept调用，调用是异步的，操作系统将在连接建立后，将最后的结果——AsynchronousSocketChannel返回给你：

public　void　pendingAccept()　{ 　　　　　　　　 if　(this.started　&&　this.serverSocketChannel.isOpen())　{ 　　　　　　　　　　　　 this.acceptFuture　=　this.serverSocketChannel.accept(null, 　　　　　　　　　　　　　　　　　　　　 new　AcceptCompletionHandler()); 　　　　　　　　 }　else　{ 　　　　　　　　　

凌众科技专业提供服务器租用、服务器托管、企业邮局、虚拟主机等服务，公司网站：http://www.lingzhong.cn 为了给广大客户了解更多的技术信息，本技术文章收集来源于网络,凌众科技尊重文章作者的版权，如果有涉及你的版权有必要删除你的文章，请和我们联系。以上信息与文章正文是不可分割的一部分,如果您要转载本文章,请保留以上信息，谢谢!