aiohttp异步编程核心是避免阻塞、提升并发,需区分客户端(复用ClientSession、显式读响应)和服务端(web.Application、async handler),并注意await、禁用同步操作、异常处理及事件循环启动方式。

使用 aiohttp 进行异步网络编程,核心是避免阻塞、提升并发效率,关键在于正确区分客户端与服务端用法,并始终配合 async/await 使用事件循环。
客户端请求:用 ClientSession 复用连接
不要每次请求都新建 session,否则失去连接复用和 cookie 管理优势。推荐在异步上下文中创建一次 session,批量发起请求:
- 用
async with aiohttp.ClientSession() as session:确保自动关闭连接和清理资源 - GET/POST 请求统一用
session.get(url)或session.post(url, json=...) - 响应体需显式读取:
await resp.text()、await resp.json()或await resp.read(),不能直接访问resp.content
服务端开发:用 web.Application 定义路由和中间件
aiohttp.web 是轻量级异步 Web 框架,适合构建 API 或微服务:
- 每个处理器必须是
async def函数,接收request: web.Request,返回web.Response - 路径参数通过
request.match_info.get('name')获取;查询参数用request.query.get('key') - 静态文件可挂载:
app.router.add_static('/static/', path='static/', name='static')
常见陷阱与应对
新手容易踩坑的地方集中在生命周期和错误处理:
立即学习“Python免费学习笔记(深入)”;
- 忘记
await:所有session.*()和resp.*()方法都是协程,不 await 会返回 coroutine 对象而非结果 - 同步操作混入异步流程:如在 handler 中调用
time.sleep()或requests.get(),会阻塞整个事件循环 - 未捕获异常导致连接中断:建议在客户端加
try/except aiohttp.ClientError,服务端用中间件统一处理web.HTTPException
运行方式:显式启动事件循环
不同于 Flask 的简单 app.run(),aiohttp.web 需手动调用 web.run_app(app),它会自动创建并运行事件循环:
- 开发时直接
web.run_app(app, host='localhost', port=8080) - 生产环境建议搭配
gunicorn(需使用aiohttp.GunicornWebWorker)或uvloop提升性能 - 若需嵌入已有事件循环(如 Jupyter 或其他 async 库),改用
app._run_app()或手动调用loop.create_task(web._run_app(...))











