Java NIO 管道是2個(gè)線程之間的單向數(shù)據(jù)連接。Pipe有一個(gè)source通道和一個(gè)sink通道。數(shù)據(jù)會(huì)被寫(xiě)到sink通道,從source通道讀取。
這里是Pipe原理的圖示:
創(chuàng)建管道
通過(guò)Pipe.open()方法打開(kāi)管道。例如:
向管道寫(xiě)數(shù)據(jù)
要向管道寫(xiě)數(shù)據(jù),需要訪問(wèn)sink通道。像這樣:
通過(guò)調(diào)用SinkChannel的write()方法,將數(shù)據(jù)寫(xiě)入SinkChannel,像這樣:
從管道讀取數(shù)據(jù)
從讀取管道的數(shù)據(jù),需要訪問(wèn)source通道,像這樣:
調(diào)用source通道的read()方法來(lái)讀取數(shù)據(jù),像這樣:
read()方法返回的int值會(huì)告訴我們多少字節(jié)被讀進(jìn)了緩沖區(qū)。
這里是Pipe原理的圖示:

創(chuàng)建管道
通過(guò)Pipe.open()方法打開(kāi)管道。例如:
Pipe pipe = Pipe.open();
向管道寫(xiě)數(shù)據(jù)
要向管道寫(xiě)數(shù)據(jù),需要訪問(wèn)sink通道。像這樣:
Pipe.SinkChannel sinkChannel = pipe.sink();
通過(guò)調(diào)用SinkChannel的write()方法,將數(shù)據(jù)寫(xiě)入SinkChannel,像這樣:
String newData = "New String to write to file..." + System.currentTimeMillis(); ByteBuffer buf = ByteBuffer.allocate(48); buf.clear(); buf.put(newData.getBytes()); buf.flip(); while(buf.hasRemaining()) { sinkChannel.write(buf); }
從管道讀取數(shù)據(jù)
從讀取管道的數(shù)據(jù),需要訪問(wèn)source通道,像這樣:
Pipe.SourceChannel sourceChannel = pipe.source();
調(diào)用source通道的read()方法來(lái)讀取數(shù)據(jù),像這樣:
ByteBuffer buf = ByteBuffer.allocate(48); int bytesRead = inChannel.read(buf);
read()方法返回的int值會(huì)告訴我們多少字節(jié)被讀進(jìn)了緩沖區(qū)。
更多文章、技術(shù)交流、商務(wù)合作、聯(lián)系博主
微信掃碼或搜索:z360901061

微信掃一掃加我為好友
QQ號(hào)聯(lián)系: 360901061
您的支持是博主寫(xiě)作最大的動(dòng)力,如果您喜歡我的文章,感覺(jué)我的文章對(duì)您有幫助,請(qǐng)用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧,狠狠點(diǎn)擊下面給點(diǎn)支持吧,站長(zhǎng)非常感激您!手機(jī)微信長(zhǎng)按不能支付解決辦法:請(qǐng)將微信支付二維碼保存到相冊(cè),切換到微信,然后點(diǎn)擊微信右上角掃一掃功能,選擇支付二維碼完成支付。
【本文對(duì)您有幫助就好】元
