异步IO通道

1f2f7374e1990b4bb551fd141bc4a53d

Java7之前，要异步实现对大文件的读写，借助java.util.concurrent中的相关类库也是可以实现的，只是依然会比较繁琐，实现起来也不是那么轻松。

Java7直接提供了用于异步操作io的各种通道。

新的异步功能的关键点，它们是Channel类的一些子集。包括：

• AsynchronousFileChannel：针对文件；
• AsynchronousSocketChannel ：针对客户端的socket；
• AsynchronousServerSocketChannel：针对服务器端的异步socket，用来接收到来的连接。

一些需要访问较大，耗时的操作，或是其它的类似实例，可以考虑应用此功能。

这里，我们以针对文件的异步操作通道AsynchronousFileChannel来看看怎么用。

package java7;

import java.io.IOException;
import java.nio.ByteBuffer;
import java.nio.channels.AsynchronousFileChannel;
import java.nio.charset.Charset;
import java.nio.file.Path;
import java.nio.file.Paths;
import java.util.concurrent.Future;

/**
 * Created by xieqiang on 2017/4/8.
 */
public class AsyncChannel {

    public static void main(String[] a) throws IOException {
        //定义要打开的文件对应的path
        Path path= Paths.get("/Users/xieqiang/test.txt");

        //打开一个可以异步读写文件的通道
        AsynchronousFileChannel channel=AsynchronousFileChannel.open(path);

        //通道是基于ByteBuff读写的，所以需要声明一个bytebuff来存储要读写的数据
        ByteBuffer bf=ByteBuffer.allocate(1024);//声明1024个字节的buff

        //从0(文件开头)异步读取文件内容到bf,由于是异步操作，不管文件有没有读取完成，这句代码执行后立刻就会执行后面的代码，通过future可以知道结果
        Future future=channel.read(bf,0);
        System.out.println("文件读取中...");
        //如果文件没有读完，可以继续干些别的事情
        while(!future.isDone()){
            System.out.println("我干别的了，你慢慢读");
        }
        System.out.println("文件读取完成");
        bf.flip();
        //打印bytebuff中的内容
        System.out.println(Charset.forName("utf-8").decode(bf));
        channel.close();
    }
}

运行结果:

文件读取中...
我干别的了，你慢慢读
我干别的了，你慢慢读
我干别的了，你慢慢读
我干别的了，你慢慢读
我干别的了，你慢慢读
我干别的了，你慢慢读
我干别的了，你慢慢读
我干别的了，你慢慢读
我干别的了，你慢慢读
我干别的了，你慢慢读
我干别的了，你慢慢读
我干别的了，你慢慢读
我干别的了，你慢慢读
我干别的了，你慢慢读
我干别的了，你慢慢读
我干别的了，你慢慢读
文件读取完成
hello,java7,我是不迷失
test

大致原理

创建异步通道时，会创建任务执行线程池，如果没有指定线程池，那会为其分配一个系统默认的线程池。

你可以自己提供和配置一个线程池。参见api

AsynchronousFileChannel open(Path file,Set<? extends OpenOption> options,ExecutorService executor,FileAttribute<?>... attrs)

执行异步操作时，会让线程池(executors)执行返回一个Future，如果你熟悉java.util.concurrent的工具，应该不难理解。否则，你应该去好好学习下java.util.concurrent中的相关技术。

--

@不迷失|知识改善生活

weixin
微信公众号:java技术

专注技术研究与视频教学，分享有价值的技术与经验，关注程序员的发展!

--
技术博客:http://bumishi.cn

技术交流群:245130488

@不迷失教学视频

QQ课堂:http://bumishi.ke.qq.com

百度传课:http://chuanke.com/s3377987.html