提问者:小点点

有没有缓存Socket.IO响应的方法?


例如,如果我得到了这个WebSocket:

let itemsArray = [];

function fetchData() {
  itemsArray = await db.query(`SELECT * FROM Items`);
}

function emitData() {
  io.sockets.in("room_foo").emit("data", JSON.stringify(itemsArray));
}

setInterval(() => fetchData(), 2500);
setInterval(() => emitData(), 5000);

基本上,这意味着:每5秒将JSON数组流到ROOM_FOO中的所有客户机,并每2.5秒提取一次数据

现在,问题来了。 当我连接到那个WebSocket时,我必须等待5秒,直到下一个emit事件发生。

有没有一种方法可以将先前的响应缓存X(在这个特定的情况下为5)秒,并且在有人连接的情况下一直发出这个响应,这样他们就不会有这样的延迟了? 即使有新用户连接(他们没有浏览器缓存)--我指的是服务器缓存


共1个答案

匿名用户

let itemsArray = [];

function fetchData() {
  itemsArray = await db.query(`SELECT * FROM Items`);
  io.sockets.in("room_foo").emit("data", JSON.stringify(itemsArray));
}
setInterval(() => fetchData(), 2500);

io.on('connection', (socket) => {
  // if user gets in to room_foo then send it so
  socket.join('room_foo', () => {
    io.sockets.in("room_foo").emit("data", JSON.stringify(itemsArray));
  })
});

所以join接受回调函数使用它:)

也许像这样更新你的代码?