Redis 进行定时任务的操作

时间:2022-02-25 21:26:47

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

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

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

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

方案

  1. 更改redis的配置文件

    notify-keyspace-events Ex
  2. 连接的客户需要开启订阅的功能

    client.on('ready', () => {
    client.psubscribe('__keyevent@' + 0 + '__:expired');
    })
    ;

    上边的参数什么意思呢 实际上就是在db0上订阅了一个keyevent 过期的事件。

  3. 接下来假定我们设置了一个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的方法就可以一步到位了。