Python中使用ZMQPUB模式进行消息通信的实例

使用 ZMQPUB 模式进行消息通信是一种非常高效和灵活的方法，并且在 Python 中使用 ZeroMQ 库可以轻松地实现。下面是一个简单的示例，演示了如何在 Python 中使用 ZMQPUB 进行发布者-订阅者通信。这个示例包括两个脚本：一个是发布者，另一个是订阅者。

发布者脚本：

import zmq

context = zmq.Context()
socket = context.socket(zmq.PUB)
socket.bind("tcp://*:5555")

while True:
    message = input("Enter a message to publish: ")
    socket.send_string(message)

在这个脚本中，我们首先创建了一个 ZeroMQ 上下文和一个 ZMQPUB 套接字。然后，我们将套接字绑定到一个特定的端口（在这个例子中是5555）。接下来，我们进入一个无限循环，以便持续地发送消息。

订阅者脚本：

import zmq

context = zmq.Context()
socket = context.socket(zmq.SUB)
socket.connect("tcp://localhost:5555")
socket.setsockopt_string(zmq.SUBSCRIBE, "")

while True:
    message = socket.recv()
    print("Received message: %s" % message.decode("utf-8"))

在这个脚本中，我们同样创建了一个 ZeroMQ 上下文和一个 ZMQSUB 套接字。然后，我们将套接字连接到发布者的绑定端口，并使用 setsockopt_string() 方法订阅所有消息。接下来，我们进入一个无限循环来接收和打印接收到的消息。

要运行这个示例，你需要在两个不同的终端窗口中分别运行发布者和订阅者脚本。当你在发布者窗口中输入一条消息时，订阅者窗口将立即接收和打印该消息。

这是一个非常简单的示例，但它演示了如何使用 ZMQPUB 模式在 Python 中进行消息通信。你可以根据自己的需求扩展和修改这个示例，以便实现更加复杂和灵活的通信模式。