zmq通讯

zmq是一个高性能的消息传递库，它提供了多种消息传递模式，如请求-应答、发布-订阅、管道等模式，可以用于构建分布式系统中的通信机制。zmq使用的是套接字(socket)概念，但是它对传统socket进行了封装，提供了更高层和更简洁的API，使得开发者可以更加专注于业务逻辑。

在zmq中，有两个重要的概念：socket和上下文(context)。socket是zmq中的通信端点，负责发送和接收消息；而上下文则是zmq的全局环境，负责管理socket和线程等资源。

zmq的通信模式有很多种，其中最常用的是请求-应答模式。在这种模式下，客户端和服务端各自创建一个socket，并分别绑定到不同的地址上。客户端通过发送请求消息到服务端，并等待服务端的响应；而服务端则接收请求消息，并根据请求内容返回相应的响应消息。

下面是一个简单的zmq请求-应答示例代码：

服务端：

import zmq

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

while True:
    # 等待接收客户端的请求
    message = socket.recv()
    print("Received request: %s" % message)

    # 处理客户端请求
    response = b"Hello, World!"
    socket.send(response)

客户端：

import zmq

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

# 发送请求
socket.send(b"Hello")

# 等待接收服务端的响应
response = socket.recv()
print("Received response: %s" % response)

在这个示例中，服务端绑定到了地址"tcp://*:5555"，表示监听所有可用的IP地址和端口5555；而客户端则连接到了地址"tcp://localhost:5555"，表示连接到本机地址和端口5555。客户端发送请求时，使用socket.send()方法发送一个字节串消息；服务端接收请求时，使用socket.recv()方法接收消息。服务端处理请求后，使用socket.send()方法发送响应消息；客户端接收响应时，使用socket.recv()方法接收消息。