【已解决】Nodejs中socket.io 如何保存所有人的连接？现在是第2个人连接上，第1个人就收不到socket消息

【已解决】Node.js 中 socket.io 如何保存所有人的连接？现在是第2个人连接上，第1个人就收不到 socket 消息

问题描述

在使用 Node.js 和 socket.io 进行实时通信时，当第二个用户连接后，第一个用户就无法收到 socket 消息。我们需要找到一种方法来保存所有用户的连接，并确保每个用户都能接收到广播的消息。

解决方案

我们可以使用一个全局对象来存储所有用户的 socket 连接信息。这样，当有新的用户连接时，我们就可以将他们的 socket 对象添加到这个全局对象中，并且可以向所有用户发送消息。

以下是改进后的示例代码：

// 定义一个全局对象来保存所有用户的 socket 连接
const players = {};

io.sockets.on('connection', function (socket) {
    // 获取用户数据（这里只是一个示例，实际应用中应从其他地方获取）
    const currentUser = {
        uid: socket.id, // 使用 socket.id 作为唯一标识符
        socket: socket,
    };

    // 将当前用户添加到全局对象中
    players[currentUser.uid] = currentUser;

    // 监听登录事件
    socket.on('login', function () {
        socket.emit('login_result', 'yes');
    });

    // 监听测试事件
    socket.on('test', function () {
        socket.emit('test_result', 'something');
    });

    // 向所有用户广播消息
    socket.on('broadcast_message', function (message) {
        for (let user in players) {
            players[user].socket.emit('broadcast_message', message);
        }
    });
});

代码解释

1. 全局对象 players:

   • 我们使用一个全局对象 players 来存储所有用户的 socket 连接信息。每个用户的 socket 都被存储在一个以 socket.id 为键的对象中。

2. 监听连接事件:

   • 当一个新的 socket 连接建立时，我们将其添加到 players 对象中。

3. 监听登录和测试事件:

   • 我们监听 login 和 test 事件，并向当前用户发送相应的响应。

4. 广播消息:

   • 我们还监听了一个名为 broadcast_message 的事件，当接收到这个事件时，我们将消息广播给所有用户。

注意事项

• 内存管理: 使用全局对象存储所有用户的 socket 连接可能会导致内存占用过高。建议定期清理不再活跃的用户连接，或者考虑使用其他更高效的数据结构或数据库来存储这些信息。

• 安全性: 在实际应用中，应确保用户数据的安全性，避免潜在的安全风险。

通过上述改进，每个用户都可以正常接收消息，并且可以向所有用户广播消息。