如何在 Socket.IO 中使用 xhr-polling 存储持久数据？

Question

我正在使用 Node.js 和 Socket.IO 编写一个多房间聊天应用程序，我想知道当传输是 xhr-polling 时，如何处理需要在会话期间持续存在的数据。

目前，在客户端上，我正在发送连接时的“加入”事件，该事件传递了很长的几个变量（例如用户名），我使用 Socket.IO 的 get 和 set 方法将其存储在服务器端。然后它们一直可用，直到客户端断开连接。

如果传输是 Websockets，这可以正常工作，但如果它回退到 xhr-polling，则会在每次连接时发出 join 事件，该事件每 5-10 秒发生一次。 （类似地，“某某已离开/加入房间”在每个 xhr-poll 请求上发送，这也是不可取的。）

我不确定最好的前进方式是什么。我无法禁用 xhr-polling，因为它是无闪存 IE 的必要后备。

这里是相关的客户端代码：

socket.on("connect", function(){
    socket.emit("join", { username: username, room: room });
});

在服务器上：

var io = require("socket.io").listen(8124)
, buffer = {}
, max_room_buffer = 15;

io.sockets.on("connection", function(socket) {
    socket.on("join", function(data){
        if(data.username && data.room) {
        socket.set("data", data);
        socket.join(data.room);
        if(!buffer[data.room]) buffer[data.room] = [];
        socket.broadcast.to(data.room).emit("message", "<em>" + data.username + " has joined room " + data.room + "</em>");
        socket.emit("message", "<em>You have joined room " + data.room + "</em>");
        socket.emit("message", buffer[data.room]);
    }
});

socket.on("message", function(message) {
    if(message) {
        socket.get("data", function(err, data){
            if(data) {
                var msg = "<span>" + data.username + ":</span> " + message;
                buffer[data.room].push(msg);
                if(buffer[data.room].length > max_room_buffer) buffer[data.room].shift();
                io.sockets.in(data.room).emit("message", msg);
            }
        });
    }
});

socket.on("disconnect", function () {
    socket.get("data", function(err, data){
        if(data) {
            socket.leave(data.room);
            socket.broadcast.to(data.room).emit("message", "<em>" + data.username + " has left room " + data.room + "</em>");
        }
    });
});

});

提前致谢。

Answer 1

也许我遗漏了一些东西，但这行不通。

客户：

var firstJoin = true;
socket.on("connect", function(){
    socket.emit("join", { username: username, room: room, firstJoin: firstJoin });
    firstJoin = false;
});

服务器：

io.sockets.on("connection", function(socket) {
    socket.on("join", function(data){
        if(data.username && data.room) {
        socket.set("data", data);
        socket.join(data.room);
        if(!buffer[data.room]) buffer[data.room] = [];

        if (data.firstJoin) {
            socket.broadcast.to(data.room).emit("message", "<em>" + data.username + " has joined room " + data.room + "</em>");
            socket.emit("message", "<em>You have joined room " + data.room + "</em>");
            socket.emit("message", buffer[data.room]);
        }
    }
});

至于每次新的轮询都会发生连接事件，这是 XHR 轮询不可避免的结果。由于每次轮询都是一个新的 HTTP 请求，因此之前的请求没有任何状态，因此需要重新设置。

如果您想减少这种情况发生的频率，您可以尝试将轮询持续时间从其默认值 20 增加。例如：

io.configure(function() {
    io.set('polling duration', 60);
});