如何在Python中创建和使用命名管道？

---

考虑一个管道，它允许在复杂系统的各个组件之间实现无缝的数据流和通信。命名管道类似于 Python 编程中的管道，使程序更容易彼此通信以及与其他进程通信。命名管道，也称为 FIFO（先进先出），是交换同一系统上或甚至系统之间进程之间数据的一种强大方法。在本文中，我们将深入 Python，学习如何创建和使用命名管道。我们将逐步分解创建命名管道的过程，通过它写入和读取数据，甚至展示高级场景。因此，让我们探索命名管道的世界，并发现它们的潜力！

理解命名管道是什么

命名管道是存在于 Python 文件系统中的特殊文件，其作用类似于传统管道。与仅限于父进程和子进程之间通信的匿名管道相反，命名管道超越了进程边界。因此，命名管道可用于在彼此无关的进程之间进行通信，使其成为一项宝贵的工具。

命名管道类似于文件，但它不存储任何内容。它只有一个路径。它可以打开、读取和写入，但内容临时存储在系统内存中。它的行为与普通文件略有不同。当它被打开时，它可以以只读或只写方式打开，而不能同时以读写方式打开。其理念是，您将有一个进程以写入方式打开它（服务器），另一个进程以读取方式打开它（客户端）。

如何创建命名管道？

要在 Python 中创建命名管道，我们使用 os 模块。让我们首先导入它。

import os

然后，我们为命名管道声明路径和名称。

pipe_path = "/path/to/named_pipe"

我们使用 os 模块的 mkfifo() 函数创建命名管道。

示例

使用此代码已成功在指定路径创建了一个命名管道。需要注意的是，命名管道只能被具有适当权限的进程访问。

os.mkfifo(pipe_path)

使用已知管道写入

让我们找到一种方法，如何在已构建的命名管道中插入数据。在此示例中，我们将使用 open() 函数以写入模式打开命名管道并将数据写入其中。

示例

通过以写入模式打开命名管道，我们还可以使用 write() 方法通过它发送数据。在此示例中，我们看到字符串“Hello, named pipe！”被写入。

with open(pipe_path, "w") as pipe:
   pipe.write("Hello, named pipe!")

从命名管道读取

为了从命名管道读取数据，我们以读取模式打开命名管道并使用 read() 或 readline() 方法。

示例

在此特定示例中，我们在以读取模式打开命名管道后使用 read() 方法获取数据。然后将数据打印到控制台。

with open(pipe_path, "r") as pipe:

   data = pipe.read()
   print(data)

清理命名管道

在完成命名管道的操作后，我们需要将其清理并从文件系统中删除。这可以通过 os.remove() 函数来实现。

示例

例如，我们通过调用 os.remove() 函数并提供其路径来从文件系统中删除命名管道。这确保了干净的退出并防止资源泄漏。

os.remove(pipe_path)

首先，我们导入 os 和 posix 模块并指定命名管道的路径和名称。之后，我们实现一个 try-except 块来处理创建命名管道过程中可能出现的任何异常。在 try 块中，posix.mkfifo() 函数用于在指定路径创建命名管道。我们显示一条消息，指示命名管道已成功生成。如果命名管道已存在，我们会通知用户。如果发生其他错误，我们会捕获错误并显示相应的错误消息。

import os
import posix

pipe_path = "/content/named_pipe"

try:
   posix.mkfifo(pipe_path)
   print("Named pipe created successfully!")
except FileExistsError:
   print("Named pipe already exists!")
except OSError as e:
   print(f"Named pipe creation failed: {e}")

在此特定情况下，输出为

Named pipe already exists!

示例

在此示例中，我们导入 os 模块并声明命名管道的路径和名称。然后，我们使用 try-except 块来处理从命名管道读取数据期间可能出现的异常情况。在 try 块中，我们使用 open() 方法以读取模式打开命名管道后，使用 read() 方法读取数据。我们将数据存储在 data 变量中后，将其显示到控制台。如果没有名为命名管道的文件，我们将捕获 FileNotFoundError 并通知用户。我们捕获任何其他错误并显示相应的错误消息。

import os

# Specify the path and name of the named pipe
pipe_path = "/path/to/named_pipe"

# Read data from the named pipe
try:
   with open(pipe_path, "r") as pipe:
      data = pipe.read()
   print(f"Read data from named pipe: {data}")
except FileNotFoundError:
   print("Named pipe does not exist!")
except OSError as e:
   print(f"Failed to read data from named pipe: {e}")

输出

在一个特定情况下，输出可能是

Named pipe does not exist!

在这篇关于命名管道的有趣的 Python 文章中，您学习了如何在 Python 中创建、写入和读取命名管道中的数据。命名管道充当进程间通信的强大中介或代理，并允许不同的进程无缝交换数据。通过提供的代码示例，您现在全面了解了如何在 Python 中创建和使用命名管道。

现在，您拥有了一个多功能工具，可以构建复杂的系统、协调进程并在 Python 项目中解锁新的可能性，从而能够创建和使用命名管道。因此，继续前进，探索有关命名管道（包括 Python 程序之间高效通信）的不同可能性。