1

我正在使用 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如果需要,可以用作许多其他功能的替代品。

4

1 回答 1

1

看起来您可以从应用程序中的某些控制流中受益。

看看异步模块。它是直截了当的,将消除使用 setTimeout 的需要。

https://github.com/caolan/async

于 2013-04-03T12:12:20.933 回答