java7新特性8-异步通道
2017-04-08 本文已影响181人
不迷失
异步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
