我正在使用 asyncio.Protocol
服务器,其目的是让客户端调用服务器,但 wait 直到服务器响应并在停止客户端循环之前返回数据 .
基于asyncio doc Echo Client和Server:https://docs.python.org/3/library/asyncio-protocol.html#protocol-example-tcp-echo-server-and-client,在调用时立即返回transport.write(...)的结果 .
通过经验,调用 loop.run_until_complete(coroutine)
失败 RuntimeError: Event loop is running.
在服务器的 data_received()
方法中运行 asyncio.sleep(n)
也没有任何效果 .
yield from asyncio.sleep(n)
中的 yield from asyncio.sleep(n)
和 yield from asyncio.async(asyncio.sleep(n))
都挂起服务器 .
我的问题是,如何让我的客户端在返回控制权之前等待服务器编写响应?
2 回答
我想永远不要直接使用传输/协议对 .
asyncio具有用于高级编程的Streams API .
客户端代码可能如下所示:
您不必更改客户端代码 .
echo-client.py
诀窍是将代码(包括self.transport方法)放入协程并使用
wait_for()
方法,在需要返回值的语句前面加上yield from
语句,或者需要一段时间才能完成的语句:echo-server.py
调用
echo-server.py
然后echo-client.py
,客户端将等待2秒,由asyncio.sleep
确定,然后停止 .