Redis 进行定时任务的操作

在这之前如果你在进行nodejs程序开发的时候需要用到定时任务执行时，你会怎么做呢？，一开始的想法就是百度 nodejs 定时任务，基本上所有的内容都是node-schedule

并没有说这种方式是不行的，那有没有更高级一点的方式或者说另外一种方式。答案是有的，我们可以用redis来实现定时器的效果

通过查询网上的资料和别人的实现方式，大概整理了如下思路。

Redis 在 2.0.0 之后推出了 Pub / Sub 的指令，可以订阅和发送特定频道消息。
Redis 的 2.8.0 版本之后，其推出了一个新的特性——键空间消息通知（Redis Keyspace Notifications)
就是如果我订阅了键空间消息，那我就可以完成定时任务了。（通知订阅缓存的过期事件，获取对应的key值，使用key值来调用对应任务。而缓存的过期时间则表示任务的具体执行时间） >.<

方案

更改redis的配置文件
```
notify-keyspace-events Ex
```
连接的客户需要开启订阅的功能
```
client.on('ready', () => {
 client.psubscribe('__keyevent@' + 0 + '__:expired');
});
```
上边的参数什么意思呢实际上就是在db0上订阅了一个keyevent 过期的事件。

接下来假定我们设置了一个key 过期时间为1分钟。那么就需要实现key过期后的处理逻辑了

client.on("pmessage", function (pattern, channel, expiredKey) {

var taskname = expiredKey;
const body = taskname.split('❤️');
if (body.length !== 3) {
return;
    }
switch(body[0]) {
case 'productTask:':
            redisUtils.initProductTask();
break;
case 'testPlanTask:':
            redisUtils.initTestPlanTask();
break;
default: 
break;
    }
var func = body[1].split('|');
var path = func[0];
var params = body[2];
    func = func[1];
var mod;
try {
        mod = require('./' + path);
    } catch (e) {
        log4js.error("Failed to load module", path);
        log4js.error(e.stack);
return;
    }
    mod[func].apply(null, [params]);
});

这里我们用了一个比较巧妙的方法，将要执行的方法以及文件的路径都写在了key里面所以我们在解析的时候就很方便，并且方法也很通用了。我们看看key的命名规则吧。

 client.set('productTask:❤️../dataPlatform/updateInfo|test❤️' + nowTime, '')

../dataPlatform/updateInfo|test 中 ../dataPlatform/updateInfo 实际就是要加载的路径了，而test则是要执行的方法了，通过node apply的方法就可以一步到位了。

秒客网

Redis 进行定时任务的操作

方案

相关文章