Python 异步 http 服务器

Question

我尝试使用以下代码构建一个基本的 http 服务器。

async def handle_client(client, address):
    print('connection start')
    data = await loop.sock_recv(client, 1024)
    resp = b'HTTP/1.1 404 NOT FOUND\r\n\r\n<h1>404 NOT FOUND</h1>'
    await loop.sock_sendall(client, resp)
    client.close()

async def run_server():
    while True:
        client, address = await loop.sock_accept(server)
        print('start')
        loop.create_task(handle_client(client,address))
        print(client)

server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server.bind(('localhost', 3006))
server.listen(8)
print(1)
loop = asyncio.get_event_loop()
loop.run_until_complete(run_server())

我期望得到的输出是

1
start
connection start

但是运行ning的实际结果是

1
start
start
start

好像loop.create_task()里的函数不是运行，所以我现在很困惑，loop.create_task()的正确使用方法是什么？

Answer 1

您需要等待通过 loop.create_task() 创建的任务，否则 run_server() 将安排任务，然后在返回结果之前退出。

尝试将 run_server() 更改为以下内容：

async def run_server():
    while True:
        client, address = await loop.sock_accept(server)
        print('start')
        await loop.create_task(handle_client(client,address))
        print(client)

Python 异步 http 服务器

Python asyncio http server

python

sockets

asynchronous

async-await