如何在Python中处理高并发WebSocket连接_基于FastAPI与Uvicorn部署

千丽同学_6699

千丽同学_6699

2026-05-07

840人浏览

原创

单机支撑5000+ websocket连接需避开三大坑:连接管理(用set+心跳+异常移除)、消息广播(asyncio.gather并发发送+分批+过滤)、阻塞调用(全程异步+线程池+异步db/http)。

如何在python中处理高并发websocket连接_基于fastapi与uvicorn部署

单机撑住 5000+ 活跃 WebSocket 连接,不是靠堆硬件,而是避开连接管理、消息广播、阻塞调用这三个坑。FastAPI + Uvicorn 组合本身足够强,但默认写法极易掉进同步陷阱。

async def websocket_endpoint() 必须全程异步

常见错误是:在 websocket.receive_text() 和 websocket.send_text() 之间插入 time.sleep()、requests.get()、未加 await 的数据库查询,或直接用 json.loads() 解析大 JSON 字符串。这些操作会卡死整个事件循环,所有连接一起变卡。

  • HTTP 调用必须换 httpx.AsyncClient,不能用 requests
  • 数据库必须用异步驱动:asyncpg(PostgreSQL)、aiomysql(MySQL),而非 psycopg2 或 pymysql
  • CPU 密集型操作(如大 JSON 解析、加密)要丢进线程池:await asyncio.to_thread(json.loads, data)
  • Pydantic 校验默认同步,高频场景建议关掉或改用 model_validate_json() 避免重复解析

别用 list 存连接,set + try/except 才安全

用 active_connections = [] 然后遍历发送,看似简单,但客户端异常断开(比如关浏览器、网络中断)时,websocket.send_text() 会抛出异常,若没捕获,连接就永远留在列表里 → 内存持续上涨 → OOM。

提示词大师-python版
提示词大师-python版

图片提示词生成器?不止如此。 马甲系统 —— 把脑海中的画面,翻译成AI能理解的专业表达。 用得越多,它越懂你:首次需要多问几句确认方向,用久了几乎一说就懂。 用得越多,它越快:缓存机制让后续对话越来越省。 RAG进化:成功案例持续入库,越跑越聪明。 输入「新手指南」查看完整功能介绍

下载
  • 改用 set 而非 list,天然去重且增删快
  • 每次广播前必须对每个连接做 try/except,捕获 WebSocketDisconnect 和通用 Exception,失败后立即从 set 中移除
  • 加心跳检测:在 while True: 循环里定期 await websocket.ping(),超时主动 close()
  • 生产环境务必用 psutil.Process().memory_info().rss 定期打点监控连接数与内存增长

Uvicorn worker 数和并发限制必须手动配

gunicorn main:app -k uvicorn.workers.UvicornWorker -w 4 是常见配置,但盲目加 -w 反而降低性能 —— Uvicorn 本身是单线程异步,每个 worker 独占一个事件循环;过多 worker 会导致 CPU 上下文切换激增、内存冗余、甚至文件描述符耗尽。

  • worker 数推荐值:CPU 核心数 × 1~1.5(例如 4 核机器设 -w 4 或 -w 6)
  • 必须加 --limit-concurrency 100,防止单个 worker 接收过多连接压垮内存
  • 启用 --ws-per-message-deflate 开启 WebSocket 压缩,文本消息体积可减小 40%+
  • 生产环境禁用 --reload,它会 fork 多个进程导致连接状态不同步

广播不能 for-loop + await 逐个发

当有 2000 个连接时,for conn in connections: 然后 await conn.send_text(...) 是串行的,总延迟爆炸。正确做法是并发发起所有 send,再统一等待完成。

  • 用 asyncio.gather(*[conn.send_json(msg) for conn in connections], return_exceptions=True)
  • 不要用 return_exceptions=False,否则一个连接失败整个广播就中断
  • 如果连接数极大(>3000),建议分批 gather,每批 100~200 个,避免 event loop 负载过重
  • 广播前先过滤掉已关闭连接(靠心跳标记或 try/except 捕获结果判断),减少无效调用

最易被忽略的是连接泄漏和广播异常处理 —— 它们不会立刻报错,但会在几小时后让服务缓慢崩塌。上线前务必压测并观察 psutil 内存曲线和连接数变化趋势。

大量免费API接口:立即使用
涵盖生活服务API、金融科技API、企业工商API、等相关的API接口服务。免费API接口可安全、合规地连接上下游,为数据API应用能力赋能!

相关文章

PHP速学视频免费教程(入门到精通)
PHP速学视频免费教程(入门到精通)

PHP怎么学习?PHP怎么入门?PHP在哪学?PHP怎么学才快?不用担心,这里为大家提供了PHP速学教程(入门到精通),有需要的小伙伴保存下载就能学习啦!

下载

相关标签:

python websocket

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

相关专题

更多
python打包成可执行文件
python打包成可执行文件

本专题为大家带来python打包成可执行文件相关的文章,大家可以免费的下载体验。

2023.07.20

1611

4

python能做什么
python能做什么

python能做的有:可用于开发基于控制台的应用程序、多媒体部分开发、用于开发基于Web的应用程序、使用python处理数据、系统编程等等。本专题为大家提供python相关的各种文章、以及下载和课程。

2023.07.25

3844

7

format在python中的用法
format在python中的用法

Python中的format是一种字符串格式化方法,用于将变量或值插入到字符串中的占位符位置。通过format方法,我们可以动态地构建字符串,使其包含不同值。php中文网给大家带来了相关的教程以及文章,欢迎大家前来阅读学习。

2023.07.31

1609

3

python教程
python教程

Python已成为一门网红语言,即使是在非编程开发者当中,也掀起了一股学习的热潮。本专题为大家带来python教程的相关文章,大家可以免费体验学习。

2023.08.03

22157

23

python环境变量的配置
python环境变量的配置

Python是一种流行的编程语言,被广泛用于软件开发、数据分析和科学计算等领域。在安装Python之后,我们需要配置环境变量,以便在任何位置都能够访问Python的可执行文件。php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

2023.08.04

2727

5

python eval
python eval

eval函数是Python中一个非常强大的函数,它可以将字符串作为Python代码进行执行,实现动态编程的效果。然而,由于其潜在的安全风险和性能问题,需要谨慎使用。php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

2023.08.04

2767

5

scratch和python区别
scratch和python区别

scratch和python的区别:1、scratch是一种专为初学者设计的图形化编程语言,python是一种文本编程语言;2、scratch使用的是基于积木的编程语法,python采用更加传统的文本编程语法等等。本专题为大家提供scratch和python相关的文章、下载、课程内容,供大家免费下载体验。

2023.08.11

1103

5

python合并两个列表
python合并两个列表

Python是一种强大的编程语言,具有许多方便的功能和工具。在Python中,有多种方法可以合并两个列表。php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

2023.08.10

596

4

python是前端还是后端
python是前端还是后端

Python属于前端也属于后端,其灵活性和丰富的生态系统使得开发人员能够在不同的领域中灵活运用。本专题为大家提供python相关的文章、下载、课程内容,供大家免费下载体验。

2023.08.11

2143

5

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程