本文介绍如何使用 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 <p>⚠️ <strong>关键注意事项</strong>：</p>
- 不要使用 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 管道语法。
