我用python-socketio和socket.io-client实现了一个网站聊天。
有时候，当我们在不同的浏览器中同时打开多个标签，或者与同一个登录用户进行匿名会话时，新打开的标签可以成功地发送和接收消息。但是，旧的标签可以发送但不能接收消息，即使它们仍然连接到Python Socket.IO和socket.io-client。此外，我已经使用了一个房间会话来管理连接。这个问题发生在一个实时服务器上，在任何时候都有大约50-100个用户连接到套接字，而不是在本地主机上。

我使用的版本如下：

python-socketio==5.9.0
uvicorn==0.16.0
eventlet==0.33.3
socket.io-client = 4.7.2

字符串

后台：

import socketio
    sio = socketio.AsyncServer(async_mode="asgi", cors_allowed_origins='*', logger=True, engineio_logger=True)
    connected_users = {}
    room_user_count = {}
    @sio.on("connect")
    async def connect(sid, environ):
      try:
        query_string = environ.get("QUERY_STRING") or "Anonymous"
        if query_string:
          username = query_string.split("username=")[1].split("&")[0]
          await sio.save_session(sid, {'username': username})
          room_name = await change_group_name(username)
          sio.enter_room(sid, room_name)
        print(f"[Connected] {sid}")
      except Exception as e:
        print("Connected error", str(e))
    @sio.on("login")
    async def handle_login(sid, data):
      username = data.get("username")
      session_id = await sio.get_session(sid)
      connected_users[sid] = {"username": username, "session_id": session_id['username']}
      print(f"{username} logged in.")
    @sio.on("disconnect")
    async def disconnect(sid):
      try:
        username = connected_users.get(sid, {}).get("username", "Anonymous")
        connected_users.pop(sid, None)
        leave_room = await change_group_name(username)
        sio.leave_room(sid, leave_room)
        print(f"Disconnected: {sid}, Username: {username}")
      except Exception as e:
        print(f"Disconnected Error: {e}")
    @sio.on("client_chat_app")
    async def message_from_client(sid, data):
      username = connected_users.get(sid, {}).get("username", "Anonymous")
      user = await get_user_obj(username)
      await chat_app_function(data, user, sid)

型

前端：

import socketIOClient from "socket.io-client";
useEffect(() => {
  let username = “username”;
  socket = socketIOClient(WEB_SOCKET_IO, {
   query: { username: username },
   secure: true,
   transports: ["websocket"],
   path: "/socket.io/",
   reconnectionDelay: 1000,
   reconnection: true,
   reconnectionAttempts: Infinity,
  });
  socket.on("connect", () => {
   socket.emit("login", { username });
  });
  let event_chat_app = username + "sent_chat_app";
  socket.on(event_chat_app, (value) => {
   try {
    console.log(“value”, value)
   } catch (e) {}
  });
 }
 return () => {
  socket?.disconnect();
 };
}, []);

型
我可以做些什么来确保同步问题不再发生？