【Python】aiohttp库：基于 asyncio 的异步 HTTP 客户端和服务器框架

Python 的 aiohttp 模块是一个基于 asyncio 的异步 HTTP 客户端和服务器框架，用于高效处理并发 Web 请求和构建异步 Web 应用。本文将详细介绍 aiohttp 的定义、安装、核心功能、使用方法、性能、适用场景、注意事项及最佳实践。

1. 什么是 aiohttp？

aiohttp（Asynchronous Input/Output HTTP）是 Python 的一个开源异步 HTTP 框架，构建于 asyncio 库之上，采用 async/await 语法，支持 HTTP 客户端和服务器功能。它由 Nikolay Kim 和 Andrew Svetlov 主导开发，遵循 Apache 2 许可证，托管于 GitHub（aiohttp GitHub）。根据 aiohttp PyPI，最新稳定版本为 3.11.18（2025 年 4 月 21 日发布），要求 Python 3.6 或更高版本。

核心特点：

• 异步处理：利用 asyncio 实现非阻塞 I/O，适合高并发场景。
• 双向功能：支持 HTTP 客户端（发送请求）和服务器（处理请求）。
• 丰富功能：包括 WebSockets、路由、中间件、JSON 处理和流式传输。
• 高性能：研究表明，aiohttp 在并发请求下优于同步库（如 requests）。

2. 安装 aiohttp

2.1 基本安装

通过 pip 安装 aiohttp：

pip install aiohttp

安装后，可验证版本：

python -c "import aiohttp; print(aiohttp.__version__)"

2.2 可选依赖

为优化性能，可安装以下可选包：

• aiodns：加速 DNS 解析：pip install aiodns
• Brotli：支持 Brotli 压缩：pip install aiohttp[speedups]

2.3 注意事项

• 确保 Python 版本为 3.6 或以上，Python 3.12 可能需要特定 wheel 文件。
• 建议在虚拟环境中安装，避免依赖冲突。

3. 核心功能

aiohttp 提供丰富的功能，适用于客户端和服务器场景。以下是主要功能概述：

表 1：aiohttp 核心功能

4. 使用方法与示例

以下是 aiohttp 的客户端和服务器使用示例，展示其异步特性和并发能力。

4.1 客户端用法

客户端使用 aiohttp.ClientSession 发送异步 HTTP 请求，推荐使用上下文管理器（async with）确保资源释放。

GET 请求

import aiohttp
import asyncio

async def main():
async with aiohttp.ClientSession() as session:
async with session.get('http://httpbin.org/get') as response:
print(f'状态码: {response.status}')
print(f'内容: {await response.text()}')

asyncio.run(main())

说明：

• ClientSession 管理连接池，避免频繁创建连接。
• response.text() 是异步方法，需 await。

POST 请求

发送 JSON 数据：

async def main():
async with aiohttp.ClientSession() as session:
async with session.post('http://httpbin.org/post', json={'key': 'value'}) as response:
print(await response.json())
asyncio.run(main())

发送表单数据：

async def main():
async with aiohttp.ClientSession() as session:
async with session.post('http://httpbin.org/post', data={'key': 'value'}) as response:
print(await response.text())
asyncio.run(main())

并发请求

并发处理多个 URL，提高效率：

import aiohttp
import asyncio

async def fetch(url, session):
async with session.get(url) as response:
return await response.text()

async def main():
urls = [
'http://httpbin.org/get',
'http://httpbin.org/user-agent',
'http://httpbin.org/headers'
]
async with aiohttp.ClientSession() as session:
tasks = [fetch(url, session) for url in urls]
results = await asyncio.gather(*tasks)
for url, result in zip(urls, results):
print(f'{url}: {result[:100]}…')

asyncio.run(main())

说明：

• asyncio.gather() 并发执行任务，适合批量请求。
• 研究表明，aiohttp 在并发场景下比 requests 快数倍。

4.2 服务器用法

服务器使用 aiohttp.web.Application 创建，结合路由处理请求。

简单服务器

from aiohttp import web

async def handle(request):
return web.Response(text="你好，世界！")

app = web.Application()
app.add_routes([web.get('/', handle)])

if __name__ == '__main__':
web.run_app(app, host='localhost', port=8080)

说明：

• 访问 http://localhost:8080/ 返回 “你好，世界！”。
• web.run_app() 适合开发，生产环境建议用 Gunicorn。

使用装饰器定义路由

from aiohttp import web

routes = web.RouteTableDef()

@routes.get('/')
async def hello(request):
return web.Response(text="你好，世界！")

@routes.post('/echo')
async def echo(request):
data = await request.json()
return web.json_response(data)

app = web.Application()
app.add_routes(routes)

if __name__ == '__main__':
web.run_app(app, host='localhost', port=8080)

说明：

• 装饰器风格更清晰，适合复杂应用。
• 支持 JSON 请求和响应。

WebSocket 示例

from aiohttp import web

async def websocket_handler(request):
ws = web.WebSocketResponse()
await ws.prepare(request)
async for msg in ws:
if msg.type == web.WSMsgType.TEXT:
await ws.send_str(f"收到: {msg.data}")
elif msg.type == web.WSMsgType.ERROR:
print(f'WebSocket 错误: {ws.exception()}')
return ws

app = web.Application()
app.add_routes([web.get('/ws', websocket_handler)])

if __name__ == '__main__':
web.run_app(app, host='localhost', port=8080)

说明：

• 实现简单的 WebSocket 服务器，回显客户端消息。
• 适合实时应用，如聊天室。

5. 性能分析

研究表明，aiohttp 在高并发场景下性能优于同步库（如 requests）。根据基准测试（参考 Real Python），在处理 1000 个并发请求时，aiohttp 的响应时间显著低于 requests。

性能优势：

• 异步 I/O：非阻塞操作，适合处理大量请求。
• 连接池：ClientSession 复用连接，减少开销。
• 流式处理：支持大文件传输，优化内存使用。

优化建议：

• 安装 aiodns 加速 DNS 解析。
• 使用 aiohttp[speedups] 启用 Brotli 压缩。
• 批量请求使用 asyncio.gather()。

6. 适用场景

aiohttp 适用于以下场景：

7. 注意事项

8. 版本差异

• Python 3.6：引入 async/await，aiohttp 基础版本支持。
• 3.8：优化 WebSockets 和中间件性能。
• 3.11.18（最新稳定版）：修复多线程和性能问题，增强稳定性。
• 4.0.0a2.dev0（开发版）：可能引入新特性，暂不推荐生产使用。

9. 最佳实践

10. 总结表

11. 学习资源

• 官方文档：aiohttp Documentation
• GitHub：aiohttp GitHub Repository
• 教程：
  • GeeksforGeeks: Install Aiohttp In Python
  • Real Python: Asynchronous Python with aiohttp
• 部署指南：Server Deployment
• 社区：Stack Overflow（标签：aiohttp）、GitHub Discussions

12. 总结

aiohttp 是 Python 中异步 Web 开发的首选工具，凭借异步 I/O 和丰富功能，适合 Web 爬虫、API 客户端、实时应用和高并发服务器。研究表明，其性能优于同步库，结合最佳实践可显著提升开发效率。