Java管道流实现线程间通信须选对流、连对路、关到位：字节流（PipedInputStream/OutputStream）适用于二进制数据，字符流（PipedReader/Writer）专为文本设计并自动处理编码；必须配对连接且不可混用，写端close后读端read返回-1标识结束，同线程读写或未connect即启动线程将导致死锁或异常。
Java 中用管道流实现线程间通信，关键不是“能不能用”，而是“选对流、连对路、关到位”。字节流和字符流底层机制不同，适用场景明确，混用会直接抛异常，不能凑合。
字节流：PipedInputStream + PipedOutputStream
适合传输二进制数据，比如序列化对象、图片字节数组、协议原始报文等。它不关心内容含义，只管按字节搬运。
- 必须配对使用：PipedOutputStream 只能 connect PipedInputStream，反向也成立；写端调 output.connect(input) 或读端调 input.connect(output) 都可以，但只能调一次
- 写入时推荐用 write(byte[], int, int) 批量写，避免单字节 write 带来频繁锁竞争
- 读取要循环调用 read(byte[])，直到返回 -1（说明写端已 close）；只读一次容易漏数据
- 写端调用 close() 后，读端下一次 read() 就会返回 -1，这是通知结束的唯一标准方式
字符流：PipedReader + PipedWriter
专为文本设计，自动处理字符编码，省去 getBytes()/new String() 的转换步骤，中文等 Unicode 支持自然，不易乱码。
- 连接方式相同：writer.connect(reader)，注意方向——writer 是输出端，reader 是输入端
- 写入建议用 write(String) 或 write(char[])，配合 flush() 确保内容及时到达；不 flush 时可能滞留在 writer 内部缓冲区
- 读取优先用 read(char[]) 批量读；逐字符 read() 效率低，不适用于日志、消息体等常规文本
- 支持 readLine()，适合按行分隔的协议（如简单命令、HTTP 头模拟），比手动找 \n 更可靠
绝对不能做的事
这些操作看似小细节，但一做就崩溃或死锁，JDK 明确禁止：
立即学习“Java免费学习笔记（深入）”；
- 在同一个线程里既往 PipedOutputStream 写、又从 PipedInputStream 读——必然死锁
- 先 start 线程、再 connect 流——竞态导致 “Pipe not connected” 异常
- 用 PipedWriter 写 byte[]，或用 PipedInputStream 读 char——类型错配，运行时报 IOException
- 忘记 close：写端不 close，读端永远卡在 read()；读端不 close，资源无法释放，可能内存泄漏
怎么选：看数据本质，不是看习惯
不是“文本就一定用字符流”，得看源头和用途：
- 如果数据来自网络 socket、文件读取、或明确是 UTF-8 编码的 byte[]，且后续要做二进制解析（比如解包协议头），用字节流
- 如果数据是纯字符串拼接、日志语句、配置项、用户输入的中文短消息，用字符流更安全简洁
- 不确定时，优先字符流：PipedReader/PipedWriter 对中文兼容性好，不用操心 StandardCharsets.UTF_8 是否一致
