nodejs Kue作业处理逻辑

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

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

我的工作处理应用程序将是一个独立的应用程序，无所事事只是处理工作。

在我的代码中，如何确保我的应用程序不断检查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(); }