node.js - Redis中添加新作业时如何获得通知

Question

我正在我的nodejs应用程序中使用Kue实现redis队列。我有一个 API，可以将电子邮件添加到. 让 cron 作业监听新作业是一种好习惯，还是有一种方法可以在输入新电子邮件并从单独的应用程序捕获以处理它时从应用程序触发事件。我对正确的方法有点困惑。jobsemail queueredis email queuenode.jsjobnode.js

Answer 1

首先，Kue 提供了一些好的事件：

https://github.com/Automattic/kue#queue-events

queue.on('job enqueue', function(id, type){
  console.log( 'Job %s got queued of type %s', id, type );
});

但是，从您的问题看来，您不仅希望收到队列中作业的通知，而且还希望在这些作业入队时对其进行处理。

https://github.com/Automattic/kue#processing-jobs

queue.process('email', function(job, done){
  // do something with job.data
  // callback to done
  email(job.data.to, done);
});