本文介绍如何使用 Go 的 os/exec 包组合多个命令形成管道（如 top -b | grep ...），并通过 channel 和 timer 实现定时执行与信号驱动的进程终止，避免依赖 shell 解析器。
本文介绍如何使用 go 的 `os/exec` 包组合多个命令形成管道（如 `top -b | grep ...`），并通过 channel 和 timer 实现定时执行与信号驱动的进程终止，避免依赖 shell 解析器。
在 Go 中，exec.Command 默认不支持 Shell 风格的管道语法（如 |、>>），因为其设计目标是安全、跨平台地直接调用二进制程序，而非调用 /bin/sh -c。但我们可以手动构建管道：通过 Cmd.StdinPipe() 和 Cmd.StdoutPipe() 连接多个 exec.Cmd 实例，形成类似 Unix pipeline 的数据流。
以下是一个生产就绪的示例，模拟 top -b | grep --line-buffered [pid] >> out.log，并支持运行指定时长后自动终止，或通过 channel 提前中断：
package main
import (
"bufio"
"io"
"log"
"os/exec"
"time"
)
func runTopGrepPipeline(pid string, timeout time.Duration, done <-chan struct{}) error {
// 启动 top 命令（批处理模式，持续输出）
topCmd := exec.Command("top", "-b", "-n", "0") // -n 0 表示无限次，实际由后续逻辑控制生命周期
topStdout, err := topCmd.StdoutPipe()
if err != nil {
return err
}
// 启动 grep 命令，接收 top 输出并过滤指定 PID
grepCmd := exec.Command("grep", "--line-buffered", pid)
grepCmd.Stdin = topStdout
// 打开日志文件（追加模式）
logFile, err := openLogFile("out.log")
if err != nil {
return err
}
defer logFile.Close()
// 将 grep 输出写入文件
grepCmd.Stdout = logFile
// 启动 top（注意：必须在设置 Stdin/Stdout 后调用 Start）
if err := topCmd.Start(); err != nil {
return err
}
defer topCmd.Process.Kill() // 确保清理
// 启动 grep（它会自动从 topStdout 读取）
if err := grepCmd.Start(); err != nil {
return err
}
defer grepCmd.Wait() // 等待 grep 结束，确保日志写入完成
// 使用 select 控制生命周期：超时或外部信号触发退出
doneCh := make(chan struct{})
go func() {
<-done
// 向 top 发送 SIGTERM（更优雅），若未响应再 SIGKILL
topCmd.Process.Signal(15) // SIGTERM
time.AfterFunc(2*time.Second, func() {
topCmd.Process.Kill()
})
close(doneCh)
}()
select {
case <-time.After(timeout):
log.Println("Timeout reached, terminating pipeline...")
topCmd.Process.Signal(15)
return nil
case <-doneCh:
log.Println("Terminated by external signal")
return nil
}
}
func openLogFile(name string) (*bufio.Writer, error) {
f, err := openFileAppend(name)
if err != nil {
return nil, err
}
return bufio.NewWriter(f), nil
}
func openFileAppend(name string) (*os.File, error) {
return os.OpenFile(name, os.O_CREATE|os.O_WRONLY|os.O_APPEND, 0644)
}
func main() {
done := make(chan struct{})
// 示例：运行 10 秒后自动停止
timeout := 10 * time.Second
// 启动管道（异步）
go func() {
if err := runTopGrepPipeline("1234", timeout, done); err != nil {
log.Fatal(err)
}
}()
// 模拟 5 秒后主动触发终止（可替换为其他事件，如 HTTP 请求、用户输入等）
time.AfterFunc(5*time.Second, func() {
close(done)
})
// 阻塞等待，防止主 goroutine 退出
select {}
}⚠️ 关键注意事项：
- 不要使用 shell -c：虽然 exec.Command("sh", "-c", "top -b | grep ...") 可行，但存在注入风险、平台兼容性差（Windows 无 sh）、且难以精确控制子进程生命周期。
- 显式管理进程树：top 可能派生子进程，Kill() 仅终止直接子进程；如需彻底清理，可结合 syscall.Setpgid 或使用 golang.org/x/sys/unix 设置进程组。
- 缓冲与阻塞风险：grep --line-buffered 对 stdin 是行缓冲，但若 top 输出过快而 grep 处理慢，管道缓冲区满会导致 top 阻塞。建议监控 grep 是否存活，或添加 io.Copy 超时包装。
- 日志写入完整性：bufio.Writer 需显式 Flush()；本例中 grepCmd.Wait() 保证其 stdout（即 logFile）已全部写出，但若需更高可靠性，可在 grepCmd.Wait() 后调用 logFile.(*bufio.Writer).Flush()。
✅ 总结：Go 中构建命令管道的核心在于「手动连接标准流」——将前一个命令的 StdoutPipe() 作为后一个命令的 Stdin，并按需启动/等待。配合 time.Timer 与 channel，即可实现灵活、可控、安全的管道化命令调度，完全替代 shell 管道语法。
