nodejs Kue作业处理逻辑

Question

我有一个非常简单的逻辑问题。

我将运行在单独的应用程序服务器上设置作业处理逻辑。

我的作业处理应用程序将是一个独立的应用程序，只处理作业。

在我的代码中，如何确保我的应用程序不断检查 redis 服务器的作业？ - 我需要运行无限循环中的代码吗？ - 或者我需要继续重启我的应用程序

或者 Kue 中有一些我在这里缺少的内置机制？

谢谢

Answer 1

查看文档 - https://github.com/Automattic/kue#processing-jobs

虽然有一个队列，但它会不断地运行，并挑选工作。

根据示例：

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

queue.process('email', function(job, done){
  email(job.data.to, done);
});

function email(address, done) {
  if(!isValidEmail(address)) {
    //done('invalid to address') is possible but discouraged
    return done(new Error('invalid to address'));
  }
  // email send stuff...
  done();
}

nodejs Kue作业处理逻辑

nodejs Kue job processing logic

redis

node.js

kue