Go语言中使用FIFO（命名管道）-Golang-PHP中文网

Go语言中使用FIFO（命名管道）

心靈之曲

发布： 2025-08-03 16:02:01

原创

581人浏览过

go语言中使用fifo（命名管道）

本文介绍了如何在Go语言中创建和使用FIFO（命名管道）。由于Go标准库的os包中没有直接提供创建命名管道的函数，我们将利用syscall包调用底层的mknod系统调用来实现这一功能。文章提供了详细的代码示例和注意事项，帮助开发者在Go程序中轻松地使用FIFO进行进程间通信。

在Unix系统中，FIFO（First-In, First-Out），也称为命名管道，是一种进程间通信（IPC）的方式。它允许两个或多个进程通过一个特殊的文件进行数据交换。与匿名管道（通过os.Pipe创建）不同，FIFO在文件系统中有一个名称，因此不相关的进程可以通过这个名称来访问它。

虽然Go语言的标准库os包中没有直接提供创建FIFO的函数，但我们可以利用syscall包来调用底层的系统调用mknod来实现。

使用 syscall.Mknod 创建 FIFO

立即学习“go语言免费学习笔记（深入）”；

syscall.Mknod 函数允许我们创建文件系统节点，包括FIFO。下面是一个创建FIFO的示例代码：

有道翻译AI助手

有道翻译提供即时免费的中文、英语、日语、韩语、法语、德语、俄语、西班牙语、葡萄牙语、越南语、印尼语、意大利语、荷兰语、泰语全文翻译、网页翻译、文档翻译、PDF翻

查看详情

package main

import (
    "fmt"
    "syscall"
    "os"
)

func main() {
    fifoPath := "/tmp/my_fifo" // 定义FIFO的路径

    // 检查FIFO是否已存在，如果存在则删除
    if _, err := os.Stat(fifoPath); err == nil {
        err := os.Remove(fifoPath)
        if err != nil {
            fmt.Println("删除已存在的FIFO失败:", err)
            return
        }
    }

    // 使用 syscall.Mknod 创建 FIFO
    err := syscall.Mknod(fifoPath, syscall.S_IFIFO|0666, 0)
    if err != nil {
        fmt.Println("创建FIFO失败:", err)
        return
    }

    fmt.Println("FIFO创建成功，路径:", fifoPath)

    // 示例：向 FIFO 写入数据
    go func() {
        file, err := os.OpenFile(fifoPath, os.O_WRONLY, os.ModeNamedPipe)
        if err != nil {
            fmt.Println("打开FIFO写入端失败:", err)
            return
        }
        defer file.Close()

        message := "Hello, FIFO!"
        _, err = file.WriteString(message)
        if err != nil {
            fmt.Println("写入FIFO失败:", err)
            return
        }
        fmt.Println("写入FIFO成功:", message)
    }()

    // 示例：从 FIFO 读取数据
    file, err := os.OpenFile(fifoPath, os.O_RDONLY, os.ModeNamedPipe)
    if err != nil {
        fmt.Println("打开FIFO读取端失败:", err)
        return
    }
    defer file.Close()

    buffer := make([]byte, 1024)
    n, err := file.Read(buffer)
    if err != nil {
        fmt.Println("读取FIFO失败:", err)
        return
    }
    fmt.Println("从FIFO读取:", string(buffer[:n]))
}

登录后复制

代码解释：

导入必要的包: syscall 用于调用系统调用，os 用于文件操作。
定义FIFO路径: fifoPath 变量指定了FIFO在文件系统中的路径。
检查并删除已存在的FIFO: 为了避免冲突，代码首先检查FIFO是否已经存在，如果存在则删除它。
调用syscall.Mknod: syscall.Mknod 函数用于创建FIFO。
- 第一个参数是FIFO的路径。
- 第二个参数是模式，syscall.S_IFIFO 表示创建一个FIFO，0666 设置了读写权限（所有用户可读写）。
- 第三个参数通常为0，在创建设备文件时才需要指定设备号。
错误处理: 在创建FIFO后，需要检查是否有错误发生。
写入FIFO (goroutine): 开启一个goroutine，用于向FIFO写入数据。使用os.OpenFile以只写模式打开FIFO，写入字符串 "Hello, FIFO!"。
读取FIFO: 使用os.OpenFile以只读模式打开FIFO，并读取数据。

注意事项：

权限: 确保你有足够的权限创建FIFO。如果权限不足，syscall.Mknod 可能会返回错误。
阻塞: 当一个进程尝试从一个空的FIFO读取数据时，它会阻塞，直到有数据写入。同样，当一个进程尝试向一个满的FIFO写入数据时，它也会阻塞，直到有空间可用。
错误处理: 始终检查函数调用返回的错误，并进行适当的处理。
清理: 程序退出前，应该删除创建的FIFO，以避免资源浪费。可以使用 os.Remove(fifoPath) 删除。
并发: 多个进程同时读写同一个FIFO时，需要进行适当的同步，以避免数据竞争。可以使用锁或其他同步机制。
文件模式: os.ModeNamedPipe 用于OpenFile函数，显式地表明要操作的是命名管道。