Golang进程间通信实现使用管道进行交互-Golang-PHP中文网

os.pipe()仅适用于父子进程间通信，因其返回的内核匿名管道fd不带名字、不持久、不可跨独立进程访问；两个独立go run程序无法共享该fd，误用会导致broken pipe、立即eof或goroutine卡死。

golang进程间通信实现使用管道进行交互

Go 的 os.Pipe() 返回一对 *os.File，本质是内核级匿名管道 fd，但它**不带名字、不持久、不可跨独立进程访问**。两个各自 go run main.go 启动的程序之间，os.Pipe() 完全无效——它们压根看不到对方的 fd。

常见错误现象：broken pipe、读写立刻返回 EOF、goroutine 卡死在 Read() 或 Write() 上。根源就是误把内存级管道当成了命名管道（FIFO）或 Unix Socket。

真正能跨任意进程的“管道”，得用系统级 FIFO：mkfifo /tmp/myapp.fifo，再用 os.OpenFile("/tmp/myapp.fifo", os.O_RDONLY, 0) 和 os.OpenFile("/tmp/myapp.fifo", os.O_WRONLY, 0) 分别打开
FIFO 是阻塞式：一端 open() 时，若另一端没开，就会卡住；必须并发启动 reader/writer，或加 context.WithTimeout
FIFO 不支持双向通信，要双向就得开两个 FIFO，或者直接换用 net.Listen("unix", ...)

同一台机器上进程通信，net.Listen("unix", socketPath) 性能远超 loopback TCP，且天然支持文件权限控制。关键不是“能不能用”，而是路径、权限、清理三件事必须做对。

常见错误现象：connect: connection refused（服务端没 listen 或 socket 文件残留）、permission denied（父目录缺 x 权限）、address already in use（旧 socket 文件没删干净）。

服务端启动前必须调用 os.RemoveAll(socketPath) 清理旧文件——os.Remove() 对残留的 socket 目录会失败
socketPath 必须是绝对路径，且其**父目录要有可执行（x）权限**，否则客户端连不上（Linux/Unix 下路径遍历需要 x）
监听后不要写 defer listener.Close() 在 accept 循环外；正确做法是 defer func() { _ = listener.Close() }()，或把 Close() 放在 shutdown 流程里
客户端连接失败时，别直接 panic；建议重试 3 次，每次 time.Sleep(100 * time.Millisecond)，因为服务端可能刚启动还没 listen 完

Go 不支持 shell 风格的管道语法，exec.Command("ls") | exec.Command("grep", "main") 这种写法根本不存在。想实现 ls | grep 效果，只有两种可靠方式。

Golang Naming

Go（Golang）命名规范 — 包括包、构造函数、结构体、接口、常量、枚举、错误、布尔值、接收器、getter/setter、函数等。

下载

常见错误现象：命令顺序执行而非管道、io.Copy 卡死、中间命令退出后下游读不到 EOF、goroutine 泄漏。

两命令简单管道：用 cmd1.StdoutPipe() 获取 reader，再设 cmd2.Stdin 为该 reader，然后 cmd1.Start() → cmd2.Start() → cmd1.Wait() → cmd2.Wait()
三命令及以上（如 ps | grep | awk），直接用 exec.Command("sh", "-c", `ps aux | grep go | awk '{print $2}'`)，Linux/macOS 用 sh -c，Windows 用 cmd /c，语法不兼容但最稳
手动链式管道时，cmd1.Wait() 必须在 cmd2.Run() 之后调用；如果提前 Wait，cmd2 可能因 stdin 关闭而无法读取完整数据
所有 io.Copy 建议包一层 context.WithTimeout，避免某一级卡死拖垮整个流程