讲师中心 微信公众号
AI工具推荐 视频效率加速

怎样在Python中使用FastAPI实现WebSockets?

酷宇同学_3914

酷宇同学_3914

发布时间:2026-11-02 10:51:15

|

326人浏览过

|

来源于php中文网

原创

WebSocket连接被拒绝或立即断开,根本原因在于握手失败而非心跳缺失;需确保使用@app.websocket正确声明路由、客户端发起标准ws/wss握手、服务端返回101状态码及Upgrade/Connection头,并排查Nginx代理配置是否透传升级头。

怎样在python中使用fastapi实现websockets?

WebSocket连接为什么总是被拒绝或立即断开?

FastAPI的WebSocket对象本身不处理HTTP升级逻辑,必须用@app.websocket装饰器显式声明路由,且路径不能和普通@app.get等冲突。常见错误是误写成@app.get("/ws")再手动调用websocket.accept()——这会直接抛出RuntimeError: Not connected。

正确做法是:确保路由只被@app.websocket接管,且客户端发起的是标准WebSocket握手(ws://或wss://协议)。

  • 检查浏览器控制台是否报ERR_CONNECTION_REFUSED:确认Uvicorn服务已启动并监听正确端口(默认http://127.0.0.1:8000,但WebSocket需用ws://127.0.0.1:8000/ws)
  • 避免在websocket.disconnect()后继续调用websocket.send_text(),会触发WebSocketDisconnect异常
  • 若用Nginx反向代理,需显式透传Upgrade和Connection头:
    location /ws {<br>    proxy_pass http://backend;<br>    proxy_http_version 1.1;<br>    proxy_set_header Upgrade $http_upgrade;<br>    proxy_set_header Connection "upgrade";<br>}

如何安全地广播消息给所有活跃连接?

FastAPI不内置连接池,需要手动维护set[WebSocket]。关键点在于:连接建立时add、断开时remove,且广播操作必须用asyncio.create_task()或async for逐个发送——不能直接await websocket.send_text()在循环里,否则一个连接卡住会阻塞全部。

示例维护方式:

python-flask-vue-creator
python-flask-vue-creator

创建 Flask + Vue.js 全栈项目,采用单端口架构、uv 依赖管理、结构化日志和生产级前端设计。当用户要求以下操作时触发:创建新的 Flask+Vue 项目、搭建 Web 应用、构建全栈 Python+Vue 应用、初始化 Flask Web 项目、设置单端口 Flask 前后端项目。触发词:新建项目、创建项目、搭建项目、Flask项目、Vue项目。

下载

立即学习“Python免费学习笔记(深入)”;

from fastapi import WebSocket, WebSocketDisconnect<br>from typing import Set<br><br>active_connections: Set[WebSocket] = set()<br><br>@app.websocket("/ws")<br>async def websocket_endpoint(websocket: WebSocket):<br>    await websocket.accept()<br>    active_connections.add(websocket)<br>    try:<br>        while True:<br>            data = await websocket.receive_text()<br>            # 广播给其他人(不含自己)<br>            for conn in active_connections:<br>                if conn != websocket:<br>                    await conn.send_text(f"User says: {data}")<br>    except WebSocketDisconnect:<br>        active_connections.discard(websocket)
  • 用set而非list:避免重复添加/删除时的O(n)开销
  • 务必用discard()而非remove():防止断连时连接已被移除导致KeyError
  • 生产环境建议加超时控制(如await asyncio.wait_for(websocket.receive_text(), timeout=30)),防恶意长连接

为什么接收二进制数据时报TypeError: Object of type bytes is not JSON serializable?

这个错误通常出现在你把await websocket.receive_bytes()的结果直接传给json.dumps()或FastAPI的response_model。WebSocket的receive_bytes()返回原生bytes,不是JSON字符串。

  • 如果客户端发的是JSON格式的二进制(比如压缩后的JSON),需先解码:json.loads(received_bytes.decode("utf-8"))
  • 如果发的是纯二进制(如图片base64片段),应直接处理bytes,不要尝试JSON序列化
  • 发送时也注意:send_text()只接受str,send_bytes()才接受bytes;混用会立刻报错
  • 调试技巧:打印type(data)和len(data),确认收发类型一致

如何让WebSocket支持查询参数或认证?

WebSocket握手请求携带的URL参数(如ws://localhost:8000/ws?token=abc123)可通过websocket.query_params获取,但它在accept()前就可用;而认证逻辑必须放在accept()之前,否则未授权连接也会被建立。

  • 校验失败时,直接raise WebSocketException(code=4001, reason="Invalid token")(code需为4000–4999),客户端会收到对应CloseEvent
  • JWT token验证建议用同步函数(如jwt.decode(..., options={"verify_signature": False})快速校验结构),避免在accept()前用await阻塞握手
  • Cookie认证也可读websocket.cookies,但注意浏览器跨域时需设置credentials: true且后端响应带Access-Control-Allow-Credentials: true

复杂状态管理(如用户绑定、房间隔离)往往需要额外存储层,仅靠内存set无法支撑多进程部署——这时候该考虑Redis的Pub/Sub或专用WebSocket网关了。

热门AI工具

更多
DeepSeek

DeepSeek是一款面向对话、写作、编程和推理场景的AI大模型工具。

火山引擎

火山引擎是一款面向企业的云计算与AI服务平台。

Seko
Seko Hot

一款AI视频创作工具,主要用于商汤科技推出的创编一体的AI短视频创作Agent,适合需要提升相关任务效率的用户。

小橡皮AI

一款AI工具,主要用于小橡皮一键去AI味,将机器味重的内容改得更有活人感,防止因为 AI 内容被平台打上 AI 标签,以及限流,适合需要提升相关任务效率的用户。

PixPix
PixPix Hot

PixPix是一款面向电商视觉生产的AI商品图生成工具。

WorkBuddy

一款AI办公效率工具,主要用于腾讯云推出的AI原生桌面智能体工作台,适合需要提升相关任务效率的用户。

豆包大模型

豆包大模型是一款由字节跳动推出的企业级大语言模型服务平台。

咔片AIPPT

一款在线AI演示文稿制作工具,可根据主题和内容需求辅助生成PPT结构与页面,提高演示材料制作效率。

SkildArt
SkildArt Hot

SkildArt是一款AI文本写作工具,一站式 AI 视觉创作平台。

相关专题

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

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

1851

2023.07.20

python能做什么
python能做什么

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

5004

2023.07.25

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

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

1789

2023.07.31

python教程
python教程

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

29997

2023.08.03

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

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

3567

2023.08.04

python eval
python eval

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

3587

2023.08.04

scratch和python区别
scratch和python区别

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

1223

2023.08.11

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

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

616

2023.08.10

Uvicorn 报错与问题解决教程
Uvicorn 报错与问题解决教程

本专题汇总了Uvicorn服务器常见问题与报错解决的教程合集,涵盖启动失败、端口占用、模块导入错误、事件循环冲突及热重载失效等典型故障的排查思路。同时整理了多进程与Worker配置、SSL/HTTPS证书报错、跨域与代理配置等实战解决方案,助你快速定位并解决Uvicorn运行中的各类问题。

0

2026.11.02

热门下载

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

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
Uvicorn官方安装与入门手册
Uvicorn官方安装与入门手册

共0课时 | 0人学习

Python uv官方项目管理指南
Python uv官方项目管理指南

共0课时 | 0人学习

Python uv官方安装与入门文档
Python uv官方安装与入门文档

共0课时 | 0人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn