python - ZeroMQ 轮询器 vs Tornados EventLoop

Question

在设计和性能方面推荐哪种方法来处理多个 Zeromq 套接字，为什么？

ZeroMQ 使用的 Tornado 的 IOLoop 占用的 CPU 比 while 循环中用于处理多个套接字的 Poller 占用的 CPU 少，这是真的吗？

Answer 1

如果您将自己的观察/分析添加到您的问题中，那就太好了。

我认为在性能上没有任何差异，但在设计上存在差异。

在轮询的情况下

您注册要轮询的套接字，然后使用 if blocks 来识别和使用每个套接字。

while should_continue:
        socks = dict(poller.poll())
        if socket_pull in socks and socks[socket_pull] == zmq.POLLIN:
            Work_on_socket_pull ....

        if socket_sub in socks and socks[socket_sub] == zmq.POLLIN:
             Work_on_socket_sub ....

在事件循环的情况下但是当你处理多个套接字时使用事件循环是非常优雅的，因为你register callbacks。

stream_pull = zmqstream.ZMQStream(socket_pull)
stream_pull.on_recv(getcommand)

stream_sub = zmqstream.ZMQStream(socket_sub)
stream_sub.on_recv(process_message)

您可以从第二个示例中注意到，if block 已被删除。您在其他地方编写套接字消息传递操作，并在套接字准备就绪时注册回调方法。 在这种情况下 on_recv()

我希望这能澄清您的问题。