FastAPI WebSocket连接立即断开主因是未显式调用await websocket.accept()或重复调用：前者致客户端报403或1006错误，后者抛“Already accepted”异常；必须且仅在接收/发送前调用一次accept()。

WebSocket连接为什么总在建立后立即断开

FastAPI的WebSocket对象必须显式调用accept()，否则客户端会收到1006错误并断连。常见写法是把accept()写在while True循环里——这会导致第二次accept()失败，直接断开连接。

正确做法是只调用一次，在接收/发送逻辑之前：

@app.websocket("/ws")
async def websocket_endpoint(websocket: WebSocket):
    await websocket.accept()  # ← 必须且仅此一次
    try:
        while True:
            data = await websocket.receive_text()
            await websocket.send_text(f"echo: {data}")
    except WebSocketDisconnect:
        pass

• 漏掉await websocket.accept() → 客户端报错403 Forbidden或直接关闭
• 在循环内重复调用accept() → 触发RuntimeError: Already accepted
• 没包try/except WebSocketDisconnect → 断连时抛未捕获异常，日志刷屏

如何安全地广播消息给所有在线客户端

FastAPI本身不维护WebSocket连接池，需要自己用线程安全的数据结构（如set配合asyncio.Lock）管理活动连接。直接用全局list或dict在并发场景下会丢连接或引发RuntimeError: Set changed size during iteration。

推荐方案：用weakref.WeakSet自动清理已断开的连接，避免内存泄漏：

立即学习“Python免费学习笔记（深入）”；

from weakref import WeakSet
<p>active_connections = WeakSet()</p><div class="aritcle_card flexRow">
                                                        <div class="artcardd flexRow">
                                                                <a class="aritcle_card_img" href="/xiazai/skill6081" title="python-code-analyz"><img
                                                                                src="https://img.php.cn/upload/skill/000/000/081/179077148379011.jpg" alt="python-code-analyz"  onerror="this.onerror='';this.src='/static/lhimages/moren/morentu.png'" ></a>
                                                                <div class="aritcle_card_info flexColumn">
                                                                        <a href="/xiazai/skill6081" title="python-code-analyz">python-code-analyz</a>
                                                                        <p>专业Python代码分析与优化，支持语法检查、安全扫描、性能评估、复杂度分析及重构后优化代码生成。</p>
                                                                </div>
                                                                <a href="/xiazai/skill6081" title="python-code-analyz" class="aritcle_card_btn flexRow flexcenter"><b></b><span>下载</span> </a>
                                                        </div>
                                                </div><p>@app.websocket("/ws")
async def websocket_endpoint(websocket: WebSocket):
await websocket.accept()
active_connections.add(websocket)
try:
while True:
data = await websocket.receive_text()</p><h1>广播给其他人（不含自己）</h1><pre class="brush:php;toolbar:false;"><pre class="brush:php;toolbar:false;">        for conn in active_connections:
            if conn != websocket:
                await conn.send_text(data)
except WebSocketDisconnect:
    pass</code></pre>

• 用list或<code>dict手动管理 → 需要额外逻辑清理断连，易出错
• 没做conn != websocket判断 → 自己发的消息又回传给自己，形成回环
• 广播时未加try/except → 某个连接已断但尚未被WeakSet清理，send_text()抛WebSocketDisconnect中断整个广播

为什么websocket.receive_json()总是报JSONDecodeError

客户端发来的数据未必是合法JSON字符串，比如空格、换行、BOM头或二进制帧混入。FastAPI默认不校验帧类型，receive_json()遇到非文本帧（如Binary）会直接崩溃。

稳妥做法是先用receive()拿到原始dict，再根据type字段分支处理：

msg = await websocket.receive()
if msg["type"] == "text":
    try:
        data = json.loads(msg["text"])
    except json.JSONDecodeError:
        await websocket.close(code=4000)  # 自定义错误码
        return
elif msg["type"] == "binary":
    # 处理二进制数据，例如protobuf或图片
    pass

• 盲目用receive_json() → 任意非JSON文本（如" "或"\n"）都触发异常
• 忽略msg["type"] → 二进制帧传进来直接炸，无法恢复
• 没设close(code=...) → 异常后连接挂起，占用资源

生产环境必须关掉的调试配置

开发时用uvicorn.run(..., reload=True)很方便，但上线后必须禁用reload和debug，否则：

• reload=True → 文件监视器在多进程下失效，可能触发多次热重载，导致连接状态错乱
• debug=True → 暴露完整堆栈、路径、环境变量，WebSocket握手阶段就可能泄露敏感信息
• 没设timeout_keep_alive → 默认5秒，高延迟网络下频繁断连重连

上线启动命令应类似：

uvicorn main:app --host 0.0.0.0 --port 8000 \
  --workers 4 \
  --timeout-keep-alive 30 \
  --log-level warning

WebSocket长连接对超时和日志敏感，30秒保活比默认值更稳妥；warning级别可过滤大量无意义的INFO连接日志，避免IO瓶颈。

真正难的不是写通一条连接，而是让几百个并发连接稳定跑三天不掉、不出错、不拖垮内存——这些细节没压到每个await后面，就容易在凌晨三点被报警叫醒。