zeromq的发布订阅模式

ZeroMQ 的发布订阅模式（Publish-Subscribe）是一种常用的消息传递模式，适用于需要发布和订阅消息的场景，例如多人聊天室、订阅新闻、实时数据传输等。

在发布订阅模式中，消息发布者（Publisher）将消息发送到一个或多个主题（Topic），消息订阅者（Subscriber）可以根据自己的需求订阅感兴趣的主题，从而接收到相应的消息。发布订阅模式支持一对多和多对多的消息传递，可以实现广播、多播等功能。

具体实现时，可以使用 ZeroMQ 的 PUB-SUB 套接字组合来实现发布订阅模式。消息发布者使用 PUB 套接字将消息发送到指定的主题，消息订阅者使用 SUB 套接字订阅感兴趣的主题，并接收相应的消息。需要注意的是，订阅者必须在发布者发送消息之前订阅相应的主题，否则无法接收到消息。

以下是使用 ZeroMQ 实现发布订阅模式的示例代码：

Publisher:

import zmq

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

while True:
    topic = input("Enter topic: ")
    message = input("Enter message: ")
    socket.send_string(f"{topic} {message}")

Subscriber:

import zmq

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

topic_filter = input("Enter topic filter: ")
socket.setsockopt_string(zmq.SUBSCRIBE, topic_filter)

while True:
    message = socket.recv_string()
    topic, content = message.split(' ', 1)
    print(f"[{topic}] {content}")

在这个示例中，消息发布者通过 PUB 套接字将消息发送到指定的主题，消息订阅者通过 SUB 套接字订阅感兴趣的主题，并接收相应的消息。需要注意的是，订阅者必须在发布者发送消息之前订阅相应的主题，否则无法接收到消息。