Java AIO初探(异步网络IO) - 编程入门网

write调用返回的结果与read一样是一个Future<Integer>，而write的CompletionHandler处理的核心逻辑大概是这样：

@Override 　　　　 public　void　completed(Integer　result,　AbstractAioSession　session)　{ 　　　　　　　　 if　(log.isDebugEnabled()) 　　　　　　　　　　　　 log.debug("Session("　+　session.getRemoteSocketAddress() 　　　　　　　　　　　　　　　　　　　　 +　")　writen　"　+　result　+　"　bytes"); 　　　　　　　　 WriteMessage　writeMessage; 　　　　　　　　 Queue<WriteMessage>　writeQueue　=　session.getWriteQueue(); 　　　　　　　　 synchronized　(writeQueue)　{ 　　　　　　　　　　　　 writeMessage　=　writeQueue.peek(); 　　　　　　　　　　　　 if　(writeMessage.getWriteBuffer()　==　null 　　　　　　　　　　　　　　　　　　　　 ||　!writeMessage.getWriteBuffer().hasRemaining())　{ 　　　　　　　　　　　　　　　　 writeQueue.remove(); 　　　　　　　　　　　　　　　　 if　(writeMessage.getWriteFuture()　!=　null)　{ 　　　　　　　　　　　　　　　　　　　　 writeMessage.getWriteFuture().setResult(Boolean.TRUE); 　　　　　　　　　　　　　　　　 } 　　　　　　　　　　　　　　　　 try　{ 　　　　　　　　　　　　　　　　　　　　 session.getHandler().onMessageSent(session, 　　　　　　　　　　　　　　　　　　　　　　　　　　　　 writeMessage.getMessage()); 　　　　　　　　　　　　　　　　 }　catch　(Exception　e)　{ 　　　　　　　　　　　　　　　　　　　　 session.onException(e); 　　　　　　　　　　　　　　　　 } 　　　　　　　　　　　　　　　　 writeMessage　=　writeQueue.peek(); 　　　　　　　　　　　　 } 　　　　　　　　 } 　　　　　　　　 if　(writeMessage　!=　null)　{ 　　　　　　　　　　　　 try　{ 　　　　　　　　　　　　　　　　 session.pendingWrite(writeMessage); 　　　　　　　　　　　　 }　catch　(IOException　e)　{ 　　　　　　　　　　　　　　　　 session.onException(e); 　　　　　　　　　　　　　　　　 session.close(); 　　　　　　　　　　　　 } 　　　　　　　　 } 　　　　 }

compete方法中的result就是实际写入的字节数，然后我们判断消息的缓冲区是否还有剩余，如果没有就将消息从队列中移除，如果队列中还有消息，那么继续发起write调用。

重复一下，这里引用的代码都是yanf4j aio分支中的源码，感兴趣的朋友可以直接check out出来看看: http://yanf4j.googlecode.com/svn/branches/yanf4j-aio。

在引入了aio之后，java对于网络层的支持已经非常完善，该有的都有了，java也已经成为服务器开发的首选语言之一。java的弱项在于对内存的管理上，由于这一切都交给了GC，因此在高性能的网络服务器上还是Cpp的天下。java这种单一堆模型比之erlang的进程内堆模型还是有差距，很难做到高效的垃圾回收和细粒度的内存管理。

这里仅仅是介绍了aio开发的核心流程，对于一

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