node.js - 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();
}