Python 的多处理库如何简化进程间通信？

Python 中的进程间通信

进程间通信 (IPC) 支持多个正在运行的 Python 进程之间的通信。探索各种选项（例如使用命名管道、dbus 服务和套接字）可能具有挑战性。本文介绍了使用多处理库的更高级别且强大的解决方案。

使用多处理库

多处理库提供了一种在 Python 中实现 IPC 的便捷高效的方法。它提供了封装套接字的监听器和客户端，允许您直接交换 Python 对象。

监听消息

要创建监听进程，请使用 Listener 类：

<code class="python">from multiprocessing.connection import Listener

address = ('localhost', 6000)
listener = Listener(address, authkey=b'secret password')
conn = listener.accept()
print('connection accepted from', listener.last_accepted)</code>

侦听器等待指定的 IP 地址和端口传入连接。建立连接后，将返回 Connection 对象 (conn)。

发送消息

要将消息作为 Python 对象发送，请使用 Client 类：

<code class="python">from multiprocessing.connection import Client

address = ('localhost', 6000)
conn = Client(address, authkey=b'secret password')
conn.send('close')
conn.close()</code>

Client 类连接到指定的地址，并且可以向侦听进程发送任意对象。

示例实现

考虑一个简单的用例，其中一个进程 (listener.py) 侦听消息，并且other (client.py) 发送消息。

listener.py:

<code class="python">from multiprocessing.connection import Listener

listener = Listener(('localhost', 6000), authkey=b'secret password')
conn = listener.accept()

message = conn.recv()
if message == 'close':
    conn.close()
    listener.close()
    exit(0)
else:
    conn.close()
    listener.close()
    exit(1)</code>

client.py:

<code class="python">from multiprocessing.connection import Client

conn = Client(('localhost', 6000), authkey=b'secret password')
conn.send('close')
conn.close()</code>

当你运行listener.py，然后运行client.py时，监听进程会收到消息并退出，返回码0，表示成功。如果发送无效消息，侦听器将退出并返回非零返回码，表示失败。

此示例演示了在 Python 中使用多处理库进行进程间通信的简便性和灵活性。它提供了对套接字的更高级别的抽象，允许您在进程之间无缝发送和接收 Python 对象。

以上是Python 的多处理库如何简化进程间通信？的详细内容。更多信息请关注PHP中文网其他相关文章！