本文介绍如何利用 Go 标准库 os/exec 模拟 Bash 管道（如 ls | wc），通过连接前一个命令的 stdout 与后一个命令的 stdin，实现流式数据传递，避免中间文件或内存缓冲。
本文介绍如何利用 Go 标准库 `os/exec` 模拟 Bash 管道（如 `ls | wc`），通过连接前一个命令的 stdout 与后一个命令的 stdin，实现流式数据传递，避免中间文件或内存缓冲。
在 Go 中模拟 Unix shell 管道（|）的关键在于复用标准 I/O 流：将第一个进程的标准输出（stdout）直接作为第二个进程的标准输入（stdin）。这不仅高效（零拷贝、流式处理），还能处理任意大小的输出（不受内存限制）。
基本实现步骤
- 创建第一个命令（如 ls），调用 StdoutPipe() 获取可读的 io.ReadCloser；
- 启动第一个命令（必须调用 Start()，不能仅用 Run()，否则会阻塞）；
- 创建第二个命令（如 wc），将其 Stdin 字段显式设置为上一步的 stdout 管道；
- 调用 wc.Output()（或 wc.Run() + 手动读取）完成执行并获取结果。
以下是完整可运行示例：
package main
import (
"fmt"
"os/exec"
)
func main() {
// 构建第一个命令：ls
ls := exec.Command("ls")
// 获取 ls 的 stdout 管道（未启动时即可调用）
lsOut, err := ls.StdoutPipe()
if err != nil {
panic(err)
}
// 启动 ls —— 关键！不调用 Start() 则 StdoutPipe() 不会生效
if err := ls.Start(); err != nil {
panic(err)
}
// 构建第二个命令：wc，并将其 stdin 指向 ls 的 stdout
wc := exec.Command("wc")
wc.Stdin = lsOut
// 执行 wc 并捕获输出（会自动等待 ls 结束）
output, err := wc.Output()
if err != nil {
panic(err)
}
fmt.Print(string(output))
}⚠️ 注意事项与最佳实践
- 必须调用 Start()：StdoutPipe() 返回的管道仅在进程启动后才开始写入。若误用 Run()，会导致死锁（Run() 内部会等待进程结束，但 wc 因无输入而永远阻塞，进而 ls 也无法退出）。
- 错误处理不可省略：真实项目中应检查每个 exec.Command 的创建、Start() 和 Output() 错误，尤其注意子进程退出非零状态时 exec.ExitError 的处理。
- 避免竞态与资源泄漏：StdoutPipe() 返回的 io.ReadCloser 需在使用后关闭（虽然 Output() 会自动关闭，但手动管理时需注意）。若使用 wc.Run() 配合 io.Copy，请确保显式关闭 lsOut。
- 跨平台兼容性：示例中 ls 和 wc 仅适用于 Unix-like 系统。Windows 下可替换为 dir 和自定义统计程序，或使用 golang.org/x/sys/execabs 提升路径解析鲁棒性。
- 扩展多级管道：可通过链式方式构建 cmd1 | cmd2 | cmd3：cmd2.Stdin = cmd1.StdoutPipe()，cmd3.Stdin = cmd2.StdoutPipe()，依此类推。
总结
Go 的 os/exec 虽无内置 Pipe() 方法，但通过 StdoutPipe() + Stdin 字段赋值，即可安全、高效地实现类 shell 管道。其本质是利用操作系统级 pipe 文件描述符，在父子进程间建立单向字节流。掌握这一模式，是编写高性能命令行工具、CI/CD 执行器或容器化工作流引擎的重要基础。
