直接调用 aiohttp.clientsession() 会报“event loop is closed”,因 session 创建依赖当前运行的事件循环,若在 async def 外使用、函数返回后 loop 已关闭,或跨线程/跨生命周期复用 session,均导致 runtimeerror;正确做法是始终用 async with aiohttp.clientsession() 确保自动创建与清理,且所有异步操作须包裹于同一 asyncio.run() 或 runner 生命周期内。

为什么直接用 aiohttp.ClientSession() 会报 “event loop is closed”?
常见于在 async def 外调用 session.get(),或在函数返回后手动调用 loop.close()。Python 3.11 默认使用 asyncio.Runner,不再推荐手动管理 event loop。正确做法是:所有异步操作必须包裹在同一个 asyncio.run() 或 asyncio.Runner 生命周期内,ClientSession 必须在其作用域内创建和关闭。
实操建议:
- 用
async with aiohttp.ClientSession() as session:确保自动清理,不要在with外保存session引用 - 避免在
__aexit__已触发后还试图 awaitsession.get() - 若需复用 session(如多个并发任务),把 session 作为参数传入协程,而非全局变量或类属性(否则容易跨 loop 使用)
如何控制并发数防止被封或压垮目标服务器?
aiohttp 本身不带内置并发限流,靠 asyncio.Semaphore 实现最轻量、最可控的并发控制。它比 asyncio.wait_for() 或队列更直接,且不会因超时中断导致连接泄漏。
实操建议:
- 初始化一个
sem = asyncio.Semaphore(10)(例如限制 10 路并发) - 每个请求前加
async with sem:,确保同时最多只有 10 个session.get()在执行 - 不要把
sem放在循环外但 await 放在循环内——必须保证async with包裹整个请求+响应处理过程 - 配合
headers={'User-Agent': 'Mozilla/5.0'}和随机 delay(await asyncio.sleep(random.uniform(0.5, 2)))效果更稳
解析 HTML 时为什么 response.text() 比 response.read() 更安全?
response.read() 返回 bytes,需手动 decode;而 response.text() 自动根据响应头的 Content-Type(如 charset=utf-8)或 meta 标签推断编码,避免乱码或 UnicodeDecodeError。Python 3.11 中部分网站响应头缺失 charset,text() 内部会 fallback 到 utf-8 并容错处理。
实操建议:
- 优先用
await response.text(),除非你明确需要二进制内容(如下载图片) - 若必须用
read(),请显式指定编码:(await response.read()).decode('utf-8', errors='ignore') - 对中文站点,避免依赖
chardet做二次检测——它同步阻塞 event loop,应提前用response.charset或响应头判断
遇到 ClientConnectorError 或 ServerDisconnectedError 怎么重试?
这些错误在高并发下极常见,源于 DNS 解析失败、连接池耗尽、服务端主动断连等。aiohttp 不提供开箱即用的重试机制,需手动实现简单指数退避。
实操建议:
- 用
try/except包裹单次请求,捕获aiohttp.ClientError(基类,覆盖多数网络异常) - 重试逻辑写在协程内部,每次 retry 前
await asyncio.sleep(2 ** attempt)(如第 1 次等 1s,第 2 次等 2s,第 3 次等 4s) - 限制最大重试次数(如 3 次),避免雪崩;超过则返回
None或抛出自定义异常 - 注意:不要在重试中重复创建
ClientSession,session 应复用,否则连接池失效
真正容易被忽略的是 session 的生命周期和 DNS 缓存行为——Python 3.11 的 aiohttp.TCPConnector 默认启用 DNS 缓存,但若目标域名 IP 频繁变更(如 CDN 轮转),需显式设置 force_close=True 或 use_dns_cache=False,否则可能持续请求旧 IP 导致超时。
Python免费学习笔记(深入):立即使用
在学习笔记中,你将探索 Python 的核心概念和高级技巧!











