Golangio.Pipe管道读写与数据传递实践-Golang-PHP中文网

Golangio.Pipe管道读写与数据传递实践

P粉602998670

发布： 2025-09-19 20:00:02

原创

796人浏览过

io.Pipe是Go中用于goroutine间同步数据传输的管道，实现io.Reader和io.Writer接口，支持单向通信、阻塞读写及错误传递，常用于内存流处理。

golangio.pipe管道读写与数据传递实践

在 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 main

import (
  "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) 通知读取方错误原因。

Pic Copilot

AI时代的顶级电商设计师，轻松打造爆款产品图片

158

查看详情

结合 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)
}

这种方式非常适合模拟日志输出、命令行输出捕获等场景。