本文讲解如何通过标准库 io.Pipe 实现线程安全、阻塞式读写的自定义 io.ReadWriter，无需手动实现接口；写端调用 Close() 即可自然触发读端返回 io.EOF，从而让 io.Copy 等函数优雅终止。
本文讲解如何通过标准库 `io.pipe` 实现线程安全、阻塞式读写的自定义 `io.readwriter`，无需手动实现接口；写端调用 `close()` 即可自然触发读端返回 `io.eof`，从而让 `io.copy` 等函数优雅终止。
在 Go 中，实现“写入时非阻塞、读取时阻塞等待直至完成”的通信模式，不应从头实现 io.ReadWriter 接口——这不仅复杂易错，还容易陷入同步、缓冲、EOF 语义等细节陷阱。正确的做法是复用标准库中经过充分验证的 io.Pipe。
io.Pipe() 返回一对关联的 *io.PipeReader 和 *io.PipeWriter，它们共享内部管道缓冲区，并通过 goroutine 安全的 channel 机制协调读写。其核心语义非常简洁：
- 写端（*io.PipeWriter）实现了 io.WriteCloser：可写入数据，且 调用 Close() 即表示“写入结束”；
- 读端（*io.PipeReader）实现了 io.Reader：持续 Read() 直至所有已写入数据被消费完毕，随后 自动返回 io.EOF；
- io.Copy(dst, r) 等标准函数正是通过检测 io.EOF 来判断流终止，与 http.Response.Body 的行为完全一致——后者底层也依赖类似机制（如连接关闭或 Content-Length 耗尽后返回 EOF）。
以下是推荐实现方式：
r, w := io.Pipe()
// 启动写协程（非阻塞）
go func() {
defer w.Close() // 关键：关闭写端即标记完成
fmt.Fprint(w, "Line one\n")
fmt.Fprint(w, "Line two\n")
fmt.Fprint(w, "END") // 自定义标记字符串（仅业务语义，非协议必需）
}()
// 主协程阻塞读取，直到 w.Close() 被调用
_, err := io.Copy(dst, r)
if err != nil && err != io.EOF {
log.Fatal("copy failed:", err)
}
// 此处保证所有数据已读完，且 r 已自然终止
⚠️ 注意事项：
- io.PipeWriter.Close() 是唯一且标准的“完成标记”方式，不建议用特殊字符串（如 "END"）作为协议级终止符——这会增加解析逻辑、破坏流式处理的通用性，并可能与真实业务数据冲突；
- 若需双向通信（读+写），可组合两个 io.Pipe，或改用 net.Conn/os.Pipe 等更底层抽象；
- io.Pipe 内部使用互斥锁和条件变量，天然支持多 goroutine 并发读写，无需额外同步；
- http.Response.Body 的 EOF 行为本质相同：当 HTTP 报文体传输完成（如 chunked 结束、长度匹配或连接关闭），底层 reader 就会返回 io.EOF，io.Copy 捕获后立即退出。
总结：面向“生产者-消费者”场景，优先选用 io.Pipe ——它以最小认知成本提供了符合 Go I/O 惯例的阻塞语义、清晰的生命周期控制（Close() = done）以及与整个 io 生态无缝集成的能力。
