python3.5：使用 aiohttp 是否可以同时提供多个响应？

Question

我正在使用最新版本的 aiohttp (1.0.2) 和 python3.5 我有以下服务器代码

import asyncio

from aiohttp.web import Application, Response, StreamResponse, run_app


async def long(request):
    resp = StreamResponse()
    name = request.match_info.get('name', 'Anonymous')
    resp.content_type = 'text/plain'
    for _ in range(1000000):
        answer = ('Hello world\n').encode('utf8')

        await resp.prepare(request)
        resp.write(answer)
    await resp.write_eof()
    return resp


async def init(loop):

    app = Application(loop=loop)
    app.router.add_get('/long', long)
    return app

loop = asyncio.get_event_loop()
app = loop.run_until_complete(init(loop))
run_app(app)

如果我随后在不同的终端运行两个 curl 请求 curl http://localhost:8080/long，则只有第一个会接收数据

我的想法是使用asyncio，您可以在单线程代码中开始提供其他响应，而另一个正在等待 I/O

我在网上找到的大部分关于 concurent+asyncio 的代码只涉及客户端，而不涉及服务器端

我是否遗漏了什么，或者我对 asyncio 工作原理的理解有缺陷？

Answer 1

只需在resp.write() 之后按await resp.drain() 即可让aiohttp 有机会在任务之间切换：

import asyncio

from aiohttp.web import Application, Response, StreamResponse, run_app


async def long(request):
    resp = StreamResponse()
    name = request.match_info.get('name', 'Anonymous')
    resp.content_type = 'text/plain'
    await resp.prepare(request)  # prepare should be called once
    for _ in range(1000000):
        answer = ('Hello world\n').encode('utf8')

        resp.write(answer)
        await resp.drain()  # switch point
    await resp.write_eof()
    return resp


async def init(loop):

    app = Application(loop=loop)
    app.router.add_get('/long', long)
    return app

loop = asyncio.get_event_loop()
app = loop.run_until_complete(init(loop))
run_app(app)