这个异步 aiohttp 代码有什么问题？

Question

对于以下使用 aiohttp 的代码：

async def send(self, msg, url):
    async with aiohttp.ClientSession() as session:
        async with session.post(url, data=msg) as response:
            self._msg = response.read()

async def recv(self):
    return await self._msg

它有效...大部分时间，但偶尔（实际上经常）会导致各种异常 - 通常是响应被截断，或者连接已经关闭异常。

相比之下，下面的效果完美：

async def send(self, msg, url):
    async with aiohttp.ClientSession() as session:
        async with session.post(url, data=msg) as response:
            self._msg = await response.read()

async def recv(self):
    return self._msg

我想知道为什么，因为第二个版本在技术上不适合我的目的，我需要修复它。（这是不正确的，因为在读取响应之前可能会调用 recv 函数）

Answer 1

with 是一个上下文管理器，它在其块内的任何语句之前和之后运行一些代码，通常是簿记。意思是，您的第一个 recv 函数很可能等待引用已经关闭的连接的未来，或者类似的东西。

假设您有一些代码如下所示：

with open(...) as file:
    file.read()

这是它的作用，大致是：

file = open(...)
file.read()
file.close()

这等同于您在第一个示例中所做的事情：

file = open()
file.close()
...
file.read()

这个异步 aiohttp 代码有什么问题？

What's wrong with this async aiohttp code?

python

python-3.x

python-asyncio

aiohttp