Java NIO的Pipe是同一进程内线程间单向通信的轻量级通道，由SinkChannel（写入端）和SourceChannel（读取端）组成，阻塞模式下天然线程安全，适用于生产者-消费者模型，需显式关闭通道以释放资源。

Java NIO 的 Pipe 是专为**同一进程内线程间单向通信**设计的轻量级通道，不涉及操作系统管道，完全在 JVM 内存中完成数据传递。它由一对关联的 Pipe.SinkChannel（写入端）和 Pipe.SourceChannel（读取端）组成，天然线程安全，适合生产者-消费者模型。

创建 Pipe 并获取两端通道

调用 Pipe.open() 创建管道实例，随后分别获取写入端和读取端：

• Pipe pipe = Pipe.open();
• Pipe.SinkChannel sink = pipe.sink(); —— 生产者线程写入数据
• Pipe.SourceChannel source = pipe.source(); —— 消费者线程读取数据

注意：两个通道默认处于阻塞模式，无需额外配置；若需非阻塞，可调用 sink.configureBlocking(false)，但需配合 Selector 使用，对简单线程通信反而增加复杂度，一般保持阻塞即可。

生产者线程：通过 SinkChannel 写入数据

使用 ByteBuffer 向 sink 写入字节数据，必须确保 buffer 处于“写模式”（即 clear() 或 flip() 后已重置）：

立即学习“Java免费学习笔记（深入）”；

deep-java-review

Java项目代码review工具。分析Git变更+完整调用链路上下文，推断业务需求，进行多维度评分和分类汇总，生成完整PRD文档。包含细粒度Java代码审查清单（Null安全、异常处理、Streams、并发、equals/hashCode、资源管理、API设计、性能、MyBatis/ORM、事务边界、SQL/DD...

下载

• 准备数据：buffer.put("hello".getBytes()); buffer.flip();
• 写入：sink.write(buffer);
• 每次写入后建议检查返回值（实际写入字节数），若为 0 表示缓冲区满（Pipe 内部有固定容量，默认约 1MB），需等待消费者读取腾出空间

写入完成后无需关闭 sink，否则管道中断；正常流程中只需保证数据写完即可。

消费者线程：通过 SourceChannel 读取数据

从 source 读取数据时，ByteBuffer 需处于“读模式”（即 flip() 后 position ≤ limit）：

• 分配缓冲区：ByteBuffer buffer = ByteBuffer.allocate(1024);
• 读取：int bytesRead = source.read(buffer);
• 若 bytesRead > 0，调用 buffer.flip() 然后提取数据；若为 -1 表示写入端已关闭；若为 0 表示当前无数据可读（阻塞模式下不会返回 0）

读取端通常在一个循环中持续调用 read()，直到明确结束信号（如收到特定终止消息或写入端关闭）。

关闭与资源释放

Pipe 不占用文件描述符，但通道仍需显式关闭以释放内部资源：

• 写入端关闭：sink.close(); → 会触发读取端后续 read() 返回 -1
• 读取端关闭：source.close(); → 不影响写入，但再读将抛 ClosedChannelException
• 推荐由生产者线程在写完所有数据后关闭 sink，消费者检测到 -1 即退出循环并关闭 source

不关闭也不会导致严重泄漏，但属于良好实践。