node.js – 如何使用节点接收Redis过期事件？

必须使用seTinterval函数来检查值是否定期过期.我知道这不等于听事件.但是,它间接地起到了作用.

以下代码每5秒检查一次值.

const redis = require('redis');
const client = redis.createClient();
const subscriber = redis.createClient();
const KEY_EXPIRING_TIME = 10; // seconds

var args = ['myKey','myValue'];


client.setex('myKey',function (err) {
  console.log('subscribed!');
});

seTinterval(function() {  
  client.get('myKey',function(err,value) {
    if (err) {
      throw err;
    }
    if (value) {
      console.log('value:',value);
    }
    else {
      console.log('value is gone');
      process.exit();
    }
  });
},5e3);

方法2： –

redis-notifier可用于收听事件.但是,它需要Python> = v2.5.0& < 3.0.0以便安装此软件包.

redis-notifier

var redisNotifier = require('redis-notifier');

var eventNotifier = new redisNotifier(redis,{
  redis : { host : '127.0.0.1',port : 6379 },expired : true,evicted : true,logLevel : 'DEBUG' //Defaults To INFO 
});

//Listen for event emission 
eventNotifier.on('message',function(pattern,chAnnelPattern,emittedKey) {
  var chAnnel = this.parsemessageChAnnel(chAnnelPattern);
  switch(chAnnel.key) {
    case 'expired':
        this._handleExpired(emittedKey);
      break;
    case "evicted":
      this._handleEvicted(emittedKey);
      break;
    default:
      logger.debug("Unrecognized ChAnnel Type:" + chAnnel.typE);
  }
});