Java Nio 十三、Java NIO Pipe（管道）

最后更新时间：2014-06-23

一个Java NIO管道是在两个线程之间的单向的数据连接。一个管道有一个源通道和一个下沉通道。你写数据到一个下沉的通道。这个数据然后从源通道中读取。

这里有一个管道原则的示意图：



创建一个管道

你可以通过调用Pipe.open()方法打开一个管道，像下面这样：

Pipe pipe = Pipe.open();

写入一个管道

为了写入一个管道，你需要访问这个下沉的通道，像下面这样：

Pipe.SinkChannel sinkChannel = pipe.sink();

通过调用write()方法写入一个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);
}

从一个管道中读

为了从一个管道中读取数据，你需要访问这个源通道，像下面这样：

Pipe.SourceChannel sourceChannel = pipe.source();

为了从源通道中读取数据，你可以调用read()方法，像下面这样：

ByteBuffer buf = ByteBuffer.allocate(48);

int bytesRead = inChannel.read(buf);

通过read方法返回的int值会告诉你有多少字节读到了buffer中。

翻译地址：http://tutorials.jenkov.com/java-nio/pipe.html