python zmq广播发送
时间: 2023-07-11 09:58:22 浏览: 148
广播发送消息
4星 · 用户满意度95%
你可以使用 ZeroMQ 中的 PUB-SUB 模式来实现广播发送。在该模式下,你需要创建一个 Publisher(发布者)和多个 Subscriber(订阅者)来实现广播发送。以下是一个 Python 代码示例:
Publisher:
```python
import zmq
context = zmq.Context()
socket = context.socket(zmq.PUB)
socket.bind("tcp://*:5555")
while True:
message = input("Enter message to publish: ")
socket.send_string(message)
```
Subscriber:
```python
import zmq
context = zmq.Context()
socket = context.socket(zmq.SUB)
socket.connect("tcp://localhost:5555")
socket.setsockopt(zmq.SUBSCRIBE, b"")
while True:
message = socket.recv_string()
print("Received: ", message)
```
在上面的示例中,Publisher 绑定了一个 TCP 地址,然后等待用户输入要发送的消息。一旦有消息,它将使用 `socket.send_string()` 方法将其发送到所有已连接的 Subscriber。
Subscriber 连接到 Publisher,使用 `socket.setsockopt(zmq.SUBSCRIBE, b"")` 方法来订阅所有消息。一旦有消息,它将使用 `socket.recv_string()` 方法接收并打印出来。
你可以运行多个 Subscriber 实例来测试广播发送。
阅读全文