Go语言命令管道详解（使用os/exec包实现进程间通信）

Go语言中的 os/exec 包

os/exec 是 Go 标准库中用于执行外部命令的核心包。通过它，我们可以启动子进程、读取输出、写入输入，甚至建立多个命令之间的管道连接。

实战：使用 Go 实现命令管道

假设我们要实现和终端命令 echo "hello world" | grep hello 相同的效果：先输出一段文本，再通过 grep 过滤包含 "hello" 的行。

方法一：手动创建管道

我们可以使用 io.Pipe() 创建一个内存管道，将第一个命令的输出写入管道，第二个命令从管道读取。

package mainimport (    "io"    "log"    "os/exec")func main() {    // 创建一个内存管道    pr, pw := io.Pipe()    // 启动第一个命令：echo    cmd1 := exec.Command("echo", "hello world")    cmd1.Stdout = pw // 将 echo 的输出写入管道写端    // 启动第二个命令：grep    cmd2 := exec.Command("grep", "hello")    cmd2.Stdin = pr // 从管道读端读取输入    // 启动第二个命令（必须先启动消费者）    output, err := cmd2.Output()    if err != nil {        log.Fatal(err)    }    // 启动第一个命令    err = cmd1.Run()    if err != nil {        log.Fatal(err)    }    // 关闭管道写端（重要！否则 grep 会一直等待）    pw.Close()    // 打印结果    log.Printf("Output: %s", output)}

⚠️ 注意：必须先启动读取方（cmd2），再启动写入方（cmd1），否则可能造成死锁。同时，写入完成后要关闭管道写端（pw.Close()），通知读取方数据已结束。

方法二：使用 StdoutPipe（推荐）

更简洁的方式是使用 Cmd.StdoutPipe() 方法：

package mainimport (    "io"    "log"    "os/exec")func main() {    // 第一个命令    cmd1 := exec.Command("echo", "hello world")    r, err := cmd1.StdoutPipe()    if err != nil {        log.Fatal(err)    }    // 第二个命令    cmd2 := exec.Command("grep", "hello")    cmd2.Stdin = r    // 同时启动两个命令    err = cmd2.Start()    if err != nil {        log.Fatal(err)    }    err = cmd1.Start()    if err != nil {        log.Fatal(err)    }    // 等待第一个命令结束    err = cmd1.Wait()    if err != nil {        log.Fatal(err)    }    // 获取第二个命令的输出    output, err := cmd2.Output()    if err != nil {        log.Fatal(err)    }    log.Printf("Result: %s", output)}

这种方法避免了手动管理 io.Pipe()，代码更清晰，也更符合 Go 的惯用法。

常见问题与注意事项

• 确保命令在目标系统中存在（如 grep 在 Windows 上可能不可用）
• 注意命令参数的传递方式：每个参数应作为独立字符串传入
• 处理错误！不要忽略 err
• 避免死锁：合理安排命令启动顺序

总结

通过本文，你已经掌握了在 Go语言 中使用 os/exec 包实现命令管道（Pipe）的核心技巧。无论是手动创建管道还是使用 StdoutPipe，都能有效完成多命令串联的任务。这些技能在自动化脚本、日志处理、系统监控等场景中非常实用。

记住关键词：Go语言、os/exec、命令管道、Pipe——它们是你深入理解进程通信的关键。

现在，快去尝试构建你自己的管道程序吧！