Java NIO Pipe

spacewander 發(fā)布于2019-08-16 13:26 / 3243人閱讀

摘要：管道是個線程之間的單向數(shù)據(jù)連接。數(shù)據(jù)會被寫到通道，從通道讀取。這里是原理的圖示創(chuàng)建管道通過方法打開管道。

Java NIO 管道是2個線程之間的單向數(shù)據(jù)連接。Pipe有一個source通道和一個sink通道。數(shù)據(jù)會被寫到sink通道，從source通道讀取。

這里是Pipe原理的圖示：

創(chuàng)建管道
通過Pipe.open()方法打開管道。例如：

Pipe pipe = Pipe.open();

向管道寫數(shù)據(jù)
要向管道寫數(shù)據(jù)，需要訪問sink通道。像這樣：

Pipe.SinkChannel sinkChannel = pipe.sink();

通過調(diào)用SinkChannel的write()方法，將數(shù)據(jù)寫入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ù)，需要訪問source通道，像這樣：

Pipe.SourceChannel sourceChannel = pipe.source();

調(diào)用source通道的read()方法來讀取數(shù)據(jù)，像這樣：

ByteBuffer buf = ByteBuffer.allocate(48);

int bytesRead = sourceChannel.read(buf);

read()方法返回的int值會告訴我們多少字節(jié)被讀進(jìn)了緩沖區(qū)。

文章版權(quán)歸作者所有，未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請注明本文地址：http://m.hztianpu.com/yun/71732.html

相關(guān)文章

【J2SE】java NIO 基礎(chǔ)學(xué)習(xí)

摘要：標(biāo)記，表示記錄當(dāng)前的位置。直接緩沖通過方法分配的緩沖區(qū)，此緩沖區(qū)建立在物理內(nèi)存中。直接在兩個空間中開辟內(nèi)存空間，創(chuàng)建映射文件，去除了在內(nèi)核地址空間和用戶地址空間中的操作，使得直接通過物理內(nèi)存?zhèn)鬏敂?shù)據(jù)。 NIO與IO的區(qū)別 IO NIO 阻塞式非阻塞式、選擇器selectors 面向流：單向流動，直接將數(shù)據(jù)從一方流向另一方面向緩存：將數(shù)據(jù)放到緩存區(qū)中進(jìn)行存取，經(jīng)通道進(jìn)行...

yexiaobai 2019-08-16 15:49 評論0 收藏0
Java線程間通信與信號量

摘要：一般用于控制并發(fā)線程數(shù)，及線程間互斥。單個信號量的對象可以實現(xiàn)互斥鎖的功能，并且可以是由一個線程獲得了鎖，再由另一個線程釋放鎖，這可應(yīng)用于死鎖恢復(fù)的一些場合。 1. 信號量Semaphore 先說說Semaphore，Semaphore可以控制某個資源可被同時訪問的個數(shù)，通過 acquire() 獲取一個許可，如果沒有就等待，而 release() 釋放一個許可。一般用于控制并發(fā)線程數(shù)...

曹金海 2019-08-16 10:55 評論0 收藏0
高級Java程序員必備：《IDEA問題庫》常見問題及解決方案，提升開發(fā)效率4（JAVA 小虛竹）

??作者簡介：大家好,我是小虛竹。Java領(lǐng)域優(yōu)質(zhì)創(chuàng)作者?，CSDN博客專家認(rèn)證?，華為云享專家認(rèn)證? ??技術(shù)活，該賞 ??點贊 ? 收藏 ?再看，養(yǎng)成習(xí)慣 Intellij IDEA使用教程相關(guān)系列目錄問題：報錯unable to establish loopback connection 問題 Caused by: java.io.IOException: Unable to es...

Tecode 2021-11-22 09:34 評論0 收藏0
壓縮20M文件從30秒到1秒的優(yōu)化過程

摘要：壓縮文件從秒到秒的優(yōu)化過程有一個需求需要將前端傳過來的張照片，然后后端進(jìn)行處理以后壓縮成一個壓縮包通過網(wǎng)絡(luò)流傳輸出去。源碼如下使用映射文件開始時間內(nèi)存中的映射文件打印如下可以看到速度和使用的速度差不多的。壓縮20M文件從30秒到1秒的優(yōu)化過程有一個需求需要將前端傳過來的10張照片，然后后端進(jìn)行處理以后壓縮成一個壓縮包通過網(wǎng)絡(luò)流傳輸出去。之前沒有接觸過用Java壓縮文件的，所以就直接...

niuxiaowei111 2019-08-19 10:33 評論0 收藏0
Java NIO 系列教程

摘要：異步可以讓你異步的使用，例如當(dāng)線程從通道讀取數(shù)據(jù)到緩沖區(qū)時，線程還是可以進(jìn)行其他事情。當(dāng)數(shù)據(jù)被寫入到緩沖區(qū)時，線程可以繼續(xù)處理它。因此，單個的線程可以監(jiān)聽多個數(shù)據(jù)通道。下面是系列文章的目錄概述通道之間的數(shù)據(jù)傳輸與原文譯者郭蕾校對方騰飛 Java NIO(New IO)是一個可以替代標(biāo)準(zhǔn)Java IO API的IO API（從Java 1.4開始)，Java NIO提供了與標(biāo)準(zhǔn)IO不同的...

fanux 2019-08-14 11:38 評論0 收藏0