如何使用zmq进行通行
时间: 2024-02-21 18:33:32 浏览: 84
Qt网络编程-ZMQ的使用
zmq 是一个高效的消息传递库,使用它可以轻松地实现进程间通信。下面是一个简单的示例,演示了如何使用 zmq 进行通信:
首先,安装 zmq 库:
```
pip install pyzmq
```
然后,编写服务端代码,监听来自客户端的消息:
```python
import zmq
context = zmq.Context()
socket = context.socket(zmq.REP)
socket.bind("tcp://*:5555")
while True:
# 等待客户端消息
message = socket.recv()
print("Received request: %s" % message)
# 发送响应消息给客户端
socket.send(b"World")
```
接下来,编写客户端代码,向服务端发送消息并接收响应:
```python
import zmq
context = zmq.Context()
socket = context.socket(zmq.REQ)
socket.connect("tcp://localhost:5555")
# 发送消息给服务端
socket.send(b"Hello")
# 等待服务端响应
message = socket.recv()
print("Received reply: %s" % message)
```
在上面的示例中,服务端使用 `zmq.REP` socket 监听客户端消息,而客户端使用 `zmq.REQ` socket 发送消息给服务端。`tcp://localhost:5555` 是服务端的地址,客户端使用 `socket.connect` 连接到服务端。服务端接收到消息后,打印消息内容并使用 `socket.send` 发送响应消息给客户端。客户端使用 `socket.recv` 等待服务端的响应。
这只是一个简单的示例,zmq 还有很多高级功能,可以根据需求进行配置。
阅读全文