您的位置:首页 > 编程语言 > Java开发

Java NIO系列教程(八) Pipe

2017-03-27 09:56 183 查看
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
);
03
buf.clear();
04
buf.put(newData.getBytes());
05
 
06
buf.flip();
07
 
08
while
(buf.hasRemaining())
{
09
    
sinkChannel.write(buf);
10
}

从管道读取数据

从读取管道的数据,需要访问source通道,像这样:

1
Pipe.SourceChannel
sourceChannel = pipe.source();
调用source通道的
read()
方法来读取数据,像这样:

1
ByteBuffer
buf = ByteBuffer.allocate(
48
);
2
 
3
int
 
bytesRead
= sourceChannel.read(buf);
read()
方法返回的int值会告诉我们多少字节被读进了缓冲区。
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: