本文介绍如何在 Go 程序中通过管道捕获 top -b 的流式输出，并为每一行自动添加精确到秒的 UTC 时间戳，适用于进程监控日志化场景。
本文介绍如何在 go 程序中通过管道捕获 `top -b` 的流式输出，并为每一行自动添加精确到秒的 utc 时间戳，适用于进程监控日志化场景。
在 Go 中实时处理外部命令（如 top）的输出并动态注入元数据（例如时间戳），关键在于非阻塞读取 + 行级事件驱动处理。由于 top 默认以交互模式运行，必须启用批处理模式（-b）才能持续输出可解析的文本流；同时，为避免阻塞和丢失数据，应结合 os.Pipe、bufio.Scanner 和 goroutine 实现异步流处理。
以下是一个完整、健壮的实现方案：
package main
import (
"bufio"
"fmt"
"os/exec"
"strconv"
"time"
)
// topMon 启动 top 命令，以批处理模式监控指定 PID 列表，并返回每行输出的只读通道
func topMon(pids ...int) <-chan string {
ch := make(chan string, 64) // 缓冲通道，避免 Scanner 因接收方慢而阻塞
// 构建 top 命令：必须带 -b（批处理）才可管道化；-n 1 可选（单次快照），但此处省略以持续流式输出
top := exec.Command("top", "-b", "-d", "1") // -d 1 表示每秒刷新一次，平衡实时性与负载
for _, pid := range pids {
top.Args = append(top.Args, "-p", strconv.Itoa(pid))
}
r, w, err := os.Pipe()
if err != nil {
panic("failed to create pipe: " + err.Error())
}
// 启动 goroutine 异步扫描 stdout 并发送每行到 channel
go func() {
defer close(ch)
scanner := bufio.NewScanner(r)
for scanner.Scan() {
ch <- scanner.Text()
}
if err := scanner.Err(); err != nil {
fmt.Fprintf(os.Stderr, "scanner error: %v\n", err)
}
}()
// 绑定管道写端到 top.Stdout，并启动进程
top.Stdout = w
top.Stderr = os.Stderr // 将错误直接透传到标准错误，便于调试
if err := top.Start(); err != nil {
panic("failed to start top: " + err.Error())
}
// 注意：不调用 top.Wait() —— 我们依赖 top 自身终止或由外部控制（如信号）
return ch
}
func main() {
// 示例：监控 PID 2543（请替换为实际目标进程 ID）
pid := 2543
for line := range topMon(pid) {
// 每行前缀添加 RFC3339 格式时间戳（UTC，精确到秒），也可用 time.Now().Format("2006-01-02 15:04:05")
timestamp := time.Now().UTC().Format(time.RFC3339)
fmt.Printf("[%s] %s\n", timestamp, line)
}
}✅ 关键要点说明：
- top -b 是必需的：交互式 top 会尝试读取终端控制序列，无法正常管道化；-b 启用纯文本批处理模式。
- -d 1 显式设置刷新间隔（单位：秒），确保输出节奏可控；若省略，top 可能默认 3 秒刷新，影响实时性。
- 使用带缓冲的 channel（如 make(chan string, 64)）可防止 bufio.Scanner 因消费者处理慢而阻塞或丢行。
- top.Stderr = os.Stderr 保证错误信息可见，便于快速定位权限不足、PID 不存在等问题。
- 不调用 top.Wait()：因 top -b 在无 -n 参数时会无限循环输出，需由主程序逻辑决定何时退出（例如超时、收到中断信号等）。如需限定总运行次数，可在 top.Args 中追加 -n 10（共输出 10 次后退出）。
⚠️ 注意事项：
- 若需高精度时间戳（如纳秒级），请在 ch <- scanner.Text() 前立即获取 time.Now()，而非在 main 循环中取——后者可能因 channel 传递延迟导致时间偏移。
- 生产环境建议增加 top.Process.Kill() 的清理逻辑（配合 context.WithTimeout），避免僵尸进程。
- 对于多行标题/空行/ANSI 转义字符（极少见但 -b 模式下通常无），可进一步用正则过滤或跳过空行提升日志可读性。
该方案兼具简洁性与工程可用性，是 Go 中实现“命令输出增强”类需求的标准范式。
