Go 的 io.Reader 和 io.Writer 是流式处理核心接口，通过 io.Pipe、io.TeeReader、io.MultiReader 和 io.Copy 等组合可构建灵活低内存管道：Pipe 实现 goroutine 间双向流，TeeReader 边读边写（如计算哈希），MultiReader 顺序合并多个 Reader，自定义 Reader/Writer 可扩展能力（如进度回调）。
Go 语言的 io.Reader 和 io.Writer 是流式处理的核心接口，它们不关心数据来源或去向，只专注“读”和“写”的契约。利用它们的组合能力（如 io.Pipe、io.MultiReader、io.TeeReader、io.Copy 等），可以构建灵活、低 内存占用 的数据管道。
用 io.Pipe 构建双向流管道
io.Pipe() 返回一对连接的 io.Reader 和 io.Writer：往 writer 写入的数据可立即被 reader 读出，适合在 goroutine 间传递流式数据，避免内存堆积。
示例：将大文件逐块压缩并写入网络，不全量加载到内存：
pr, pw := io.Pipe() defer pr.Close() <p>// 启动压缩 goroutine：从 pr 读，压缩后写入响应 go func() { defer pw.Close() gz := gzip.NewWriter(pw) _, err := io.Copy(gz, pr) // pr 流入 → gz 压缩 → pw 流出 gz.Close() if err != nil { log.Printf("compress error: %v", err) } }()</p><p>// 主流程：打开文件，拷贝到 pw（即流入管道）file, _ := os.Open("huge.log") defer file.Close() io.Copy(pw, file) // file → pw → pr → gz → ……用 io.TeeReader 实现“边读边记录”管道
io.TeeReader(r, w) 在读取 r 的同时，把读到的数据 ** 原样写入 ** w（如日志文件、hash 计算器、监控计数器）。它不缓冲，不改变原始流行为，适合审计、校验、埋点等场景。
示例：上传文件时实时计算 SHA256 并保存原始内容：
file, _ := os.Open("upload.bin") hasher := sha256.New() tee := io.TeeReader(file, hasher) // 每次 Read 都同步写入 hasher <p>// 将 tee 流复制到目标存储（如磁盘或对象存储）dst, _ := os.Create("saved.bin") n, err := io.Copy(dst, tee)</p><p>fmt.Printf("copied %d bytes, hash: %xn", n, hasher.Sum(nil))用 io.MultiReader 组合多个 Reader 成单一流
io.MultiReader(rs……io.Reader) 把多个 reader 串成一个逻辑 reader，按顺序读完第一个再读第二个……适合拼接 header + body、多段配置、分片合并等。
示例：构造 HTTP 响应体（JSON header + CSV body）：
header := strings.NewReader(`{"count":3,"format":"csv"}n`) body := strings.NewReader("name,agenAlice,30nBob,25n") <p>combined := io.MultiReader(header, body) http.ServeContent(w, r, "data.json", time.Now(), combined)用 io.Copy + 自定义 Reader/Writer 扩展管道能力
只要实现 Read([]byte) (int, error) 或 Write([]byte) (int, error)，就能无缝接入标准管道。例如实现带进度回调的 Writer：
type ProgressWriter struct {w io.Writer total int64 written int64 onWrite func(int64, int64) // callback: current, total } <p>func (pw *ProgressWriter) Write(p []byte) (n int, err error) {n, err = pw.w.Write(p) pw.written += int64(n) pw.onWrite(pw.written, pw.total) return }</p><p>// 使用 pw := &ProgressWriter{w: os.Stdout, total: fileSize} io.Copy(pw, src) // 实时打印进度
