原文地址

目錄

• Java NIO教程
• Java NIO 教程(一) 概述
• Java NIO 教程(二) Channel
• Java NIO 教程(三) Buffer
• Java NIO 教程(四) Scatter/Gather
• Java NIO 教程(五) 通道之間的數(shù)據(jù)傳輸
• Java NIO 教程(六) Selector
• Java NIO 教程(七) FileChannel
• Java NIO 教程(八) SocketChannel
• Java NIO 教程(九) ServerSocketChannel
• Java NIO 教程(十) 非阻塞式服務器
• Java NIO 教程(十一) Java NIO DatagramChannel
• Java NIO 教程(十二) Pipe
• Java NIO 教程(十三) Java NIO vs. IO
• Java NIO 教程(十四) Java NIO Path
• Java NIO 教程(十五) Java NIO Files
• Java NIO 教程(十六) Java NIO AsynchronousFileChannel

在Java 7中盛末，AsynchronousFileChannel被添加到Java NIO。AsynchronousFileChannel使讀取數(shù)據(jù)丁溅，并異步地將數(shù)據(jù)寫入文件成為可能附井。本教程將解釋如何使用AsynchronousFileChannel重归。

創(chuàng)建一個AsynchronousFileChannel

您可以通過它的靜態(tài)方法open()創(chuàng)建一個AsynchronousFileChannel。下面是創(chuàng)建AsynchronousFileChannel的示例:

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

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

open()方法的第一個參數(shù)是指向與AsynchronousFileChannel相關聯(lián)的文件的Path實例。

第二個參數(shù)是一個或多個打開選項蛇更，它告訴AsynchronousFileChannel在底層文件上執(zhí)行哪些操作闺鲸。在本例中筋讨，我們使用了StandardOpenOption.READ選項。閱讀意味著該文件將被打開以供閱讀摸恍。

讀取數(shù)據(jù)

您可以通過兩種方式從AsynchronousFileChannel讀取數(shù)據(jù)悉罕。讀取數(shù)據(jù)的每一種方法都調用AsynchronousFileChannel的read()方法之一。這兩種讀取數(shù)據(jù)的方法都將在下面的部分中介紹立镶。

通過Future閱讀數(shù)據(jù)

從AsynchronousFileChannel讀取數(shù)據(jù)的第一種方法是調用返回Future的read()方法壁袄。下面是如何調用這個read()方法的示例:

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

read()方法的這個版本將ByteBuffer作為第一個參數(shù)。從AsynchronousFileChannel讀取的數(shù)據(jù)被讀入這個ByteBuffer媚媒。第二個參數(shù)是文件中的字節(jié)位置嗜逻，以便開始讀取。

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();

這個例子創(chuàng)建了一個AsynchronousFileChannel，然后創(chuàng)建一個ByteBuffer搪哪，它被傳遞給read()方法作為參數(shù)靡努，以及一個0的位置。在調用read()之后，這個示例循環(huán)惑朦，直到返回的isDone()方法返回true神年。當然，這不是非常有效地使用CPU行嗤，但是您需要等到讀取操作完成之后才會執(zhí)行已日。

讀取操作完成后，數(shù)據(jù)讀取到ByteBuffer中栅屏，然后進入一個字符串并打印到System.out中飘千。

通過一個CompletionHandler讀取數(shù)據(jù)

從AsynchronousFileChannel讀取數(shù)據(jù)的第二種方法是調用read()方法版本，該方法將一個CompletionHandler作為參數(shù)栈雳。下面是如何調用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) {

    }
});

一旦讀取操作完成护奈，將調用CompletionHandler的completed()方法。對于completed()方法的參數(shù)傳遞一個整數(shù)哥纫，它告訴我們讀取了多少字節(jié)霉旗，以及傳遞給read()方法的“附件”≈В“附件”是read()方法的第三個參數(shù)厌秒。在本例中，它是ByteBuffer擅憔，數(shù)據(jù)也被讀取鸵闪。您可以自由選擇要附加的對象。

如果讀取操作失敗暑诸，則將調用CompletionHandler的failed()方法蚌讼。

寫數(shù)據(jù)

就像閱讀一樣，您可以通過兩種方式將數(shù)據(jù)寫入一個AsynchronousFileChannel个榕。寫入數(shù)據(jù)的每一種方法都調用異步文件通道的write()方法之一篡石。這兩種方法都將在下面的部分中介紹。

通過Future寫數(shù)據(jù)

AsynchronousFileChannel還允許您異步地寫數(shù)據(jù)西采。下面是一個完整的Java 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以寫模式打開。然后創(chuàng)建一個ByteBuffer苛让，并將一些數(shù)據(jù)寫入其中沟蔑。然后，ByteBuffer中的數(shù)據(jù)被寫入到文件中狱杰。最后瘦材，示例檢查返回的Future，以查看寫操作完成時的情況仿畸。

注意食棕，在此代碼生效之前朗和，文件必須已經存在。如果該文件不存在簿晓，那么write()方法將拋出一個java.nio.file.NoSuchFileException眶拉。

您可以確保該Path指向的文件具有以下代碼:

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

通過一個CompletionHandler寫入數(shù)據(jù)

您還可以使用一個CompletionHandler將數(shù)據(jù)寫入到AsynchronousFileChannel中，以告訴您何時完成寫入憔儿，而不是Future忆植。下面是一個將數(shù)據(jù)寫入到AsynchronousFileChannel的示例，該通道有一個CompletionHandler:

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();
    }
});

當寫操作完成時谒臼，將會調用CompletionHandler的completed()方法朝刊。如果由于某種原因而寫失敗，則會調用failed()方法蜈缤。

注意如何將ByteBuffer用作附件——該對象被傳遞給CompletionHandler的方法拾氓。