Java NIO的Pipe是专为两个线程间单向、低开销数据传输设计的机制，基于共享环形缓冲区实现零拷贝、无锁传递，仅支持SinkChannel写入和SourceChannel读取，必须非阻塞使用且不可双向通信。
Java NIO 的 Pipe 是专为**两个线程间单向、低开销数据传输**设计的机制，不支持双向通信，也不适合替代队列或复杂消息系统。它本质是轻量级内核管道封装，依赖环形缓冲区实现零拷贝、无锁传递。
Pipe 的基本结构和工作方式
Pipe.open() 会一次性创建一对绑定通道：
-
SinkChannel：只写端，是唯一数据入口；调用
write()后数据直接进入内核缓冲区 -
SourceChannel：只读端，是唯一数据出口；调用
read()从同一缓冲区取数据 - 两端共享一个固定大小（OpenJDK 默认约 8 KiB）的内核环形缓冲区，不经过 JVM 堆内存中转
- 任意一端关闭（
close()），整条管道即失效，另一端后续 I/O 操作将抛ClosedChannelException
必须配置为非阻塞才能真正高效
默认阻塞模式下，缓冲区满时写线程挂起、为空时读线程挂起，完全丧失“线程间快速协作”的意义。实际使用务必：
Java 接口排错助手
下载
在调试 Java 后端 API 故障时使用此技能，尤其适用于以下任务：分析日志、跨 Controller、Service 和 Mapper 层追踪请求、定位异常根因、检查 SQL 执行或参数流转，以及生成简洁的诊断结论与修复方案。
- 写线程：调用
sinkChannel.configureBlocking(false)，然后循环检查write(buf)返回值；返回 0 表示暂不可写（缓冲区满），需稍后重试 - 读线程：调用
sourceChannel.configureBlocking(false)，再注册到Selector监听OP_READ；就绪后调用read(buf)，注意返回 -1（管道已关）、0（暂无数据） - 每次
write()前确保buf.flip()，每次read()后及时buf.flip()再clear()，避免 position/limit 错位导致丢数
典型单向传输代码结构
两个线程分工明确，无需额外同步：
立即学习“Java免费学习笔记（深入）”；
- 生产者线程：获取
pipe.sink()→ 非阻塞写入 ByteBuffer → 写完可关闭 sink（若不再发） - 消费者线程：获取
pipe.source()→ 注册到 Selector → 收到 OP_READ 后读取 → 处理数据 → 可关闭 source - 注意：不要在写线程里 close sink 后还尝试 write；也不要让读线程在 source 关闭后继续监听
- 如需优雅退出，建议约定终止信号（例如发送长度为 0 的 buffer 或特定字节序列），而非依赖异常流控
为什么不能直接用于双向通信
Pipe 从设计上就是单工的：
- 没有读写复用能力，
SourceChannel不允许 write，SinkChannel不允许 read - 内部环形缓冲区只支持单向推进（尾进头出），无法反向流动
- 试图并发读写同一 Pipe 会导致未定义行为或阻塞异常
- 若真需双向，应组合两个 Pipe（A→B + B→A），或改用
Exchanger<byte></byte>、TransferQueue<bytebuffer></bytebuffer>等更合适机制
