多Tab页Socket.IO消息同步异常问题排查与解决请求

核心问题定位 #

你的问题本质是生产环境多Worker下的状态一致性问题：本地单进程环境不会触发，但线上50-100用户时，多Uvicorn Worker各自维护独立的内存状态（connected_users、房间成员信息），导致同一用户的多标签页连接分散在不同Worker中，消息无法广播到所有连接；同时消息发送逻辑可能仅针对单个SID，而非用户专属房间，进一步加剧了同步问题。

具体修复方案 #

1. 更换Redis适配器实现跨Worker状态共享 #

生产环境多Worker模式下，内存存储的连接、房间信息无法在Worker间同步，必须用外部存储统一管理状态：

• 安装依赖：pip install python-socketio[redis]
• 修改后端初始化代码：

import socketio
from redis.asyncio import Redis

# 初始化Redis客户端
redis = Redis(host='你的Redis地址', port=6379, db=0, password='你的密码（如果有）')

# 配置Socket.IO使用Redis适配器
sio = socketio.AsyncServer(
    async_mode="asgi",
    cors_allowed_origins='*',
    logger=True,
    engineio_logger=True,
    # 用Redis统一管理连接、房间状态
    adapter=socketio.AsyncRedisAdapter(redis),
    # 用Redis存储会话，确保多Worker下会话一致
    session_store=socketio.RedisSessionStore(redis)
)

2. 确保消息发送到用户专属房间而非单个SID #

检查并修改chat_app_function，将消息广播到用户的专属房间，而非触发消息的单个连接SID：

async def chat_app_function(data, user, sid):
    # 获取用户专属房间名
    room_name = await change_group_name(user.username)
    # 构造前端监听的事件名
    event_name = f"{user.username}sent_chat_app"
    # 向房间内所有连接广播消息
    await sio.emit(event_name, data, to=room_name)

3. 完善房间加入逻辑 #

确保用户的每一个连接（多标签页）都正确加入专属房间，避免连接时的异常导致遗漏：

@sio.on("login")
async def handle_login(sid, data):
    username = data.get("username")
    # 重新保存会话，确保会话一致性
    await sio.save_session(sid, {'username': username})
    # 强制加入用户专属房间
    room_name = await change_group_name(username)
    await sio.enter_room(sid, room_name)
    # 移除内存connected_users（改用Redis适配器维护连接状态）
    print(f"{username} logged in.")

4. 前端优化：避免事件监听泄漏 #

确保组件卸载时正确移除事件监听，防止无效连接残留：

import socketIOClient from "socket.io-client";

useEffect(() => {
  const username = "username";
  const socket = socketIOClient(WEB_SOCKET_IO, {
    query: { username: username },
    secure: true,
    transports: ["websocket"],
    path: "/socket.io/",
    reconnectionDelay: 1000,
    reconnection: true,
    reconnectionAttempts: Infinity,
  });

  const eventName = `${username}sent_chat_app`;
  const handleChatMessage = (value) => {
    try {
      console.log("收到消息", value);
    } catch (e) {}
  };

  socket.on("connect", () => {
    socket.emit("login", { username });
  });
  socket.on(eventName, handleChatMessage);

  return () => {
    // 先移除事件监听
    socket.off(eventName, handleChatMessage);
    // 再断开连接
    socket.disconnect();
  };
}, []);

额外建议 #

• 关闭connected_users内存字典：Redis适配器会自动维护房间成员信息，无需手动管理连接映射
• 开启Socket.IO的调试日志：线上问题发生时，通过engineio_logger=True查看连接、房间、消息的流转细节，快速定位问题

内容的提问来源于stack exchange，提问作者Yash Mittra