Java-NIO:管道 (Pipe)

Posted yy

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Java-NIO:管道 (Pipe)相关的知识,希望对你有一定的参考价值。

Java NIO 管道是2个线程之间的单向数据连接。Pipe有一个source通道和一个sink通道。数据会被写到sink通道,从source通道读取。


代码使用示例:

 1 @Test
 2     public void testPipe() throws IOException {
 3         // 1、获取通道
 4         Pipe pipe = Pipe.open();
 5 
 6         // 2、获取sink管道,用来传送数据
 7         Pipe.SinkChannel sinkChannel = pipe.sink();
 8 
 9         // 3、申请一定大小的缓冲区
10         ByteBuffer byteBuffer = ByteBuffer.allocate(1024);
11         byteBuffer.put("123232142345234".getBytes());
12         byteBuffer.flip();
13 
14         // 4、sink发送数据
15         sinkChannel.write(byteBuffer);
16 
17         // 5、创建接收pipe数据的source管道
18         Pipe.SourceChannel sourceChannel = pipe.source();
19         // 6、接收数据,并保存到缓冲区中
20         ByteBuffer byteBuffer2 = ByteBuffer.allocate(1024);
21         byteBuffer2.flip();
22         int length = sourceChannel.read(byteBuffer2);
23 
24         System.out.println(new String(byteBuffer2.array(), 0, length));
25 
26         sourceChannel.close();
27         sinkChannel.close();
28 
29     }

 

以上是关于Java-NIO:管道 (Pipe)的主要内容,如果未能解决你的问题,请参考以下文章

NIO之管道 (Pipe)

简述Linux进程间通信之管道pipe(下)

妙不可言,使用 Python 管道 Pipe 编写代码如此优雅

Python 开发神技 -- 使用管道 Pipe

java nio管道

命名管道:ConnectNamedPipe 后的 ReadFile 返回 ERROR_BROKEN_PIPE