Python编程中的zmqDEALER多线程处理示例

在Python编程中，zmq.DEALER模式是一种多线程处理模式，它允许多个线程同时处理消息。下面是一个使用zmq.DEALER模式的示例代码：

import zmq
import time
from threading import Thread

def worker_handler(worker_id):
    context = zmq.Context()
    worker = context.socket(zmq.DEALER)
    worker.setsockopt(zmq.IDENTITY, str(worker_id).encode())
    worker.connect("tcp://localhost:5555")

    while True:
        # 接收消息
        message = worker.recv()
        print("Worker {}: received message {}".format(worker_id, message))
        
        # 模拟工作过程
        time.sleep(1)
        
        # 发送响应
        response = "Response from worker {}".format(worker_id)
        worker.send(response.encode())

def main():
    # 创建上下文和套接字
    context = zmq.Context()
    router = context.socket(zmq.ROUTER)
    router.bind("tcp://*:5555")

    # 创建4个工作线程
    for worker_id in range(4):
        thread = Thread(target=worker_handler, args=(worker_id,))
        thread.start()

    # 主线程处理消息
    while True:
        # 接收消息
        identity, message = router.recv_multipart()
        print("Received message: {}".format(message))
        
        # 发送消息给工作线程
        router.send_multipart([identity, b'', message])

        # 等待响应
        response = router.recv()
        print("Received response: {}".format(response))
        
        # 发送响应给请求者
        router.send_multipart([identity, b'', response])

if __name__ == "__main__":
    main()

上述代码中，我们首先创建一个ROUTER套接字并绑定到本地5555端口。然后创建四个工作线程，每个线程都会使用DEALER模式连接到ROUTER套接字。在主线程中，我们可以接收来自客户端的消息，并将其发送给工作线程进行处理。工作线程会接收消息，并在收到消息后发送一个响应。主线程再次接收这个响应，并将其发送给客户端。

为了测试这个示例，你可以运行多个客户端来模拟并发请求的情况。下面是一个简单的客户端代码示例：

import zmq

def main():
    context = zmq.Context()
    socket = context.socket(zmq.DEALER)
    socket.connect("tcp://localhost:5555")

    for request in range(5):
        # 发送请求
        message = "Request {}".format(request)
        socket.send(message.encode())
        
        # 接收响应
        response = socket.recv()
        print("Received response: {}".format(response))

if __name__ == "__main__":
    main()

在上述客户端代码中，我们创建一个DEALER套接字并连接到服务器的5555端口。然后我们循环发送5个请求，并打印响应。

你可以在一个终端窗口中运行主机代码，然后在另一个或多个终端窗口中运行客户端代码来模拟多个客户端发送请求并接收响应的场景。