Java NIO管道用于在两个线程之间建立单向数据连接。它有一个槽通道和源通道。数据正在写入槽通道，然后可以从源通道读取该数据。
在Java NIO中，包java.nio.channel.pipe用于按顺序读取和写入数据。管道用于确保数据必须以写入管道的相同顺序读取。
下面来看看管道工作原理的示意图说明：
创建管道
要创建一个管道，可通过调用Pipe.open()方法打开管道。
打开或创建管道的语法是：
Pipe pp = Pipe.open();
从管道读取数据
要从管道读取数据，需要先访问源通道。 因此，用于访问源通道的语法是：
Pipe.SourceChannel sc= pipe.source();
要从SourceChannel读取数据，可调用read()方法，如下所示：
ByteBuffer bb= ByteBuffer.allocate(512);
int bytesRead = inChannel.read(bb);
read()方法返回的整数值用于确定读入缓冲区的字节数。
写入管道
要将数据写入管道，需要访问接收器通道。访问宿通道的语法是：
Pipe.SinkChannel sc= pipe.sink();
要将数据写入SinkChannel，可调用write()方法，如下所示：
String newData = "The new String is writing in a Pipe..." + System.currentTimeMillis();
ByteBuffer bb= ByteBuffer.allocate(512);
bb.clear();
bb.put(newData.getBytes());
bb.flip();
while(bb.hasRemaining()) {
SinkChannel.write(bb);
}
基本管道示例：
package com.yiibai;
import java.io.IOException;
import java.nio.ByteBuffer;
import java.nio.channels.Pipe;
public class PipeExample {
public static void main(String[] args) throws IOException {
// The Pipe is created
Pipe pipe = Pipe.open();
// For accessing the pipe sink channel
Pipe.SinkChannel skChannel = pipe.sink();
String td = "Data is successfully sent for checking the java NIO Channel Pipe.";
ByteBuffer bb = ByteBuffer.allocate(512);
bb.clear();
bb.put(td.getBytes());
bb.flip();
// write the data into a sink channel.
while (bb.hasRemaining()) {
skChannel.write(bb);
}
// For accessing the pipe source channel
Pipe.SourceChannel sourceChannel = pipe.source();
bb = ByteBuffer.allocate(512);
// The data is write to the console
while (sourceChannel.read(bb) > 0) {
bb.flip();
while (bb.hasRemaining()) {
char TestData = (char) bb.get();
System.out.print(TestData);
}
bb.clear();
}
}
}
执行上面示例代码，得到以下结果 -
Data is successfully sent for checking the java NIO Channel Pipe.
