Nodejs 请教一个问题 关于socket.broadcast.emit

Nodejs 请教一个问题 关于socket.broadcast.emit

刚刚开始接触node.js 想请教这么个问题： 一个连接的客户端向socket服务器传递了一些消息，然后由socket把这个消息向所有连接的客户端传播。我想知道，为何最初发送消息的客户无法接收到这个传播的消息？有什么办法让那个客户端也收到消息吗？

io.sockets.on(‘connection’, function (socket) { socket.on(‘message’, function (data) { socket.broadcast.emit(‘push message’, data); }); });


4 回复

当然可以！以下是针对你提出的问题的详细解答：

问题描述

在使用 Socket.IO 进行实时通信时，你希望当一个客户端发送一条消息到服务器后，该消息能够被广播给其他所有连接的客户端。然而，你发现最初的发送者没有收到这条消息。

原因分析

当你使用 socket.broadcast.emit 方法时，它会将消息发送给除了当前 socket 之外的所有连接的客户端。因此，发送消息的客户端本身不会收到这条消息。

解决方案

如果你希望发送消息的客户端也能收到消息，你需要显式地将消息发送给自己。你可以通过 socket.emit 方法来实现这一点。

示例代码

const io = require('socket.io')(server);

io.on('connection', function(socket) {
    console.log('A user connected:', socket.id);

    socket.on('message', function(data) {
        // 广播消息给除自己以外的所有客户端
        socket.broadcast.emit('push message', data);

        // 向自己发送消息
        socket.emit('push message', data);
    });

    socket.on('disconnect', function() {
        console.log('A user disconnected:', socket.id);
    });
});

解释

  1. 连接处理：

    • 当有新的客户端连接时，会在控制台打印出连接的客户端 ID。

  2. 消息处理：

    • 当客户端发送消息时，首先使用 socket.broadcast.emit 将消息广播给其他所有客户端。
    • 然后使用 socket.emit 将消息发送给自己。

  3. 断开连接处理：

    • 当客户端断开连接时，会在控制台打印出断开连接的客户端 ID。

总结

通过上述代码，你可以确保发送消息的客户端也能接收到消息。这种方法简单且直接，适用于大多数需要双向通信的场景。希望这能帮助你解决问题！


自己要接收,那把想要触发的写在send那里就好了,没必要接收

io.sockets.on(‘connection’, function (socket) { socket.on(‘message’, function (data) { socket.broadcast.emit(‘push message’, data); socket.emit(‘push message_done’,data); //再增加条呗。。。 }); });

当你使用 socket.broadcast.emit 时，它只会将消息发送给除发送消息的客户端之外的所有其他客户端。如果你希望发送消息的客户端也能收到这条消息，你需要显式地将消息发送给该客户端。

你可以通过将消息同时发送给当前的 socket 和其他客户端来实现这一点。示例如下：

io.sockets.on('connection', function(socket) {
    socket.on('message', function(data) {
        // 发送消息给所有其他客户端
        socket.broadcast.emit('push message', data);

        // 发送消息给当前客户端
        socket.emit('push message', data);
    });
});

解释

  1. socket.broadcast.emit:

    • 这行代码将消息发送给除了当前 socket 之外的所有已连接的客户端。

  2. socket.emit:

    • 这行代码将消息发送回给当前的 socket（即发送消息的客户端）。

这样，发送消息的客户端也会接收到自己发出的消息，并且所有其他客户端也会接收到该消息。

如果你不想重复处理逻辑，可以将发送消息的逻辑封装到一个函数中，然后分别调用两次这个函数：

function sendMessageToAll(data) {
    io.sockets.emit('push message', data);
}

io.sockets.on('connection', function(socket) {
    socket.on('message', function(data) {
        // 发送消息给所有客户端（包括当前客户端）
        sendMessageToAll(data);
    });
});

这种方法更简洁，而且避免了重复代码。

回到顶部