【问题标题】:async server code in python wont work when using asyncio.start_server使用 asyncio.start_server 时,python 中的异步服务器代码不起作用
【发布时间】:2025-12-12 19:20:04
【问题描述】:

这是异步 python,但是当我向它发送请求并使用 time.sleep(5) 进行并行测试时不起作用,但它是顺序的并且请求顺序执行:

def main(*args):    
    loop = get_event_loop()

    coro = asyncio.start_server(handle_echo, '127.0.0.1', 50008,loop=loop)
    srv = loop.run_until_complete(coro)   
def handle_echo(reader, writer):
    data = yield from reader.read(500)
    message = data.decode(encoding='utf-8')            

    nameindex=('name="calculator2"' in message)
    if nameindex:
        time.sleep(5)
        writer.write("Content-Length: 1\r\n\r\n2".encode())
        yield from writer.drain()
    else:
        writer.write("Content-Length: 1\r\n\r\n1".encode())
        yield from writer.drain()

    print("Close the client socket")
    writer.close()

【问题讨论】:

  • @udi 这是我的新代码
  • 不要在协程中使用time.sleep,而是使用asyncio.sleep
  • @uid 好的,我会测试它并通知你。 Tnx

标签: python asynchronous python-asyncio coroutine parallels


【解决方案1】:

替换:

time.sleep(5)

与:

await asyncio.sleep(5)

【讨论】:

  • 谢谢。我用这段代码做到了,它成功了:yield from asyncio.sleep(5)
  • await 在 python 3.5 中-我为我的项目使用 python 3.4,我像以前的评论一样这样做