本文详解如何在 go 中安全运行外部命令，同时支持超时终止与实时流式读取 stdout 的每一行，避免阻塞、资源泄漏和逻辑竞态问题。
本文详解如何在 go 中安全运行外部命令，同时支持超时终止与实时流式读取 stdout 的每一行，避免阻塞、资源泄漏和逻辑竞态问题。
在 Go 中调用外部命令（如 traceroute、ping 或自定义脚本）并实时处理其输出，是运维工具、监控系统和 CLI 应用中的常见需求。但若不加约束，长时间运行的命令可能导致程序挂起；而错误的并发控制又容易引发 goroutine 泄漏或超时失效。核心挑战在于：既要非阻塞地读取 stdout 流，又要确保超时信号能及时中断整个流程。
原代码的主要问题在于将耗时的 scanner.Scan() 循环放在了 select 的 default 分支中——这导致 select 语句仅执行一次，随后便陷入同步循环，完全跳过了超时通道监听。time.After 本身是单次触发的 timer，但若 select 永远不重新进入，它就永远无法被选中。
✅ 正确做法是：将 stdout 读取逻辑放入独立 goroutine，让 select 始终处于可响应状态，并在超时时主动终止进程：
func RunCommandWithTimeout(cmd *exec.Cmd, timeout time.Duration) error {
stdout, err := cmd.StdoutPipe()
if err != nil {
return fmt.Errorf("failed to get stdout pipe: %w", err)
}
if err := cmd.Start(); err != nil {
return fmt.Errorf("failed to start command: %w", err)
}
// 启动 goroutine 实时读取 stdout
done := make(chan error, 1)
go func() {
scanner := bufio.NewScanner(stdout)
for scanner.Scan() {
log.Println(scanner.Text()) // 或转发至 channel/Writer
}
done <p>? <strong>关键注意事项</strong>：</p>
- cmd.Process.Kill() 发送 SIGKILL（Unix）或 TerminateProcess（Windows），是最强终止手段，但需确保进程无子进程残留；
- cmd.Wait() 必须在 cmd.Start() 后调用，否则可能 panic；超时后调用 Wait() 可回收进程资源；
- bufio.Scanner 默认每行上限 64KB，如需处理超长行，应提前设置 scanner.Buffer(make([]byte, 64*1024), 1
- 若需同时捕获 stderr，可用 cmd.StderrPipe() 并启动另一 goroutine 处理，或统一重定向到 cmd.Stdout（cmd.Stderr = cmd.Stdout）；
- 在生产环境，建议使用 context.WithTimeout 替代 time.After，便于传播取消信号与嵌套超时。
完整示例调用：
func main() {
cmd := exec.Command("sh", "-c", "for i in {1..5}; do echo \"line $i\"; sleep 1; done")
if err := RunCommandWithTimeout(cmd, 3*time.Second); err != nil {
log.Fatal(err)
}
}
// 输出前 3 行后超时终止
该模式兼顾实时性、可靠性与可维护性，是 Go 中执行外部命令的标准实践之一。
