506
阿裏雲 技術社區[雲棲]
Java NIO係列教程（十一） Pipe
Java NIO 管道是2個線程之間的單向數據連接。Pipe有一個source通道和一個sink通道。數據會被寫到sink通道，從source通道讀取。
這裏是Pipe原理的圖示：
創建管道
通過Pipe.open()方法打開管道。例如：
1 |
Pipe pipe = Pipe.open(); |
向管道寫數據
要向管道寫數據，需要訪問sink通道。像這樣：
1 |
Pipe.SinkChannel sinkChannel = pipe.sink(); |
通過調用SinkChannel的write()方法，將數據寫入SinkChannel,像這樣：
01 |
String newData = "New String to write to file..." + System.currentTimeMillis();
|
02 |
ByteBuffer buf = ByteBuffer.allocate(48);
|
04 |
buf.put(newData.getBytes()); |
08 |
while(buf.hasRemaining()) {
|
09 |
sinkChannel.write(buf);
|
從管道讀取數據
從讀取管道的數據，需要訪問source通道，像這樣：
1 |
Pipe.SourceChannel sourceChannel = pipe.source(); |
調用source通道的read()方法來讀取數據，像這樣：
1 |
ByteBuffer buf = ByteBuffer.allocate(48);
|
3 |
int bytesRead = sourceChannel.read(buf);
|
read()方法返回的int值會告訴我們多少字節被讀進了緩衝區。
文章轉自 並發編程網-ifeve.com
最後更新：2017-05-22 17:01:38