Python3 os.mkfifo() 方法（手把手讲解）

💡一则或许对你有用的小广告

欢迎加入小哈的星球 ，你将获得：专属的项目实战(已更新的所有项目都能学习) / 1v1 提问 / Java 学习路线 / 学习打卡 / 每月赠书 / 社群讨论

• 新开坑项目:《Spring AI 项目实战》 正在持续爆肝中，基于 Spring AI + Spring Boot 3.x + JDK 21...， 点击查看 ;
• 《从零手撸：仿小红书（微服务架构）》 已完结，基于 Spring Cloud Alibaba + Spring Boot 3.x + JDK 17...，点击查看项目介绍 ;演示链接： http://116.62.199.48:7070 ;
• 《从零手撸：前后端分离博客项目（全栈开发）》 2 期已完结，演示链接： http://116.62.199.48/ ;

截止目前， 星球 内专栏累计输出 90w+ 字，讲解图 3441+ 张，还在持续爆肝中.. 后续还会上新更多项目，目标是将 Java 领域典型的项目都整一波，如秒杀系统, 在线商城, IM 即时通讯，权限管理，Spring Cloud Alibaba 微服务等等，已有 3100+ 小伙伴加入学习 ，欢迎点击围观

在 Python 开发中，进程间通信（IPC）是一个核心且复杂的主题。随着项目规模的扩大，开发者常常需要让多个进程安全高效地交换数据。此时，Python3 os.mkfifo() 方法便成为一种轻量级且灵活的解决方案。本文将从基础概念讲起，逐步深入其语法细节、使用场景及实际案例，帮助编程初学者和中级开发者掌握这一工具，并理解其在现代软件架构中的应用价值。

一、什么是命名管道（FIFO）？

命名管道（FIFO）是一种特殊的文件类型，它允许不同进程通过共享路径进行数据传输。可以将其想象为一个“虚拟邮筒”：一个进程将数据“放入”管道，另一个进程则从同一路径“取出”数据。这种机制确保了进程间通信的有序性和可靠性，且无需依赖复杂的网络协议或内存共享技术。

在 Unix/Linux 系统中，命名管道通过 mkfifo 系统调用创建，而 Python 的 os 模块则封装了这一功能，使其能直接在 Python 脚本中调用。

二、os.mkfifo() 方法的语法解析

os.mkfifo() 是 Python 标准库 os 模块中的一个函数，用于创建命名管道。其语法如下：

os.mkfifo(path, mode=0o666)  

参数说明

关键点解析

1. 路径选择：命名管道的路径需要确保可写入且唯一。例如，/tmp/my_fifo 是一个常见且安全的路径。
2. 权限控制：mode 参数遵循 Unix 文件权限规则。例如，0o600 表示仅所有者可读写，其他用户无权限。

三、命名管道的工作原理与特点

1. 工作流程比喻

想象两个人通过一面墙传递信息：

• 一个人在墙的一侧开一个“窗口”（创建 FIFO 文件），
• 另一个人通过同一窗口发送或接收消息。

命名管道的通信流程类似：

• 创建阶段：调用 os.mkfifo() 在文件系统中生成一个 FIFO 文件。
• 通信阶段：
  • 一个进程以写模式打开该文件，向管道中写入数据。
  • 另一个进程以读模式打开同一文件，从中读取数据。

2. 核心特点

• 无状态通信：管道本身不存储数据，仅作为进程间数据流动的通道。
• 阻塞行为：
  • 若读取端未准备好，写入操作会阻塞，直到有进程开始读取。
  • 反之，若写入端未准备好，读取操作也会阻塞。

四、os.mkfifo() 的典型应用场景

命名管道适用于以下场景：

1. 简单进程间通信：当两个进程需要共享少量数据时，无需复杂的队列或数据库支持。
2. 脚本自动化：在 shell 脚本或 Python 脚本中，快速实现进程间数据传递。
3. 监控系统：例如，父进程通过管道向子进程发送控制指令（如停止、重启）。

五、实战案例：用 os.mkfifo() 实现进程通信

案例 1：父进程与子进程通信

步骤说明

