使用pyzmq的异步ioloop

Question

我想用zmq套接字创建一个tcp服务器。下面的代码使用python的异步ioloop使用zmq套接字创建tcp服务器。

在下面的代码中，我创建了zmq套接字来侦听传入的连接。coroutine recv_and_process创建一个套接字来侦听连接，并有一个while循环来响应传入的连接。

我的问题是如何消除while循环，而使用存在的asyncio event loop？

import asyncio
import zmq
import zmq.asyncio

zmq.asyncio.install()
ctx = zmq.asyncio.Context()

@asyncio.coroutine
def recv_and_process():
    sock = ctx.socket(zmq.PULL)
    sock.bind('tcp://127.0.0.1:8888')
    while True:
        msg = yield from sock.recv_multipart() # waits for msg to be ready
        print(msg)

if __name__ == '__main__':

    loop = asyncio.get_event_loop()
    loop.run_until_complete(recv_and_process())

Answer 1

我不确定我是否理解您想要的内容，但是这里有一些想法:当我们说“异步事件循环”时，我们指的是在脚本中执行协同的全局对象。您已经通过运行事件循环来使用这个事件循环，直到coroutine recv_and_process用loop.run_until_complete(recv_and_process())行完成为止。

运行异步事件循环来执行协同并不意味着您的程序不应该有普通的while循环语句。循环可以和以往一样用于相同的目的--例如，重复地做一些事情，包括等待某种协同作用，就像在您的情况下一样。