ZMQ_STREAM客户端代码
时间: 2023-07-03 16:21:41 浏览: 148
C语言ZMQ server端代码
以下是一个简单的 ZMQ_STREAM 的 Python 客户端代码示例:
```python
import zmq
ctx = zmq.Context()
socket = ctx.socket(zmq.STREAM)
# 连接到服务器
socket.connect("tcp://localhost:5555")
# 发送请求
identity = b"CLIENT"
request = b"请求数据"
socket.send_multipart([identity, request])
# 等待响应
response = socket.recv_multipart()[1]
# 处理响应
print(response.decode())
```
在这个示例中,我们使用 `zmq.STREAM` 创建了一个 ZMQ_STREAM 类型的 Socket,并将其连接到本地地址的 5555 端口。然后,我们使用 `socket.send_multipart` 方法发送一个带有身份标识和请求数据的多部分消息。接下来,我们使用 `socket.recv_multipart` 方法等待服务器的响应,并从响应中提取出实际数据。最后,我们对响应进行处理并打印出来。
需要注意的是,在使用 ZMQ_STREAM 时,客户端和服务器都需要手动处理身份标识。在上面的示例中,我们使用 `b"CLIENT"` 作为客户端的身份标识,并将其与请求一起发送给服务器。
阅读全文