本文介绍如何使用 Go 启动 top -b 命令并逐行捕获其输出，同时为每一行自动添加当前 UTC 时间戳，适用于进程监控日志场景。
本文介绍如何使用 go 启动 `top -b` 命令并逐行捕获其输出，同时为每一行自动添加当前 utc 时间戳，适用于进程监控日志场景。
在 Go 中为外部命令（如 top）的输出动态添加时间戳，核心在于非阻塞地按行读取 stdout 并即时处理。由于 top 默认以交互模式运行，必须启用批处理模式（-b）才能持续输出可解析的文本流；同时，需借助 bufio.Scanner 配合 goroutine 实现异步、流式处理。
以下是一个完整、健壮的实现方案：
package main
import (
"bufio"
"fmt"
"os/exec"
"strconv"
"time"
)
func main() {
// 监控单个或多个 PID（例如 PID 2543）
for line := range topMon(2543) {
timestamp := time.Now().UTC().Format(time.RFC3339)
fmt.Printf("[%s] %s\n", timestamp, line)
}
}
// topMon 启动 top -b 命令，监听指定 PID，并返回每行输出的只读通道
func topMon(pids ...int) <-chan string {
ch := make(chan string, 16) // 缓冲通道，避免 Scanner 因消费者慢而阻塞
cmdArgs := []string{"-b"} // 必须启用批处理模式
for _, pid := range pids {
cmdArgs = append(cmdArgs, "-p", strconv.Itoa(pid))
}
top := exec.Command("top", cmdArgs...)
r, w, err := os.Pipe()
if err != nil {
panic(fmt.Sprintf("failed to create pipe: %v", err))
}
// 启动 goroutine：从管道读取并发送每行到 channel
go func() {
defer close(ch)
scanner := bufio.NewScanner(r)
for scanner.Scan() {
select {
case ch <- scanner.Text():
// 成功发送
default:
// 缓冲满时丢弃（或可改为阻塞等待，视需求调整）
fmt.Fprintf(os.Stderr, "warning: channel full, dropping line\n")
}
}
if err := scanner.Err(); err != nil {
fmt.Fprintf(os.Stderr, "scanner error: %v\n", err)
}
}()
// 将 top 的 stdout 重定向至管道写端
top.Stdout = w
top.Stderr = os.Stderr // 便于调试错误（如 PID 不存在）
if err := top.Start(); err != nil {
panic(fmt.Sprintf("failed to start top: %v", err))
}
// 注意：不要调用 top.Wait() —— top -b 会持续输出，应由主逻辑控制生命周期
// 如需优雅终止，可额外暴露 stop 机制（例如通过 context 或 signal）
return ch
}✅ 关键要点说明：
- ✅ 必须使用 -b（batch mode）：否则 top 不会持续输出，而是进入交互界面，导致管道挂起。
- ✅ bufio.Scanner 按行解析：天然适配 top 的换行分隔输出，避免手动处理 \n 和缓冲边界。
- ✅ goroutine + channel 解耦生产与消费：确保 top 进程持续运行，同时主线程自由控制格式化与输出节奏。
- ⚠️ 注意资源释放：示例中未显式终止 top 进程；生产环境建议结合 context.Context 控制超时或信号中断，并调用 top.Process.Kill() 清理子进程。
- ? 扩展性提示：支持多 PID（-p PID1 -p PID2），也可轻松接入日志库（如 log/slog）替代 fmt.Println。
该方案兼具简洁性与工程可用性，是 Go 中处理实时命令流并注入元数据（如时间戳）的标准实践。
