3

我试图允许用户从客户端设置警报并将其传递给服务器。然后服务器有一个 setTimeout 倒计时，当时间用完时，执行该函数。

第一部分工作正常，但是，如果客户端决定取消该特定警报，我需要能够清除相同的超时。

注意：我一直在使用 Redis 存储各种数据，因此可用。

var client = redis.createClient();
io.set("store", new sio.RedisStore);

io.sockets.on('connection', function (socket) {

socket.on('alarm:config', function(list, date, time, bool) {

  if (bool) {

    var now = new Date().getTime();

    var year = date[0],
        month = date[1] - 1,
        day = date[2];

    var hour = time[0],
        minutes = time[1];

    var alarm = new Date(year, month, day, hour, minutes);

    var countdown = alarm - now;

    var myAlarm = setTimeout(function() {

      // do stuff...

    }, ( countdown ) );

  } else {

    clearTimeout(myAlarm);

  }

});
});

我想到的方法是我将使用布尔值来确定用户是否正在设置或取消该特定警报。我意识到设置一个局部变量“myAlarm”是行不通的，我只是把它放在那里传达这个想法。

我试图找出一种方法来存储对该确切超时的引用，以便下次使用错误的布尔值触发“alarm：config”套接字事件时，它可以取消之前设置的超时。

这可能是另一个问题，但是像谷歌日历这样的应用程序如何存储日期和时间，然后准确地知道何时触发它以及提供取消它的能力？这基本上是相同的想法。

更新：我使用以下解决方案让它工作。我愿意接受更优雅的解决方案。

socket.on('alarm:config', function(list, date, time, bool) {

  var alarmName = "timer:" + list;

  if (bool) {

    client.hset(alarmName, "status", true);

    var now = new Date().getTime();

    var year = date[0],
        month = date[1] - 1,
        day = date[2];

    var hour = time[0],
        minutes = time[1];

    var alarm = new Date(year, month, day, hour, minutes);

    var countdown = alarm - now;

    setTimeout(function() {

      client.hget(alarmName, "status", function(err, bool) {

        if(bool == 'true') {

          // do stuff...

        } else {

          console.log("This alarm has been canceled.");

        }

      });

    }, ( countdown ) );

  } else {

    console.log('canceling alarm');
    client.hset(alarmName, "status", false);

  }
});
4

1 回答 1

1

根据您正在构建的应用程序的大小，有几个选项。

处理队列

您可以重组您的应用程序以使用作业队列，而不是简单地设置计时器。这有一个优点，您可以在将来将其拆分为多个进程，但它确实使处理变得有点复杂。

像Kue这样的库只使用 Redis，并允许您在将来执行延迟设置事件。

从 Kue 自述文件开始：

var kue = require('kue')
  , jobs = kue.createQueue();

// Create delayed job (need to store email.id in redis as well)
var email = jobs.create('email', {
    title: 'Account renewal required',
    to: 'tj@learnboost.com',
    template: 'renewal-email'
}).delay(minute).save();

// Process job
jobs.process('email', function(job, done){
  email(job.data.to, done);
});

// Cancel job
email.remove(function(err){
  if (err) throw err;
  console.log('removed completed job #%d', job.id);
});

存储对超时的引用

这不那么健壮，但可以让您非常简单地做到这一点。它使全局变量四处浮动，并且如果进程崩溃则无法恢复。

基本上，您将计时器存储在全局变量中并根据作业 ID 取消它。

var myAlarms = {}

socket.on('alarm:config', function(list, date, time, bool) {
  var alarmName = "timer:" + list;

  if (bool) {

    myAlarms[alarmName] = setTimeout(function() {
      // do stuff...
    }, countdown);

  } else {
    clearTimeout(myAlarms[alarmName]);
  }
}

注意：此代码均未经过测试，可能包含错误。

于 2013-02-27T22:45:19.250 回答