Go os.Pipe怎样把一个进程的输出接到另一个进程怎样在批处理代码中减少额外分配

要把一个进程的输出直接交给另一个进程，核心就是先调用 os.Pipe() 得到读端和写端，再把写端交给生产进程的 Stdout，把读端交给消费进程的 Stdin。这样数据沿着操作系统管道流动，不必先把全部输出拼成字符串或放进一个不断增长的 bytes.Buffer。

官方资料：https://pkg.go.dev/os

性能重点不是盲目追求“零分配”，而是让两个进程直接共享一条数据通路，并把父进程保留的管道句柄及时关闭，避免 EOF 和等待顺序被拖住。

先看清 os.Pipe 的读写关系

os.Pipe() 返回 r 和 w 两个文件对象：写入 w 的字节会从 r 读出。对进程管线来说，生产进程只需要持有写端，消费进程只需要持有读端。父进程不负责搬运每一块数据，也就不需要额外创建中间切片来接住完整输出。

把两个 exec.Cmd 接成一条管线

下面用一个生产命令输出两行文本，再用消费命令转成大写。示例只展示连接关系，重点是启动消费进程后再启动生产进程，并让两个 Cmd 都直接使用管道文件对象。

package main

import (
	"fmt"
	"os"
	"os/exec"
)

func main() {
	// r 和 w 是同一条操作系统管道的读端与写端。
	r, w, err := os.Pipe()
	if err != nil {
		panic(err)
	}
	defer r.Close()

	producer := exec.Command("printf", "alpha\\nbeta\\n")
	consumer := exec.Command("tr", "a-z", "A-Z")
	producer.Stdout = w // 生产进程的输出直接写入管道。
	consumer.Stdin = r  // 消费进程从同一条管道读取。
	consumer.Stdout = os.Stdout
	consumer.Stderr = os.Stderr

	if err := consumer.Start(); err != nil {
		panic(err)
	}
	if err := producer.Start(); err != nil {
		panic(err)
	}
	// 父进程不再写入，关闭自己的副本，便于消费进程最终看到 EOF。
	if err := w.Close(); err != nil {
		panic(err)
	}
	if err := producer.Wait(); err != nil {
		panic(fmt.Errorf("producer: %w", err))
	}
	if err := consumer.Wait(); err != nil {
		panic(fmt.Errorf("consumer: %w", err))
	}
}

这里没有把生产进程的输出读进 Go 的 []byte，也没有再把它转换成字符串，所以连续处理大批量数据时少了一层完整结果的内存占用。示例中的 printf 和 tr 是演示用外部命令；实际项目应根据运行平台替换，并检查命令路径与退出错误。

关闭和 Wait 的顺序决定是否会卡住

最容易遗漏的是父进程仍然持有 w。即使生产进程已经结束，只要还有写端打开，消费进程就可能一直等不到 EOF。因此生产进程成功 Start 后，父进程应关闭自己的写端；子进程继承的写端仍会在生产进程结束时关闭。

另一方面，Start 成功后必须调用 Wait。先等待生产进程、再等待消费进程适合这个短管线；如果消费进程可能提前退出，生产进程写满管道后可能收到写错误，此时要保留两个进程各自的错误，而不是只看最后一个 Wait。如果使用 Cmd.StdoutPipe 读取单个子进程输出，也不要在读完之前调用 Wait。

按数据规模选择更少分配的写法

当目标只是把一个进程的流交给另一个进程，直接绑定 Stdout 和 Stdin 最省事，也避免在 Go 进程里保存完整中间结果。如果 Go 代码必须检查、改写或分流每一块内容，再使用 io.Copy 或自定义 Reader/Writer；这时用户态搬运是业务需求，不应为了追求数字而删除。

常见问题

os.Pipe 是 Go channel 的替代品吗？

不是。它返回文件对象，主要用于文件描述符和进程标准流之间的连接；Go 内部协程通信仍应根据语义选择 channel 或其他同步方式。

为什么消费进程一直没有结束？

优先检查父进程是否关闭了自己的写端，以及是否还有其他写端副本存活。只要写端未全部关闭，消费进程就可能继续等待 EOF。

一句话总结：用 os.Pipe 连接两个 exec.Cmd 时，让操作系统负责流转，让父进程负责清理句柄和等待进程；只有确实需要改写或保留数据时，才增加 Go 层缓冲。