fastapi高并发需全程异步:路由用async def、http客户端用httpx.asyncclient或aiohttp、数据库用asyncpg等异步驱动、cpu任务交由线程池或进程处理,并配置uvicorn多worker等参数。

FastAPI 本身默认支持异步,但光写 async def 不等于高并发——真正起作用的是你如何组织 I/O 等待、是否混用同步阻塞调用、以及事件循环是否被意外拖慢。
async def 路由函数必须配 async 客户端
常见错误是:在 async def 路由里调用 requests.get() 这类同步库。它会阻塞整个事件循环,所有并发请求排队等一个请求完成。
正确做法是用原生支持异步的 HTTP 客户端:
-
httpx.AsyncClient()(推荐,FastAPI 官方示例标配) -
aiohttp.ClientSession()(适合复杂定制场景) - 避免
requests、urllib.request等同步库直接出现在async函数中
示例对比:
# ❌ 错误:同步库阻塞事件循环
@app.get("/bad")
async def bad_endpoint():
resp = requests.get("https://www.php.cn/link/5f69e19efaba426d62faeab93c308f5c") # 这里卡死整个服务
return resp.json()
<h1>✅ 正确:异步客户端 + await</h1><p>@app.get("/good")
async def good_endpoint():
async with httpx.AsyncClient() as client:
resp = await client.get("<a href="https://www.php.cn/link/5f69e19efaba426d62faeab93c308f5c">https://www.php.cn/link/5f69e19efaba426d62faeab93c308f5c</a>")
return resp.json()
</p>
数据库查询必须用异步驱动
哪怕路由是 async,如果底层用 SQLAlchemy 同步 ORM(比如 create_engine 默认配置),查询仍会阻塞。关键不是“有没有 await”,而是驱动是否真正异步。
实操要点:
- PostgreSQL 推荐
asyncpg驱动,搭配SQLAlchemy 2.0+的 async session - MySQL 推荐
aiomysql或asyncmy - 避免用
sqlite做高并发后端——它不支持真正的并发写入,且无异步驱动 - 连接池要显式配置
pool_pre_ping=True,防止空闲连接断连导致报错OperationalError: (sqlite3.OperationalError) database is locked
CPU 密集任务不能直接 await
async/await 只对 I/O 等待有效。如果你在路由里做图像缩放、JSON 解析大文件、或跑机器学习推理,这些 CPU 操作会霸占线程,其他协程照样等。
解决方案只有两个:
- 用
loop.run_in_executor()把 CPU 工作扔进线程池(适合中等负载) - 拆到独立进程(如 Celery + Redis),用
BackgroundTasks触发后立即返回(适合重负载)
示例:
from concurrent.futures import ThreadPoolExecutor
import time
<p>@app.get("/cpu-bound")
async def cpu_bound():
loop = asyncio.get_event_loop()
with ThreadPoolExecutor() as pool:
result = await loop.run_in_executor(pool, time.sleep, 2) # 模拟 CPU 工作
return {"done": True}
</p>
uvicorn 启动参数直接影响并发上限
uvicorn main:app 默认只开 1 个 worker,再多协程也跑不满 CPU。生产环境必须调参:
-
--workers 4(建议设为 CPU 核数 × 2) -
--limit-concurrency 1000防止单 worker 处理过多连接耗尽内存 -
--timeout-keep-alive 5缩短长连接保持时间,释放连接资源更快 - 禁用
--reload上生产——它会干扰事件循环稳定性
完整命令示例:
uvicorn main:app --host 0.0.0.0 --port 8000 --workers 4 --limit-concurrency 1000 --timeout-keep-alive 5
真正容易被忽略的点是:异步性能不取决于单个接口多快,而取决于整个调用链是否全程异步。从 HTTP 客户端、数据库驱动、缓存客户端(如 aioredis)、到下游 gRPC 或消息队列 SDK,只要其中一环是同步阻塞的,就等于给高速路修了个收费站。
大量免费API接口:立即使用
涵盖生活服务API、金融科技API、企业工商API、等相关的API接口服务。免费API接口可安全、合规地连接上下游,为数据API应用能力赋能!











