例如,如果我得到了这个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)秒,并且在有人连接的情况下一直发出这个响应,这样他们就不会有这样的延迟了? 即使有新用户连接(他们没有浏览器缓存)--我指的是服务器缓存
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接受回调函数使用它:)
也许像这样更新你的代码?