本文详解如何在 Go 中可靠捕获向已关闭读端的命名管道（mkfifo）写入时产生的 EPIPE 错误，指出常见误区（如直接比较 err == syscall.EPIPE 失败），并提供可落地的错误检查、信号处理与健壮写入逻辑。
本文详解如何在 go 中可靠捕获向已关闭读端的命名管道（`mkfifo`）写入时产生的 `epipe` 错误，指出常见误区（如直接比较 `err == syscall.epipe` 失败），并提供可落地的错误检查、信号处理与健壮写入逻辑。
在 Go 中向命名管道（FIFO）写入数据时，若对端 reader（如 cat /tmp/test 或 head /tmp/test）意外退出或未启动，写操作不会立即返回 syscall.EPIPE，而是触发 SIGPIPE 信号——而 Go 运行时默认屏蔽该信号并将其转化为包装后的错误，而非裸 errno。这是开发者常踩的坑：直接 if err == syscall.EPIPE 永远为 false。
✅ 正确检测 EPIPE：解包 *os.PathError
Go 的 os.File.Write 在系统调用失败时返回的是 *os.PathError 类型错误（而非原始 syscall.Errno）。其内部字段 .Err 才真正承载了底层 errno（如 syscall.EPIPE）。因此，必须显式类型断言并检查嵌套错误：
n, err := pipe.Write([]byte("foo\n"))
if err != nil {
if perr, ok := err.(*os.PathError); ok && perr.Err == syscall.EPIPE {
fmt.Println("⚠️ 对端 reader 已关闭，写入被拒绝（EPIPE）")
// 此处可安全关闭 pipe、重试、降级到文件等
pipe.Close()
return
}
// 其他错误（如权限不足、路径不存在）
log.Fatal("写入失败:", err)
}
fmt.Printf("成功写入 %d 字节\n", n)
? 验证技巧：打印错误全貌可快速定位结构：
fmt.Printf("err = %+v\n", err) // 输出包含 Op、Path、Err 字段的完整 PathError
⚠️ SIGPIPE 无法被 Go 程序常规捕获或忽略
尽管 os/signal.Notify(csig, syscall.SIGPIPE) 在 kill -13 时能收到信号，但这仅适用于用户主动发送的 SIGPIPE；当内核因写入无 reader 的 FIFO 自动发送 SIGPIPE 时，Go 运行时会*优先拦截并转为 `os.PathError**，不再投递到signal.Notify通道。更关键的是：**Go 不允许通过signal.Ignore(syscall.SIGPIPE)` 来恢复传统 Unix 行为**——这会导致运行时 panic 或未定义行为。
? 重要事实：Go 1.5+ 默认屏蔽 SIGPIPE，并在连续多次 EPIPE 后（约 10 次）放弃拦截，直接让进程被 signal: broken pipe 终止。此时 signal.Notify 仍无法捕获，因为进程已退出。
✅ 健壮实践：非阻塞写 + 及时退出
针对 tee 类场景（需容忍 reader 临时离线），应结合 O_NONBLOCK 标志与错误处理：
// 以非阻塞模式打开 FIFO（避免 Write 永久挂起）
pipe, err := os.OpenFile("/tmp/test", os.O_WRONLY|os.O_NONBLOCK, 0)
if err != nil {
log.Fatal("打开 FIFO 失败:", err)
}
for {
n, err := pipe.Write([]byte("log line\n"))
if err != nil {
if perr, ok := err.(*os.PathError); ok && perr.Err == syscall.EPIPE {
fmt.Println("❌ FIFO 读端不可用，跳过本次写入")
time.Sleep(100 * time.Millisecond) // 避免忙等
continue
}
if errors.Is(err, syscall.EAGAIN) || errors.Is(err, syscall.EWOULDBLOCK) {
fmt.Println("? FIFO 缓冲区满，稍后重试")
time.Sleep(50 * time.Millisecond)
continue
}
log.Fatal("不可恢复写入错误:", err)
}
fmt.Printf("✅ 写入成功: %d 字节\n", n)
}
✅ 总结：关键要点
- 不要直接比较 err == syscall.EPIPE —— 必须解包 *os.PathError.Err；
- 不要尝试 signal.Ignore(syscall.SIGPIPE) —— Go 运行时禁止此操作；
- 不要无限循环写入失败的 FIFO —— 需检测 EPIPE 并主动退出或降级；
- 推荐使用 os.O_NONBLOCK 打开 FIFO，避免阻塞，并配合 EAGAIN/EWOULDBLOCK 处理缓冲区满；
- 若需完全兼容传统 Unix 行为（如 fork 后 exec 子进程），应在 exec 前用 syscall.Reset(syscall.SIGPIPE) 清除 Go 的 SIGPIPE 处理器（仅限高级场景）。
遵循以上方法，即可在 Go 中稳定实现类似 tee 的管道容错日志写入能力。
