在JAVA 7，AsynchronousFileChannel 被添加到了Java NIO中。使用AsynchronousFileChannel可以實(shí)現(xiàn)異步地讀取和寫(xiě)入文件數(shù)據(jù)。
創(chuàng)建一個(gè)AsynchronousFileChannel
我們可以使用AsynchronousFileChannel提供的靜態(tài)方法 open() 創(chuàng)建它。示例代碼如下：
Path path = Paths.get("data/test.xml");
AsynchronousFileChannel fileChannel =
AsynchronousFileChannel.open(path, StandardOpenOption.READ);
第一個(gè)參數(shù)是一個(gè) PATH 的對(duì)像實(shí)例，它指向了那個(gè)與 AsynchronousFileChannel 相關(guān)聯(lián)的文件。
第二個(gè)參數(shù)是一個(gè)或多個(gè)操作選項(xiàng)，它決定了 AsynchronousFileChannel 將對(duì)目標(biāo)文件做何種操作。示例代碼中我們使用了 StandardOpenOption.READ ，它表明我們將要對(duì)目標(biāo)文件進(jìn)行讀操作。
讀取數(shù)據(jù)
AsynchronousFileChannel 提供了兩種讀取數(shù)據(jù)的方式，都是調(diào)用它本身的 read() 方法。下面將對(duì)兩種方式進(jìn)行介紹。
使用Futrue讀取數(shù)據(jù)第一種反式是調(diào)用 AsynchronousFileChannel 的 read() 方法，該方法反回一個(gè) Future 類型的對(duì)象。
Future operation = fileChannelread(buffer, 0);
第一個(gè)參數(shù)是ByteBuffer，從 AsynchronousFileChannel 中讀取的數(shù)據(jù)先寫(xiě)入這個(gè) ByteBuffer 。
第二個(gè)參數(shù)表示從文件讀取數(shù)據(jù)的開(kāi)始位置。
此 read() 方法會(huì)立即返回，即使整個(gè)讀的過(guò)程還沒(méi)有完全結(jié)束。我們可以通過(guò)operation.isDone()來(lái)檢查讀取是否完成。這里的 operation 是上面調(diào)用 read() 方法返回的 Future 類型的實(shí)例。下面是一段詳細(xì)的代碼示例：
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)建了一個(gè) AsynchronousFileChannel 對(duì)象，然后調(diào)用它的read()方法返回一個(gè)Future。其中read()方法需要兩個(gè)參數(shù)，一個(gè)是ByteBuffer，另一個(gè)是讀取文件的開(kāi)始位置。然后通過(guò)循環(huán)調(diào)用isDone() 方法檢測(cè)讀取過(guò)程是否完成，完成后 isDone()方法將返回true。盡管這樣讓cpu空轉(zhuǎn)了一會(huì)，但是我們還是應(yīng)該等讀取操作完成后再進(jìn)行后續(xù)的步驟。
一旦讀取完成，數(shù)據(jù)被存儲(chǔ)到ByteBuffer，然后將數(shù)據(jù)轉(zhuǎn)化為字符串既而輸出。
使用CompletionHandler讀取數(shù)據(jù)
第二種讀取數(shù)據(jù)的方式是調(diào)用AsynchronousFileChannel 的另一個(gè)重載 read() 方法，改方法需要一個(gè)CompletionHandler 作為參數(shù)。下面是代碼示例：
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的 complete() 方法將會(huì)被調(diào)用。它的第一個(gè)參數(shù)是個(gè) Integer類型，表示讀取的字節(jié)數(shù)。第二個(gè)參數(shù) attachment 是 ByteBuffer 類型的，用來(lái)存儲(chǔ)讀取的數(shù)據(jù)。它其實(shí)就是由 read() 方法的第三個(gè)參數(shù)。當(dāng)前示例中，我們選用 ByteBuffer 來(lái)存儲(chǔ)數(shù)據(jù)，其實(shí)我們也可以選用其他的類型。
讀取失敗的時(shí)候，CompletionHandler的 failed()方法會(huì)被調(diào)用。
寫(xiě)入數(shù)據(jù)就像讀取一樣，我們同樣有兩種方式向 AsynchronousFileChannel 寫(xiě)入數(shù)據(jù)。我們可以調(diào)用它的2個(gè)重載的 write() 方法。下面我們將分別加以介紹。
使用Future讀取數(shù)據(jù)
AsynchronousFileChannel也可以異步寫(xiě)入數(shù)據(jù)。下面是一個(gè)完整的寫(xiě)入示例：
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");
首先實(shí)例化一個(gè)寫(xiě)入模式的 AsynchronousFileChannel, 然后創(chuàng)建一個(gè) ByteBuffer 并寫(xiě)入一些數(shù)據(jù)。再然后將數(shù)據(jù)寫(xiě)入文件。最后，檢查返回的 Future，看是否寫(xiě)入完成。
注意，寫(xiě)入目標(biāo)文件要提前創(chuàng)建好，如果它不存在的話，writh() 方法會(huì)拋出一個(gè) java.nio.file.NoSuchFileException。
我們可以用以下方式來(lái)解決這一問(wèn)題：
if(!Files.exists(path)){
Files.createFile(path);
}
使用CompletionHandler寫(xiě)入數(shù)據(jù)
我們也可以使用 CompletionHandler代替Future向AsynchronousFileChannel寫(xiě)入數(shù)據(jù)，這種方式可以更加直接的知道寫(xiě)入過(guò)程是否完成。下面是示例程序：
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();
}
});
當(dāng)寫(xiě)入程序完成時(shí)，CompletionHandler的completed()方法將會(huì)被調(diào)用，相反的如果寫(xiě)入失敗則會(huì)調(diào)用failed()方法。
要留意CompletionHandler的方法的參數(shù) attachemnt是怎么使用的。
最后
私信回復(fù) 資料 領(lǐng)取一線大廠Java面試題總結(jié)+阿里巴巴泰山手冊(cè)+各知識(shí)點(diǎn)學(xué)習(xí)思維導(dǎo)+一份300頁(yè)pdf文檔的Java核心知識(shí)點(diǎn)總結(jié)！
這些資料的內(nèi)容都是面試時(shí)面試官必問(wèn)的知識(shí)點(diǎn)，篇章包括了很多知識(shí)點(diǎn)，其中包括了有基礎(chǔ)知識(shí)、Java集合、JVM、多線程并發(fā)、spring原理、微服務(wù)、Netty 與RPC 、Kafka、日記、設(shè)計(jì)模式、Java算法、數(shù)據(jù)庫(kù)、Zookeeper、分布式緩存、數(shù)據(jù)結(jié)構(gòu)等等。
