Съхраняване на върнатата стойност на node.js setTimeout в redis

Не можете да съхранявате обекта в Redis. Методът setTimeout връща Handler (препратка към обект).

Една идея би била да създадете свой собствен асоциативен масив в паметта и да съхраните индекса в Redis. Например:

var nextTimerIndex = 0;
var timerMap = {};

var timer = setTimeout(function(timerIndex) {
    console.log('Ding!');

    // Free timer reference!
    delete timerMap[timerIndex];
}, 5 * 1000, nextTimerIndex);

// Store index in Redis...

// Then, store the timer object for later reference
timerMap[nextTimerIndex++] = timer;

// ...
// To clear the timeout
clearTimeout(timerMap[myTimerIndex]);

Опитвах се да направя същото като OP. Моето решение беше да задам времето за изчакване с условна проверка на нов ключ вътре в изчакването в моя манипулатор за прекъсване на връзката:

redis.hset("userDisconnecting:" + userId, "disconnect", 1);

setTimeout(function() {
    redis.hget("userDisconnecting:" + userId, "disconnect",
     function(err, result) {
        if (result.toString() === "1") {
           //do stuff, like notify other clients of the disconnect.
        }
    });
}, 10000);

След това, когато клиентът се свърже отново, задавам този ключ на 0, така че нещата, които трябва да се задействат при истинско прекъсване на връзката, не се случват:

redis.hset("userDisconnecting:" + userId, "disconnect", 0);

Самите изчаквания не са постоянни при рестартиране на сървъра, но можете да разрешите това, като стартирате метод за почистване при стартиране. Свързаните клиенти биха се върнали „онлайн“ доста бързо.

Този код се използва, когато изчакванията не трябва да са постоянни при рестартиране на сървъра

var timeouts = {};

app.get('/', function (req, res) {
  var index = timeouts.length;
  timeouts[index] = setTimeout(console.log, 1000000, req.user.name);

  redis.set('timeout:' + req.user.name, index, function (err, reply) {
    res.end();
  });
});

app.get('/clear', function (req, res) {
  redis.get('timeout:' + req.user.name, function (err, index) {
   clearTimeout(timeouts[index]);
   delete timeouts[index];
   redis.delete('timeout:' + req.user.name);
   res.end();
  });
});

Ако имате нужда от изчакване, за да бъдете постоянни при рестартиране на сървъра, тогава може да се наложи да съхранявате _idleStart и _idleTimeout стойности за всеки таймер в redis и да ги зареждате при всяко рестартиране на сървъра

app.get('/', function (req, res) {
  var timeout = setTimeout(console.log, 1000000, req.user.name);
  var time = timeout._idleStart.getTime() + timeout._idleTimeout;

  redis.set('timeout:' + req.user.name, time, function (err, reply) {
    res.end();
  });
});

app.get('/clear', function (req, res) {
  redis.delete('timeout:' + req.user.name);
  res.end();
});

// Load timeouts on server start
// *I know this is not the correct redis command*
// *It's not accurate, only approx*
redis.get('timeout:*', function (err, vals) {
  vals.forEach(function (val) {
    var time = val - new Date().getTime();
    setTimeout(console.log, time, username)
  });
});

В по-новите версии на node можете да използвате идентификатора на обекта Timeout вместо самия обект, за да прекратите цикъла.

   redisClient.set('time', JSON.stringify(10))
   let timeoutObject = setInterval(async function(){
      let time = await JSON.parse(redisClient.get('time'))
      if(time === 0){
       let intervalId = await JSON.parse(redisClient.get('intervalId'))
       clearInterval(intervalId)
      }
       time -= 1
       redisClient.set('time', JSON.stringify(time))
    }, 1000)
    
    let intervalId = timeoutObject[Symbol.toPrimitive]()
    redisClient.set('intervalId', JSON.stringify(intervalId))

Това е само пример за таймер, изграден с комбинирани setInterval и redis. Както можете да видите, можете да вземете идентификатора на обекта Timeout и да го съхраните, за да прекратите изпълнението на setInterval, вместо да се опитвате да съхраните целия обект.

Ето връзката към документите на възела: https://nodejs.org/api/timers.html#timers_timeout_symbol_toprimitive