应选websockets库:它提供纯WebSocket协议控制,无Socket.IO额外封装,安装简单(pip install websockets),支持异步直接操作send/recv,便于调试消息乱序等问题,但需手动处理连接管理、JSON序列化和断连清理。

WebSocket 服务器选 websockets 而不是 Flask-SocketIO
想快速搭一个轻量、可控的聊天室,websockets 库比 Flask-SocketIO 更直接。后者依赖 Socket.IO 协议(带轮询降级、JSON 封装、命名空间等额外层),而纯 WebSocket 场景下反而容易踩坑:比如客户端没发 ping 时服务端误判断连,或广播逻辑被封装层干扰。
用 websockets 你能明确控制连接生命周期、消息格式和广播时机——这对调试聊天消息乱序、重复、丢失问题很关键。
- 安装只需:
pip install websockets - 不依赖 WSGI 服务器(如 Gunicorn),直接运行异步 server
- 每个连接对应一个
websocket对象,await websocket.send()和await websocket.recv()是最接近协议本意的操作
用集合管理在线用户,但必须加锁防止并发写入
聊天室核心是把新消息广播给所有当前连接的客户端。常见错误是直接用全局 set 存 websocket 对象,然后在 for ws in connected: 循环里发消息——这会触发 RuntimeError: Set changed size during iteration,因为某个客户端可能正在断开,同时 connected.remove(ws) 在另一个协程执行。
正确做法是用 asyncio.Lock 保护读写,或更简单:广播前先转成列表副本。
立即学习“Python免费学习笔记(深入)”;
connected = set()
# …
async def broadcast(message):
# 安全做法:取快照
for ws in list(connected):
try:
await ws.send(message)
except ConnectionClosed:
connected.discard(ws)
json.dumps() 发送前必须处理非 JSON 类型,否则 TypeError
聊天消息通常含时间戳、用户 ID、头像 URL 等字段,如果用了 datetime 或自定义对象,直接 json.dumps(msg) 会报 TypeError: Object of type datetime is not JSON serializable。
让 macOS 自动化像说话一样简单 —— 用代码控制你的 Mac,无需学习 AppleScript 系统要求 macOS 14+ (Sonoma) Python 3.9+ 需要开启:辅助功能 + 屏幕录制权限
别在每个 send() 前手写 default= 参数,统一用 json.JSONEncoder 子类更可靠:
class ChatJSONEncoder(json.JSONEncoder):
def default(self, obj):
if isinstance(obj, datetime):
return obj.isoformat()
if isinstance(obj, UUID):
return str(obj)
return super().default(obj)
<h1>发送时:</h1><p>await ws.send(json.dumps(msg, cls=ChatJSONEncoder))- 避免用
str()强转,它输出的不是标准 JSON 格式(比如datetime变成'2024-06-12 15:23:44.123456',没引号) - 前端
JSON.parse()会失败
客户端断连后服务端没清理,导致“幽灵用户”和内存泄漏
WebSocket 连接关闭时,浏览器可能不发 close 帧(比如关掉标签页、网络中断),服务端不会自动从 connected 集合移除该 websocket。结果是:旧连接占着内存,广播时还试图向已断开的 socket 写数据,触发 ConnectionClosed 异常,但没人捕获——最后集合越滚越大。
必须在 try/except 中监听 ConnectionClosed,并在 finally 块里做清理:
async def handle_client(websocket, path):
connected.add(websocket)
try:
async for message in websocket:
# 处理消息...
except ConnectionClosed:
pass # 正常断连
finally:
connected.discard(websocket) # 无论怎么退出都清理注意 connected.discard() 比 remove() 安全,避免 KeyError;也别只靠 websocket.close() 后清理——它只是发送关闭帧,不代表对方已确认断开。
真实环境里还要加心跳检测(ping_interval),但多数开发阶段先确保基础清理逻辑跑通,比过早引入复杂机制更重要。

















