本文详解如何在 Go 中模拟 Shell 管道（如 top -b | grep --line-buffered [pid] >> out.log），使用 os/exec 组合多个命令、连接 stdin/stdout，并配合 channel 与 timer 实现优雅超时终止。
本文详解如何在 go 中模拟 shell 管道（如 `top -b | grep --line-buffered [pid] >> out.log`），使用 `os/exec` 组合多个命令、连接 stdin/stdout，并配合 channel 与 timer 实现优雅超时终止。
在 Go 中，exec.Command 默认不支持类似 Shell 的 | 语法，但可通过手动连接进程的 StdinPipe 和 StdoutPipe 实现等效的管道链。核心思路是：将前一个命令的 stdout 作为后一个命令的 stdin，并可选地将最终输出重定向到文件或进一步处理。
以下是一个生产就绪的示例，实现 top -b | grep --line-buffered [pid] >> out.log 的功能，并支持运行指定时长后自动终止：
package main
import (
"bufio"
"io"
"log"
"os/exec"
"time"
)
func runPipedCommand(pid string, timeout time.Duration, logFile string) error {
// 创建日志文件（追加模式）
f, err := openLogFile(logFile)
if err != nil {
return err
}
defer f.Close()
// 第一步：启动 top -b（持续输出，需限制行数避免无限阻塞）
topCmd := exec.Command("top", "-b", "-n", "10") // -n 10 表示采集 10 次快照
topOut, err := topCmd.StdoutPipe()
if err != nil {
return err
}
// 第二步：启动 grep，接收 top 输出并过滤目标 PID
grepCmd := exec.Command("grep", "--line-buffered", pid)
grepCmd.Stdin = topOut
grepCmd.Stdout = f // 直接写入日志文件
// 启动两个命令（注意：必须先 Start top，再 Start grep）
if err := topCmd.Start(); err != nil {
return err
}
if err := grepCmd.Start(); err != nil {
topCmd.Process.Kill() // 清理上游
return err
}
// 设置超时控制：通过 channel + select 实现
done := make(chan error, 2)
go func() { done <p>✅ <strong>关键要点说明</strong>：</p><div class="aritcle_card flexRow artxards">
<div class="artcardd flexRow">
<a class="aritcle_card_img" rel="nofollow" href="/xiazai/learn/7564" title="使用Go语言搭建家庭相册系统-相关课件"><img
src="https://img.php.cn/upload/webcode/000/000/164/636a2b4d84031727.png" alt="使用Go语言搭建家庭相册系统-相关课件" onerror="this.onerror='';this.src='/static/lhimages/moren/morentu.png'" ></a>
<div class="aritcle_card_info flexColumn">
<a rel="nofollow" href="/xiazai/learn/7564" title="使用Go语言搭建家庭相册系统-相关课件" class="overflowclass">使用Go语言搭建家庭相册系统-相关课件</a>
<p class="overflowclass">使用Go语言搭建家庭相册系统-相关课件</p>
</div>
<a rel="nofollow" href="/xiazai/learn/7564" title="使用Go语言搭建家庭相册系统-相关课件" class="aritcle_card_btn flexRow flexcenter"><b></b><span>下载</span>
</a>
</div>
</div>
- 管道连接：topCmd.StdoutPipe() 返回 io.ReadCloser，赋给 grepCmd.Stdin 即完成数据流串联；
- 行缓冲保障：grep --line-buffered 确保每行立即输出，避免因默认全缓冲导致延迟；
- 超时与清理：使用 time.After 配合 select 实现非阻塞等待；超时时主动调用 Process.Kill() 终止整个管道链；
- 资源安全：所有 Wait() 调用均通过 goroutine 封装，防止主流程阻塞；defer 和显式 Close() 保证文件句柄释放；
- 健壮性增强：添加了双进程退出等待逻辑，避免僵尸进程；对 OpenFile 使用 O_APPEND 确保多轮运行日志追加。
⚠️ 注意事项：
- 在 Windows 上需替换为兼容命令（如 tasklist + findstr），或使用跨平台库（如 golang.org/x/sys/execabs）；
- 若目标命令不存在或权限不足，Start() 会立即失败，务必检查错误；
- top -b 在容器环境可能受限，建议配合 ps 或 /proc/[pid]/stat 等轻量方案作为备选；
- 生产环境中建议增加日志上下文（如 slog）、错误分类（超时/IO/信号）及监控指标。
通过上述方法，你完全可以在 Go 中替代 Shell 脚本完成复杂管道任务，同时获得更好的可观测性、类型安全和生命周期控制能力。
