python实现zmq的发布订阅模式代码
时间: 2023-07-23 17:15:36 浏览: 190
zmq 发布,订阅模式 , DEOM
好的。使用 Python 实现 ZeroMQ 发布-订阅模式的代码如下:
```python
import zmq
# 创建 ZeroMQ 上下文
context = zmq.Context()
# 创建订阅者
subscriber = context.socket(zmq.SUB)
subscriber.connect("tcp://localhost:5555")
subscriber.setsockopt(zmq.SUBSCRIBE, b"")
# 接收消息
while True:
message = subscriber.recv()
print("Received message: %s" % message.decode("utf-8"))
```
其中,`subscriber.connect("tcp://localhost:5555")`表示连接到地址为 `localhost:5555` 的 ZeroMQ 服务器。`subscriber.setsockopt(zmq.SUBSCRIBE, b"")`表示订阅所有消息。`subscriber.recv()`表示等待接收消息,程序将在此处阻塞,直到接收到消息。
阅读全文