Java AIO详解

2017-07-05  本文已影响0人  每天学点编程

JDK1.7升级了NIO类库,升级后的NIO类库被称为NIO 2.0。
Java正式提供了异步文件I/O操作,同时提供了与UNIX网络编程事件驱动I/O对应的AIO。

AIO编程

NIO 2.0引入了新的异步通道的概念,并提供了异步文件通道和异步套接字通道的实现。

异步通道获取获取操作结果方式:
1.使用java.util.concurrent.Future类表示异步操作的结果;
2.在执行异步操作的时候传入一个java.nio.channels
操作完成后胡回调CompletionHandler接口的实现类。

NIO 2.0的异步套接字通道是真正的异步非阻塞I/O,对应于UNIX网络编程中的事件驱动I/O(AIO)。

AIO版本TimeServer

主程序:

开启一个线程运行服务,下面是任务类的实现:

CompletionHandler:
public void completed (AsynchronousSocketChannel result, AsyncTimeServerHandler attachment);
public void failed (Throwable exc, AsyncTimeServerHandler attachment)

接收客户端连接的回调类:

读取客户端的回调类:


AIO版本TimeClient

客户端:

客户端回调类:

一点说明

JDK底层通过线程池ThreadPoolExecutor来执行回调通知,异步回调通知类由sun.nio.ch.AsynchronousChannelGroupImpl实现,它经过层层调用,最终回调com.phei.netty.aio.AsyncTimeClientHandler$1.completed方法,完成回调通知。

异步Socket Channel是被动执行对象,我们不需要像NIO编程那样创建一个独立的I/O线程来处理读写操作。对于AsynchronousServerSocketChannelAsynchronousSocketChannel它们都由JDK底层的线程池负责回调并驱动读写操作。正因为如此,基于NIO 2.0新的异步非阻塞Channel进行编程比NIO编程更为简单。

上一篇下一篇

猜你喜欢

热点阅读