使用 Socket.io 更新所有客户端？

Question

是否可以强制所有客户端使用 socket.io 进行更新？我已尝试以下操作，但当新客户端连接时，它似乎不会更新其他客户端：

服务器端 JavaScript：

我正在尝试向所有客户端发送一条消息，其中包含当前已连接用户的数量，它正确发送用户数量......但是，在刷新页面之前，客户端本身似乎不会更新。我希望这是实时发生的。

var clients = 0;
io.sockets.on('connection', function (socket) {
  ++clients;
  socket.emit('users_count', clients);    
  socket.on('disconnect', function () {
    --clients;
  });
});

客户端 JavaScript：

var socket = io.connect('http://localhost');

socket.on('connect', function(){
  socket.on('users_count', function(data){
    $('#client_count').text(data);
    console.log("Connection");
  });
});

Answer 1

它实际上根本不向其他客户端发送更新，而只是向刚刚连接的客户端发送（这就是为什么您在第一次加载时看到更新）

// socket is the *current* socket of the client that just connected
socket.emit('users_count', clients); 

相反，您希望向所有 sockets

io.sockets.emit('users_count', clients);

或者，您可以使用广播函数，它向除启动它的套接字之外的所有人发送消息：

socket.broadcast.emit('users_count', clients);

Answer 2

我发现使用 socket.broadcast.emit() 只会广播到当前的“连接”，但是io.sockets.emit 将向所有客户端广播。
这里服务器正在监听“两个连接”，这正是 2 个套接字命名空间，

io.of('/namespace').on('connection', function(){
    socket.broadcast.emit("hello");
});
io.of('/other namespace').on('connection',function(){/*...*/});

我尝试使用io.sockets.emit()在一个命名空间中，但客户端在另一个命名空间中接收到它。然而 socket.broadcast.emit() 只会广播当前的套接字命名空间。

Answer 3

从socket.io版本0.9开始，“emit”不再对我有用，我一直在使用“send”，

这就是我正在做的：

服务器端：

var num_of_clients = io.sockets.clients().length;
io.sockets.send(num_of_clients);

客户端：< /强>

ws = io.connect...
ws.on('message', function(data)
{
var sampleAttributes = fullData.split(',');
if (sampleAttributes[0]=="NumberOfClients")
        {
            console.log("number of connected clients = "+sampleAttributes[1]);
        }
});

Answer 4

根据此广播。
对于nodejs服务器，你可以使用这个：

io.emit('event_id', {your_property: 'your_property_field'});

一定要初始化websocket，例如：

var express = require('express');
var http = require('http');
var app = express();
var server = http.Server(app);
var io = require('socket.io')(server);

app.get('/', function (req, res) {
    res.send('Hello World!');
    io.emit('event_hello', {message: 'Hello Socket'});
});

server.listen(3000, function () {
  console.log('Example app listening on port 3000!');
});

在这种情况下，当用户到达你的服务器时，将会有“event_hello”广播到所有带有json对象的web-socket客户端 {message: 'Hello插座'}。

Answer 5

您可以按照此示例来实现您的场景。

您可以让所有客户端加入公共房间来发送一些更新。
每个套接字都可以像这样加入房间：

currentSocket.join("client-presence") //can be any name for room

然后您可以让客户端在包含多个客户端数据（id 和状态）的套接字中输入密钥，如果一个客户端的状态发生变化，您可以像这样在套接字上接收更改事件：

socket.on('STATUS_CHANGE',emitClientsPresence(io,namespace,currentSocket); //event name should be same on client & server side for catching and emiting

现在您想要所有其他客户端要获得更新，因此您可以执行以下操作：

emitClientsPresence => (io,namespace,currentSocket) {
  io.of(namespace)
        .to(client-presence)
        .emit('STATUS_CHANGE', { id: "client 1", status: "changed status" });
}

这将向已加入“客户端存在”房间的所有套接字发出 STATUS_CHANGE 事件，然后您可以在客户端捕获相同的事件并更新其他客户端的状态。

Answer 6

这对我有用：

io.in("room1").emit(/* ... */)

正如 socket.io 发出备忘单中所述：https://socket.io/docs/v3/emit-cheatsheet/