在 Go 中调用外部命令时，若需实时、独立处理 stdout 和 stderr 并严格保持其原始输出时序，不能依赖管道读取的自然顺序——因二者为并发流，需通过同步机制（如互斥锁或带序通道）显式归并。本文提供可落地的线程安全归并方案，并附完整示例与关键注意事项。
在 go 中调用外部命令时，若需**实时、独立处理 stdout 和 stderr 并严格保持其原始输出时序**，不能依赖管道读取的自然顺序——因二者为并发流，需通过同步机制（如互斥锁或带序通道）显式归并。本文提供可落地的线程安全归并方案，并附完整示例与关键注意事项。
当 Go 程序通过 os/exec 启动子进程（如 bash -c "echo TEST1; echo TEST2 1>&2; echo TEST3"）时，Stdout 和 Stderr 是两个独立、并发写入的管道。操作系统不保证它们在父进程中被读取的相对顺序——即使子进程按序写入，Go 侧的 io.Writer 实现若无同步保护，stdout.Write() 与 stderr.Write() 的执行时机仍由调度器决定，导致最终拼接结果（如 "TEST1\nTEST3\nTEST2\n"）随机。
要解决这一问题，核心思路是：不追求“同时读取”，而是在写入阶段就对每段输出打上来源标签（stdout/stderr）和逻辑时间戳，并用同步原语确保写入操作原子化。以下是一个生产可用的实现方案：
✅ 推荐方案：使用 sync.Mutex 归并带源标记的输出
package main
import (
"fmt"
"log"
"os/exec"
"sync"
)
type writeRecord struct {
Source string // "STDOUT" or "STDERR"
Data string
}
type syncedWriter struct {
Source string
mu *sync.Mutex
records *[]writeRecord // 指向共享切片的指针，支持多 writer 共同追加
}
func (w *syncedWriter) Write(p []byte) (int, error) {
w.mu.Lock()
defer w.mu.Unlock()
*w.records = append(*w.records, writeRecord{
Source: w.Source,
Data: string(p),
})
return len(p), nil
}
func main() {
// 示例命令：模拟交错输出（注意添加 sleep 仅用于演示时序可控性，真实命令无需修改）
cmd := exec.Command("bash", "-c", "echo TEST1; sleep 0.01; echo TEST2 1>&2; sleep 0.01; echo TEST3")
var mu sync.Mutex
var records []writeRecord // 所有输出将按写入顺序追加至此切片
cmd.Stdout = &syncedWriter{
Source: "STDOUT",
mu: &mu,
records: &records,
}
cmd.Stderr = &syncedWriter{
Source: "STDERR",
mu: &mu,
records: &records,
}
if err := cmd.Start(); err != nil {
log.Fatal("启动命令失败:", err)
}
if err := cmd.Wait(); err != nil {
log.Fatal("命令执行出错:", err)
}
// 按归并顺序打印（保留原始时序）
for _, r := range records {
fmt.Printf("[%s] %s", r.Source, r.Data)
}
}运行结果稳定输出（注意 [STDOUT]/[STDERR] 标签与内容顺序）：
[STDOUT] TEST1 [STDERR] TEST2 [STDOUT] TEST3
⚠️ 关键注意事项
- 不要依赖 CombinedOutput：它虽能保序，但会混合 stdout 和 stderr，无法满足“分别处理”的需求；
- 避免竞态的根源：*[]writeRecord + sync.Mutex 是关键——所有 writer 共享同一锁和同一底层数组指针，确保 append 原子性；
- 真实场景无需 sleep：示例中 sleep 0.01 仅为放大时序差异便于验证；实际调用 curl、git、ffmpeg 等命令时，只要子进程自身输出有序，本方案即可 100% 还原；
- 性能考量：Mutex 开销极小（微秒级），远低于 I/O 本身，适用于绝大多数场景；若需极致吞吐（如高频日志流），可升级为带缓冲的 channel + 单 goroutine 归并（见进阶变体）；
- 换行符处理：Write 接收的是原始字节流，可能不含 \n（如 echo -n）。建议在业务逻辑中按需缓冲/分隔，或使用 bufio.Scanner 封装。
✅ 总结
Go 中保持子进程 stdout/stderr 输出时序的本质，是将“顺序”从操作系统管道语义转移到应用层同步控制。通过为每个 Writer 注入共享锁与统一记录容器，我们以最小侵入方式实现了确定性归并。该方案简洁、健壮、无第三方依赖，可直接集成至 CLI 工具、运维脚本或服务端命令代理模块中。
