瓶颈在于aiohttp默认tcpconnector限制总连接数为100、单host最多30连接、dns缓存5秒及保守超时,需显式配置limit/limit_per_host、缩短ttl_dns_cache、分层设超时并复用session。

为什么直接用 aiohttp.ClientSession() 会卡在几百 QPS?
不是代码写错了,是默认配置把并发压死了。aiohttp 默认的 TCPConnector 限制总连接数为 100,单个 host 最多 30 个连接,还带 5 秒 DNS 缓存和保守超时策略——这根本不是为万级并发设计的。
常见现象:发 1000 个请求,实际同时跑的只有二三十个,其余全在排队;响应时间从几十毫秒飙到几秒;CPU 利用率不到 30%,但吞吐上不去。
- 必须显式传入自定义
TCPConnector,把limit和limit_per_host设为 0(不限制)或足够大的值(如 1000) - DNS 缓存设短点:
use_dns_cache=True, ttl_dns_cache=10,避免解析卡住 - 超时要分层设:
timeout=aiohttp.ClientTimeout(total=10, connect=3, sock_read=5),防止单个慢请求拖垮整批
如何安全压到 10k+ QPS 而不被目标封或崩自己?
并发数不是越大越好。真实场景中,10k QPS 意味着每秒新建上千 TCP 连接,若不做节流,轻则触发对方限流(返回 429),重则被 WAF 拉黑;本地也可能耗尽文件描述符或内存。
关键控制点:
- 用
asyncio.Semaphore限流,比如semaphore = asyncio.Semaphore(500),确保同时活跃请求数可控 - 复用
ClientSession实例——绝不能每个请求都新建 session,否则连接池失效、TLS 握手开销爆炸 - 加随机 jitter 延迟(如
await asyncio.sleep(random.uniform(0.01, 0.05))),避开请求毛刺峰 - 监控
session.connector._conns实时连接数,发现堆积立即降并发
orjson + uvloop 对性能的真实影响有多大?
序列化和事件循环是两个最易被忽略的瓶颈。标准 json.dumps 在高频响应构造时 CPU 占用能到 40%+;默认 asyncio 事件循环在高负载下调度延迟明显上升。
实测对比(4 核 8G 机器,10k 并发请求 JSON API):
- 换
orjson后,web.json_response构造耗时从 12ms 降到 1.8ms,CPU 占用下降 27% - 启用
uvloop.install()后,事件循环吞吐提升约 2.3 倍,P99 延迟从 210ms 降至 89ms - 二者叠加,QPS 从 6.2k 稳定提升至 14.7k,且无连接泄漏
注意:orjson 不支持自定义 JSONEncoder,遇到 datetime 或 Decimal 得先转成字符串或 str() 处理。
为什么生产环境一定要配 ClientSession 的 raise_for_status=True?
默认情况下,aiohttp 遇到 4xx/5xx 响应不会抛异常,而是照常返回 ClientResponse。这会导致错误静默传播——比如目标返回 503,你的代码却当成成功继续解析 response.json(),最终触发 JSONDecodeError,堆栈里根本看不到 HTTP 错误源头。
正确做法:
- 初始化 session 时加上
raise_for_status=True - 统一用
try/except aiohttp.ClientResponseError捕获 HTTP 错误,区分处理 429、503、403 等语义 - 对非 2xx 响应,别急着
await response.json(),先检查response.status
这个开关不开,线上出问题时 debug 成本会翻倍——你得逆向从解析失败往回推,而不是一眼看到 “got 429 from api.example.com”。
Python免费学习笔记(深入):立即使用
在学习笔记中,你将探索 Python 的核心概念和高级技巧!











