本文介绍如何使用 Go 的 exec 包配合 StdoutPipe 实现子进程输出的实时捕获与处理，支持边运行边读取、条件中断及避免僵尸进程，适用于日志监听、命令行工具集成等场景。
本文介绍如何使用 go 的 `exec` 包配合 `stdoutpipe` 实现子进程输出的实时捕获与处理，支持边运行边读取、条件中断及避免僵尸进程，适用于日志监听、命令行工具集成等场景。
要在 Go 中实时打印（或处理）正在运行的子进程输出——而非等待其完全结束后一次性获取全部输出——关键在于避免阻塞式等待，并采用流式读取机制。你提供的原始代码中使用 cmd.Run() 是同步阻塞调用，会一直等到脚本执行完毕才返回，因此 out.String() 只能在 30 秒后输出全部内容。
正确的做法是：
- 调用 cmd.StdoutPipe() 获取一个 io.ReadCloser；
- 使用 cmd.Start() 启动进程（非阻塞）；
- 通过 bufio.Scanner 或 bufio.Reader 按行/按字节实时读取 stdout 流；
- 在读取循环中动态处理每条输出（如匹配关键字、触发返回、写入日志等）；
- 必要时主动终止子进程或清理资源。
以下是改进后的完整示例：
package main
import (
"bufio"
"fmt"
"os/exec"
"time"
)
func main() {
burstingScript := "./bash_loop.sh"
cmd := exec.Command("/bin/sh", burstingScript)
stdout, err := cmd.StdoutPipe()
if err != nil {
panic(err)
}
if err := cmd.Start(); err != nil {
panic(err)
}
defer func() {
// 确保进程被正确等待或终止，防止僵尸进程
if cmd.ProcessState == nil || !cmd.ProcessState.Exited() {
cmd.Wait() // 若未退出则等待；若已退出则 Wait 不阻塞
}
}()
scanner := bufio.NewScanner(stdout)
for scanner.Scan() {
line := scanner.Text()
fmt.Println("→", line) // 实时打印
// 示例：发现 "3" 后立即返回结果，并可选择是否终止子进程
if line == "3" {
fmt.Println("Found target! Returning early.")
// 注意：此时子进程仍在后台运行
// 如需强制终止，可调用 cmd.Process.Kill()
// cmd.Process.Kill()
return
}
}
if err := scanner.Err(); err != nil {
fmt.Printf("Scanner error: %v\n", err)
}
// 等待子进程自然结束（若未提前 return）
if err := cmd.Wait(); err != nil {
fmt.Printf("Command finished with error: %v\n", err)
}
}✅ 关键要点说明：
- cmd.StdoutPipe() 必须在 cmd.Start() 之前调用，否则会 panic；
- cmd.Start() 启动进程但不等待，为流式读取创造前提；
- bufio.Scanner 默认按行扫描，适合日志类文本输出；若需更细粒度控制（如逐字节），可用 bufio.NewReader(stdout) 配合 ReadString('\n') 或 ReadBytes('\n')；
- 关于僵尸进程：只要最终调用 cmd.Wait()（或 cmd.Process.Wait()），Go 运行时就能回收子进程资源。即使你在读取中途 return，只要 defer cmd.Wait() 已注册，仍能确保清理。但注意：若子进程持续运行且你不显式 Kill()，它将在后台继续执行（符合 P.S.2 的“detach”需求）；
- 若需在匹配后立即终止子进程，取消注释 cmd.Process.Kill() 即可（注意：Kill() 发送 SIGKILL，不可被捕获；如需优雅退出，建议发送 SIGTERM 并配合 cmd.Process.Signal(syscall.SIGTERM)）。
此外，若还需捕获 stderr，可同样调用 cmd.StderrPipe() 并启动 goroutine 分别读取，避免因 stderr 缓冲满导致子进程阻塞（常见于未重定向 stderr 的长时命令）。
总之，Go 提供了足够底层且灵活的接口来实现真正的实时 I/O 处理——无需轮询（poll()），而是依托操作系统管道 + Go 的并发读取能力，高效、可靠地完成流式交互。
