io.Pipe是Go中用于goroutine间同步数据传输的管道，实现io.Reader和io.Writer接口，支持单向通信、阻塞读写及错误传递，常用于内存流处理。
在 Go 语言中，io.Pipe 是一种用于在 goroutine 之间进行同步数据传输的管道机制。它实现了 io.Reader 和 io.Writer 接口，适合在并发场景下实现一个协程写入、另一个协程读取的数据流控制。与操作系统级别的管道不同，io.Pipe 完全由 Go 运行时管理，常用于内存中的数据传递，比如处理 HTTP 响应、压缩流、日志转发等场景。
io.Pipe 基本原理
io.Pipe 返回一对关联的 *io.PipeReader 和 *io.PipeWriter。写入 PipeWriter 的数据可以从 PipeReader 中读取。它的核心特点是：
- 同步阻塞：读写操作是同步的，写入方在没有读取方消费时会阻塞。
- 单向通信：PipeReader 只能读，PipeWriter 只能写。
- 非线程安全：多个 goroutine 同时写或读同一个端点需自行加锁或通过 channel 协调。
- 支持关闭：关闭读端或写端可通知对方结束操作。
创建方式非常简单：
r, w := io.Pipe()// r 是 *io.PipeReader，实现 io.Reader
// w 是 *io.PipeWriter，实现 io.Writer
基本读写示例
下面是一个简单的例子，演示如何在一个 goroutine 中写入数据，在另一个中读取：
立即学习“go语言免费学习笔记（深入）”；
package mainimport (
"fmt"
"io"
"log"
)
func main() {
r, w := io.Pipe()
go func() {
defer w.Close()
_, err := w.Write([]byte("hello from writer"))
if err != nil {
log.Fatal(err)
}
}()
buf := make([]byte, 100)
n, err := r.Read(buf)
if err != nil {
log.Fatal(err)
}
fmt.Printf("read: %s\n", buf[:n])
r.Close()
}
运行结果输出：
read: hello from writer
注意：必须在写入完成后调用 w.Close()，否则读取方在数据读完后会一直等待更多数据。如果写入失败或提前中断，也应使用 w.CloseWithError(err) 通知读取方错误原因。
结合 bufio.Scanner 实现行读取
实际开发中，我们常需要逐行处理数据流。可以将 io.Pipe 与 bufio.Scanner 结合使用：
r, w := io.Pipe()scanner := bufio.NewScanner(r)
go func() {
defer w.Close()
w.Write([]byte("line 1\n"))
w.Write([]byte("line 2\n"))
w.Write([]byte("line 3\n"))
}()
for scanner.Scan() {
fmt.Println("got:", scanner.Text())
}
if err := scanner.Err(); err != nil {
log.Fatal(err)
}
这种方式非常适合模拟日志输出、命令行输出捕获等场景。
错误处理与资源释放
使用 io.Pipe 时，良好的错误处理至关重要。推荐使用 CloseWithError 显式传递错误信息，避免读取方无限等待：
go func() {_, err := w.Write(someData)
if err != nil {
w.CloseWithError(fmt.Errorf("write failed: %v", err))
return
}
w.Close()
}()
读取方接收到错误后会终止读取：
_, err := r.Read(buf)if err != nil {
// 可能是 EOF，也可能是 CloseWithError 传入的错误
fmt.Println("read error:", err)
}
务必确保两端都关闭，防止资源泄漏。
基本上就这些。io.Pipe 虽然简单，但在流式数据处理中非常实用，关键是理解其同步特性和生命周期管理。
