python - 非阻塞 zmq 发送/接收并在收到所有回复时进行处理

Question

我正在使用 python 和 zmq 构建一个简单的客户端服务器应用程序。

目标如下:我希望从客户端同时向多个服务器发送(非阻塞)请求，并在收到所有响应后收到通知以便进行多项计算。

到目前为止，我发现并应用的所有 zmq 示例都在每个请求的 socket.recv 中阻塞，直到收到每个服务器的响应。这意味着我能够将请求发送到多个服务器，但我是以串行方式执行此操作并损失了一些宝贵的时间。

我所做的尝试基于以下几点: https://learning-0mq-with-pyzmq.readthedocs.io/en/latest/pyzmq/patterns/client_server.html

您有关于我的问题的任何 Material /示例吗？

提前非常感谢!

Answer 1

我假设，在您的客户端中，您为每个服务器创建一个 REQ 套接字。 ZeroMQ 指南描述了如何handle multiple sockets并提供了 Python 示例。