AsynchronousFileChannel

AsynchronousFileChannel在Java7被加入了Java NIO。AsynchronousFileChannel让我们可以以异步的方式从文件读取或往文件写入数据。本教程会介绍怎么使用AsynchronousFileChannel

Creating an AsynchronousFileChannel

通过静态方法open()可以创建AsynchronousFileChannel实例。这有个例子:

Path path = Paths.get("data/test.xml");

AsynchronousFileChannel fileChannel = AsynchronousFileChannel.open(path, StandardOpenOption.READ);

open()方法的第一个参数是指向该AsynchronousFileChannel关联的文件的Path实例。

第二个参数是一个或多个打开选项,它用来告诉AsynchronousFileChannel要对底层的文件执行什么操作。本例中,我们使用了StandardOpenOption.READ,意味着文件将被打开以供读取。

Reading Data

您可以通过两种方式从AsynchronousFileChannel读取数据。读取数据的每一种方法都调用AsynchronousFileChannelread()方法之一。这两种读取数据的方法将在下面的部分中介绍。

Reading Data Via a Future

第一种从AsynchronousFileChannel读取数据的方式是调用其返回值类型为Futureread()方法。就像下面这样:

Future<Integer> operation = fielChannel.read(buffer, 0);

这个版本的read()方法接收一个ByteBuffer作为第一个参数。从AsynchronousFileChannel读取的数据就会被读入该ByteBuffer。第二个参数是要开始读取的文件字节位置。

read()方法会立即返回,即使读取操作还未完成。你可以通过调用read()方法返回Future实例的isDone()方法来检查读取操作是否已经完成。

这有一个长一点的例子,展示了如何是这个版本的read()方法:

AsynchronousFileChannel fileChannel = AsynchronousFileChannel.open(path, StandardOpenOption.READ);

ByteBuffer buffer = ByteBuffer.allocate(1024);
long position = 0;

Future<Integer> operation = fileChannel.read(buffer, position);

while (!operation.isDone());

buffer.flip();
byte[] data = new byte[buffer.limit()];
buffer.get(data);
System.out.println(new String(data));
buffer.clear();

该例创建了一个AsynchronousFileChannel实例,然后创建了一个ByteBuffer,并同一个为0的位置一起作为参数传给了read()方法。在调用read()方法后,该例一直循环直到read()方法返回的Future对象的isDone()返回true为止。当然,这不是一种有效的CPU使用方式 - 但你总需要以某种方式等待读取操作完成。

当读取操作完成后,数据就被读入了ByteBuffer,然后装入了String,然后打印。

Reading Data Via a CompletionHandler

AsynchronousFileChannel读取数据的第二种方式是调用其接收一个CompletionHandler作为参数的read()方法。这有个例子:

fileChannel.read(buffer, position, buffer, new CompletionHandler<Integer, ByteBuffer>() {
    @Override
    public void completed(Integer result, ByteBuffer attachment) {
        System.out.println("result = " + result);

        attachment.flip();
        byte[] data = new byte[attachment.limit()];
        attachment.get(data);
        System.out.println(new String(data));
        attachment.clear();
    }

    @Override
    public void failed(Throwable exc, ByteBuffer attachment) {

    }
});

当读取操作完成后,CompletionHandlercompleted()方法就会被调用。当传递给complete()方法的参数时,将传递一个整数,表示读取了多少字节,以及传递给read()方法的附件附件read()方法的第三个参数。本例中就是数据被读入的ByteBuffer。你可以选择附带任何对象。

如果读取操作失败,则CompletionHandler的failed()会被调用。

Writing Data

就像读取数据一样,你有两种方式可以将数据写入AsynchronousFileChannel。写入数据的每一种方法都调用AsynchronousFileChannelwrite()方法之一。这两种写数据的方法将在下面的部分中介绍。

Writing Data Via a Future

AsynchronousFileChannel同样允许你以异步的方式写入数据。下面是一个完整的AsynchronousFileChannel写入数据的例子:

Path path = Paths.get("data/test-write.txt");
AsynchronousFileChannel fileChannel = AsynchronousFileChannel.open(path, StandardOpenOption.WRITE);

ByteBuffer buffer = ByteBuffer.allocate(1024);
long position = 0;

buffer.put("test data".getBytes());
buffer.flip();

Future<Integer> operation = fileChannel.write(buffer, position);
buffer.clear();

while (!operation.isDone());

System.out.println("Write done");

首先,以写模式打开了一个AsynchronousFileChannel。然后创建了一个ByteBuffer,并向其中写入了一些数据。然后ByteBuffer中的数据被写入了文件。最后,例子通过检查返回的Future来看写入操作是否完成。

注意,在代码工作之前,文件必须已经存在。如果文件不存在,write()方法会抛出一个java.nio.file.NoSuchFileException

你可以通过以下代码来确保Path指向的文件存在:

if (!Files.exists(path)) {
    Files.createFile(path);
}

Writing Data Via a CompletionHandler

你也可以用CompletionHandler代替Future来向AsynchronousFileChannel写入数据,以便在数据写入完成时告知你。下面是一个通过CompletionHandlerAsynchronousFileChannel写入数据的例子:

Path path = Paths.get("data/test-write.txt");
if (!Files.exists(path)){
    Files.createFile(path);
}
AsynchronousFileChannel fileChannel = AsynchronousFileChannel.open(path, StandardOpenOption.WRITE);

ByteBuffer buffer = ByteBuffer.allocate(1024);
long position = 0;

buffer.put("test data".getBytes());
buffer.flip();

fileChannel.write(buffer, position, buffer, new CompletionHandler<Integer, ByteBuffer>() {

    @Override
    public void completed(Integer result, ByteBuffer attachment) {
        System.out.println("bytes written: " + result);
    }

    @Override
    public void failed(Throwable exc, ByteBuffer attachment) {
        System.out.println("Write failed");
        exc.printStackTrace();
    }
});

当写入操作完成后,CompletionHandlercompleted()方法就会被调用。如果因为某些原因导致写入失败,failed()方法就会被调用。

注意ByteBuffer是怎么作为附件使用的 - 传给CompletionHandler的方法的参数。

发现貌似有人在看这个系列文章了,有必要说明下,这个Java NIO系列来源于jenkov.com,本文只是翻译,希望大家千万不要误会,本文不是原创。原文地址:Java NIO

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 214,377评论 6 496
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 91,390评论 3 389
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 159,967评论 0 349
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 57,344评论 1 288
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 66,441评论 6 386
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 50,492评论 1 292
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 39,497评论 3 412
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 38,274评论 0 269
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,732评论 1 307
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,008评论 2 328
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,184评论 1 342
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 34,837评论 4 337
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 40,520评论 3 322
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,156评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,407评论 1 268
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 47,056评论 2 365
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 44,074评论 2 352