前提条件与环境准备
系统兼容性与权限
在 Linux、Unix 及其类系统中，Unix FIFO（命名管道）是一种用于进程间通信（IPC）的高效机制。确保内核对命名管道的支持，以及当前用户对目标路径具备写入权限，这样才能在目标目录创建并操作 FIFO 文件。
实践中，优先选择 /tmp 等临时目录来放置 FIFO，以降低权限冲突和持久化副作用的风险，提高测试与调试的便利性。
Go 语言实现 Unix FIFO 的核心要点
使用系统调用创建命名管道
Go 语言通过系统调用实现命名管道。Mkfifo 是核心函数，用于在指定路径创建一个命名管道节点。通过合理的权限位，可以控制谁可以写入或读取该管道。
为了更好的跨平台性和维护性，推荐使用 golang.org/x/sys/unix 包中的 unix.Mkfifo，并在创建后打开读写端进行数据传输。下面展示了一个简单的创建示例。
package mainimport ("log""os""golang.org/x/sys/unix"
)func main() {path := "/tmp/myfifo_go"// 如果已经存在，先移除_ = os.Remove(path)// 创建命名管道，权限 0666if err := unix.Mkfifo(path, 0666); err != nil {log.Fatalf("failed to create fifo: %v", err)}// 打开写端，注意此操作在没有读端时会阻塞w, err := os.OpenFile(path, os.O_WRONLY, 0)if err != nil {log.Fatalf("open for write: %v", err)}defer w.Close()// 简单写入示例_, _ = w.Write([]byte("hello fifo\n"))
}
从创建到数据传输的实战示例
概览：生产者与消费者的协作模式
在实际应用中，最常见的用法是生产者将数据写入 FIFO，消费者从 FIFO 读取数据。命名管道的读写端需要由不同进程打开，才能实现完整的数据传输，这也是 IPC 的核心特性之一。
以下示例展示了如何在同一台主机上，通过两个独立进程实现完整的生产者-消费者模型。两端分别打开 FIFO 的方式与数据传输的流程是重点。
生产者示例代码
生产者的职责是打开 FIFO 的写端并持续写入数据。写端在没有读端时会阻塞，因此同时启动消费者是必须的，以确保数据被读取。
package mainimport ("log""os""time""strconv""golang.org/x/sys/unix"
)func main() {path := "/tmp/myfifo_go"// 确保 FIFO 存在_ = os.Remove(path)if err := unix.Mkfifo(path, 0666); err != nil {log.Fatalf("mkfifo error: %v", err)}// 打开写端w, err := os.OpenFile(path, os.O_WRONLY, 0)if err != nil {log.Fatalf("open for write: %v", err)}defer w.Close()// 逐条写入数据for i := 0; i < 5; i++ {msg := "message " + strconv.Itoa(i) + "\n"if _, err := w.Write([]byte(msg)); err != nil {log.Printf("write error: %v", err)break}time.Sleep(1 * time.Second)}
}
消费者示例代码
消费者打开 FIFO 的读端并实时读取数据。读取端通常使用阻塞模式，等待生产者写入数据，直到生产者结束或管道被关闭。
package mainimport ("bufio""fmt""log""os"
)func main() {path := "/tmp/myfifo_go"// 打开读端r, err := os.OpenFile(path, os.O_RDONLY, 0)if err != nil {log.Fatalf("open for read: %v", err)}defer r.Close()// 按行读取并输出到标准输出scanner := bufio.NewScanner(r)for scanner.Scan() {fmt.Println("received:", scanner.Text())}if err := scanner.Err(); err != nil {log.Fatalf("read error: %v", err)}
}
要在同一台机器上测试上述示例，通常需要在两个独立的终端中分别执行两个 Go 程序，先启动生产者再启动消费者，或者同时启动两个后台进程以实现实时数据流。
