我有一个实时传感应用程序、多个客户端、一个处理服务器。
我有一个问题，我使用 Socket.IO 和 NodeJS 尽可能快地将数据推送到客户端。问题似乎是客户端从服务器上发出的传入数据开始堆积，客户端落后（不同步）。
有了足够的吞吐量，客户端就可以正常运行。有什么办法可以强制执行一项策略，服务器/客户端将丢弃任何早于指定时间段的发射？
数据被丢弃，客户端应该保持最新，所以我不担心丢失超过 2 秒的数据。
【问题讨论】：
标签： javascript performance node.js websocket socket.io
为了帮助可能遇到此问题的其他人，我设计了一个锁定系统，以便服务器仅在套接字空闲时发布数据。
这意味着服务器仍然尽可能快地发布，它只是不会堆叠几个传出的数据请求。请注意，这仅在您的消息被丢弃并且您需要最新信息时才有效。这也意味着消息之间存在一些开销，因为客户端必须通知服务器它已准备好接收更多消息。
然而，这意味着我的应用程序保持最新，不会因请求堆积而落后，如果您在本地运行一个浏览器并通过网络运行另一个浏览器，这在之前很明显。
Server.js
var socket = ...; // Create socket
// Create my data, in my project this updates very quickly
// roughly 60 times per second
var my_data = ...;
// Initially set receiving to false as the socket
// has no outgoing data
socket.set('receiving', false);
// Listen for received event, this indicates
// that the client has received an update
// and is now ready to receive more
socket.on('received', function() {
socket.set('receiving', false);
});
// Function will be called repeatedly to send out data
function update() {
// Check if the socket is receiving any data
socket.get('receiving', function(receiving) {
if(!receiving) {
// Lock the socket from receiving future updates
// by setting the receiving variable to true
socket.set('receiving', true, function() {
// Now emit data
socket.emit('update', my_data);
});
}
});
setTimeout(update, 0); // Recursively call update
}
setTimeout(update, 0); // Start update
Client.js
var socket = io.connect();
socket.on('update', function(data) {
// Store the data for processing
// Tell the server we have received the data
socket.emit('received');
});
【讨论】：
.emit('update' 放在.on('received' 回调中，因为您基本上希望在服务器接收到接收到的事件时发送数据更新。
发送易失性消息，如果无法发送，可以将其丢弃。 Socket.IO 通常会跟踪客户端是否收到消息，但对于易失性消息，此检查不会完成，Socket.IO 进程可以继续，而不是等待：
socket.volatile.emit('event', data);
这是文档所述：
这在功能上基本上是一劳永逸，这些消息不是 当客户端无法接收消息时在内部缓冲 例如，如果客户端有网络问题，或者客户端使用 轮询传输并处于请求/响应周期的中间。
因此，如果您的客户错过了几条消息或 您可能希望将这些事件作为易失性消息发送。
【讨论】：