1. 父进程创建 FIFO 文件。
2. 父进程启动子进程。
3. 子进程以读模式打开 FIFO，等待接收消息。
4. 父进程向 FIFO 写入数据。

代码示例

import os  
import sys  
from multiprocessing import Process  

def child_process(fifo_path):  
    # 子进程以只读模式打开管道  
    with open(fifo_path, 'r') as fifo:  
        data = fifo.read()  
        print(f"Child received: {data}")  

if __name__ == "__main__":  
    FIFO_PATH = "/tmp/my_fifo"  
    try:  
        # 创建 FIFO  
        os.mkfifo(FIFO_PATH, 0o600)  
        print(f"FIFO created at {FIFO_PATH}")  

        # 启动子进程  
        child = Process(target=child_process, args=(FIFO_PATH,))  
        child.start()  

        # 父进程向管道写入数据  
        with open(FIFO_PATH, 'w') as fifo:  
            fifo.write("Hello from parent!")  

        child.join()  
    finally:  
        # 确保程序退出时删除 FIFO  
        os.remove(FIFO_PATH)  

输出结果

FIFO created at /tmp/my_fifo  
Child received: Hello from parent!  

案例 2：模拟“生产者-消费者”模型

场景描述

• 生产者进程不断生成数据并写入管道。
• 消费者进程持续读取数据并处理。

代码示例

import os  
import time  
from multiprocessing import Process  

FIFO_PATH = "/tmp/producer_consumer_fifo"  

def producer(fifo_path):  
    with open(fifo_path, 'w') as fifo:  
        for i in range(5):  
            message = f"Data {i}"  
            fifo.write(message + "\n")  
            print(f"Produced: {message}")  
            time.sleep(1)  

def consumer(fifo_path):  
    with open(fifo_path, 'r') as fifo:  
        while True:  
            line = fifo.readline().strip()  
            if not line:  
                break  
            print(f"Consumed: {line}")  

if __name__ == "__main__":  
    try:  
        os.mkfifo(FIFO_PATH, 0o666)  
        print(f"FIFO created at {FIFO_PATH}")  

        p = Process(target=producer, args=(FIFO_PATH,))  
        c = Process(target=consumer, args=(FIFO_PATH,))  
        p.start()  
        c.start()  
        p.join()  
        c.join()  # 注意：消费者进程可能因管道关闭而提前终止  
    finally:  
        os.remove(FIFO_PATH)  

注意事项

• 生产者写入完毕后需关闭管道，否则消费者可能因读取阻塞而无法退出。
• 实际应用中可通过信号或特殊标记（如 EOF）通知消费者结束。

六、常见问题与解决方案

1. 文件权限不足

现象：运行脚本时出现 PermissionError。
原因：mode 参数设置不当或路径所在目录权限受限。
解决方法：

• 使用 mode=0o666 并确保父目录可写。
• 手动创建路径或修改目录权限：chmod 755 /tmp。

2. 管道未正确关闭

现象：进程因阻塞无法退出。
解决方法：

• 在写入完成后关闭文件对象（如 fifo.close()）。
• 使用 os.unlink() 删除管道文件，强制结束通信。

3. 跨平台兼容性

问题：命名管道是 Unix 系统特性，Windows 不支持。
解决方案：

• 在代码中添加平台检测：

  if sys.platform.startswith("win"):  
      print("FIFO not supported on Windows!")  
  else:  
      os.mkfifo(...)  
  

七、与类似技术的对比

八、总结与进阶建议

通过本文，读者应已掌握 Python3 os.mkfifo() 方法 的核心概念、语法及实际应用。命名管道是一种高效且易于上手的 IPC 工具，尤其适合中小型项目或脚本开发。

推荐学习方向

1. 深入进程间通信：学习 os.pipe()、multiprocessing.Queue 等 Python 内置工具。
2. 系统级编程：阅读《Advanced Programming in the UNIX Environment》了解底层机制。
3. 实践项目：尝试用命名管道实现日志收集器或简单消息队列系统。

掌握这一方法后，开发者能更灵活地设计分布式或并行程序，提升代码的扩展性和协作能力。