17370845950

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')

常见陷阱与应对

新手容易踩坑的地方集中在生命周期和错误处理：

• 忘记 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(...))