套接字IO和动态室

Question

如果有人对WebSocket/Socket IO有经验，希望你能给我指出正确的方向。

我制作了一个不和谐的克隆，我正试图优化它以更好地扩展。现在，当一个用户发送一条消息时，我向数据库查询该服务器的所有用户部分，并向他们的特定套接字发送一条消息。这显然不能很好地扩展，因为每条消息都需要在客户机列表中进行昂贵的查询和查找

// Emit messages to only users part of specific server
    // Will only return list of users part of server and active in last 10 minutes
    sqlQuery = `SELECT userservers.user_id FROM userservers 
                  JOIN users ON users.user_id = userservers.user_id AND users.user_last_active > (NOW() - INTERVAL 10 minute)
                  WHERE server_id = ${sql.escape(serverId)}`;
    const users = await sql.query(sqlQuery);
    action = { type: "message", payload: msg };

    // Iterate over users, and find them in clients list
    // Emit over socket only to that user
    users.forEach((user) => {
      clients.forEach((client) => {
        if (client.userId === user.user_id) {
          io.to(client.id).emit(user.user_id, action);
        }
      })
    });

然而，为每台服务器使用房间将消除我查询数据库的需要。我知道我可以在套接字服务器首次启动时执行此操作

// Get server list from Mysql DB
servers.forEach((server) => {
    socket.join(server.name);
}

但是，我的问题是，当用户在应用程序运行后创建新服务器时，它不会更新列表。

我可能缺少一些关于创建动态房间的概念。

编辑：我想解决方案可能是每次创建“服务器”时，我都会向套接字服务器发送一条消息，这样它就可以加入那个“房间”

Answer 1

现在，当一个用户发送一条消息时，我向数据库查询该服务器的所有用户

我认为您可以向所有在线用户提交广播消息，而不是每个客户端的forEach=

我也想知道你为什么要创建许多服务器？您可以通过使用const命名空间=io.of（'/thisIsADetateNamespace'）将服务器划分为命名空间；并且您还可以通过namespace.emit向此名称空间中的所有用户提交广播消息（'某些事件'，{for：'名称空间中的每个人' });

所以你的聊天结构可以是这样的

服务器

• 命名空间//用于单独的聊天应用/或类似于松弛的工作空间
• 房间//小组聊天
• ClientID//为一对一