前言
-
JDK 1.4
后躏尉,Java
提供了一個全新的IO API
偎血,即Java New IO
- 本文 全面 & 詳細解析
Java New IO
鹦筹,希望你們會喜歡
目錄
儲備知識:Java IO
1. 定義
- 即
Java New IO
- 是1個全新的佛呻、
JDK 1.4
后提供的IO API
2. 作用
- 提供了與標準
IO
不同的IO
工作方式 - 可替代 標準
Java IO
的IO API
3. 新特性
對比于 Java IO
,NIO
具備的新特性如下
4. 核心組件
Java NIO
的核心組件 包括:
- 通道(
Channel
) - 緩沖區(qū)(
Buffer
) - 選擇器(
Selectors
)
下面將詳細介紹:
5. 具體使用
5.1 基于通道 & 緩沖數(shù)據(jù)
具體步驟如下:
// 1. 獲取數(shù)據(jù)源 和 目標傳輸?shù)氐妮斎胼敵隽鳎ù颂幰詳?shù)據(jù)源 = 文件為例)
FileInputStream fin = new FileInputStream(infile);
FileOutputStream fout = new FileOutputStream(outfile);
// 2. 獲取數(shù)據(jù)源的輸入輸出通道
FileChannel fcin = fin.getChannel();
FileChannel fcout = fout.getChannel();
// 3. 創(chuàng)建 緩沖區(qū) 對象:Buffer(共有2種方法)
// 方法1:使用allocate()靜態(tài)方法
ByteBuffer buff = ByteBuffer.allocate(256);
// 上述方法創(chuàng)建1個容量為256字節(jié)的ByteBuffer
// 注:若發(fā)現(xiàn)創(chuàng)建的緩沖區(qū)容量太小凌盯,則重新創(chuàng)建一個大小合適的緩沖區(qū)
// 方法2:通過包裝一個已有的數(shù)組來創(chuàng)建
// 注:通過包裝的方法創(chuàng)建的緩沖區(qū)保留了被包裝數(shù)組內(nèi)保存的數(shù)據(jù)
ByteBuffer buff = ByteBuffer.wrap(byteArray);
// 額外:若需將1個字符串存入ByteBuffer奶陈,則如下
String sendString="你好,服務器. ";
ByteBuffer sendBuff = ByteBuffer.wrap(sendString.getBytes("UTF-16"));
// 4. 從通道讀取數(shù)據(jù) & 寫入到緩沖區(qū)
// 注:若 以讀取到該通道數(shù)據(jù)的末尾抱完,則返回-1
fcin.read(buff);
// 5. 傳出數(shù)據(jù)準備:將緩存區(qū)的寫模式 轉(zhuǎn)換->> 讀模式
buff.flip();
// 6. 從 Buffer 中讀取數(shù)據(jù) & 傳出數(shù)據(jù)到通道
fcout.write(buff);
// 7. 重置緩沖區(qū)
// 目的:重用現(xiàn)在的緩沖區(qū),即 不必為了每次讀寫都創(chuàng)建新的緩沖區(qū)抛猫,在再次讀取之前要重置緩沖區(qū)
// 注:不會改變緩沖區(qū)的數(shù)據(jù)蟆盹,只是重置緩沖區(qū)的主要索引值
buff.clear();
5.2 基于選擇器(Selecter)
具體步驟如下:
// 1. 創(chuàng)建Selector對象
Selector sel = Selector.open();
// 2. 向Selector對象綁定通道
// a. 創(chuàng)建可選擇通道,并配置為非阻塞模式
ServerSocketChannel server = ServerSocketChannel.open();
server.configureBlocking(false);
// b. 綁定通道到指定端口
ServerSocket socket = server.socket();
InetSocketAddress address = new InetSocketAddress(port);
socket.bind(address);
// c. 向Selector中注冊感興趣的事件
server.register(sel, SelectionKey.OP_ACCEPT);
return sel;
// 3. 處理事件
try {
while(true) {
// 該調(diào)用會阻塞闺金,直到至少有一個事件就緒逾滥、準備發(fā)生
selector.select();
// 一旦上述方法返回,線程就可以處理這些事件
Set<SelectionKey> keys = selector.selectedKeys();
Iterator<SelectionKey> iter = keys.iterator();
while (iter.hasNext()) {
SelectionKey key = (SelectionKey) iter.next();
iter.remove();
process(key);
}
}
} catch (IOException e) {
e.printStackTrace();
}
6. 實例講解
- 實例說明:實現(xiàn)文件復制功能
- 實現(xiàn)方式:通道
FileChannel
败匹、 緩沖區(qū)ByteBuffer
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.nio.ByteBuffer;
import java.nio.channels.FileChannel;
public class Test {
public static void main(String[] args) throws IOException {
// 設置輸入源 & 輸出地 = 文件
String infile = "C:\\copy.sql";
String outfile = "C:\\copy.txt";
// 1. 獲取數(shù)據(jù)源 和 目標傳輸?shù)氐妮斎胼敵隽鳎ù颂幰詳?shù)據(jù)源 = 文件為例)
FileInputStream fin = new FileInputStream(infile);
FileOutputStream fout = new FileOutputStream(outfile);
// 2. 獲取數(shù)據(jù)源的輸入輸出通道
FileChannel fcin = fin.getChannel();
FileChannel fcout = fout.getChannel();
// 3. 創(chuàng)建緩沖區(qū)對象
ByteBuffer buff = ByteBuffer.allocate(1024);
while (true) {
// 4. 從通道讀取數(shù)據(jù) & 寫入到緩沖區(qū)
// 注:若 以讀取到該通道數(shù)據(jù)的末尾寨昙,則返回-1
int r = fcin.read(buff);
if (r == -1) {
break;
}
// 5. 傳出數(shù)據(jù)準備:調(diào)用flip()方法
buff.flip();
// 6. 從 Buffer 中讀取數(shù)據(jù) & 傳出數(shù)據(jù)到通道
fcout.write(buff);
// 7. 重置緩沖區(qū)
buff.clear();
}
}
}
7. 與Java IO的區(qū)別
8. 總結(jié)
本文全面講解了Java
中的NIO
的相關知識。
歡迎關注Carson_Ho的簡書掀亩!
分享Android技術干貨舔哪,追求短、平槽棍、快捉蚤,但卻不缺深度。
請點贊炼七!因為你的鼓勵是我寫作的最大動力缆巧!
相關文章閱讀
Android開發(fā):最全面、最易懂的Android屏幕適配解決方案
Android事件分發(fā)機制詳解:史上最全面豌拙、最易懂
Android開發(fā):史上最全的Android消息推送解決方案
Android開發(fā):最全面陕悬、最易懂的Webview詳解
Android開發(fā):JSON簡介及最全面解析方法!
Android四大組件:Service服務史上最全面解析
Android四大組件:BroadcastReceiver史上最全面解析