我正在使用 socket.io 将一些数据从服务器连续发送到客户端。所以我正在使用该setTimeout
功能定期发送数据,并且睡眠时间不是恒定的,所以我没有使用setInterval
,但setTimeout
无法正常工作。我正在使用服务总线从我的工作角色获取一些数据,这些数据会定期转发给客户端。这是我的代码:
var sleepTime;
function requestQueue() {
sleepTime = 0;
console.log("REQUEST QUEUE STARTED");
console.log("SEND to WORKER ROLE");
// send the request to worker role
var broadcastMessage = {}
broadcastMessage.Channel = "World";
broadcastMessage.BufferSize = 10;
sendMessage(socketToWorkerRole, broadcastMessage)
receivePeriodicRecordsQueue(workerRoleToSocket);
}
////
function receivePeriodicRecordsQueue(queue) {
serviceBusService.receiveQueueMessage(queue, function (error, receivedMessage) {
if (!error) {
if (receivedMessage != null) {
var messageBody = receivedMessage.body;
if (messageBody != null) {
// Lots of processing and calculating sleep time
// SET TIMEOUT
if (sleepTime != 0) {
console.log("SLEEP TIME:" + sleepTime);
setTimeout(function () { requestQueue(); }, sleepTime);
}
// sending data to client through socket
io.sockets.emit('broadcast', recordsQueue);
}
}
}
}
else {
console.log(error);
}
})
}
我基本上是一个 C# 程序员,对 JS 很陌生。setTimeout
如果我的实施有误,请告诉我。本质上,我希望requestQueue
使用可变的睡眠时间定期调用该方法
编辑答案:
就我而言,这是一个愚蠢的问题。我以秒为单位使用睡眠时间而不是毫秒。setTimeout
需要毫秒。我已将 Scott 标记为答案,因为我认为 async 模块非常有用,setTimeout
如果需要,可以用作许多其他功能的替代品。