我正在尝试使用 Redis 并需要队列来接收来自 Redis 的 nodejs 中的实时通知并发布到连接的客户端。为此,我使用了 Kue。阅读 Redis 文档,您订阅了您感兴趣的频道模式,想知道 Kue 是如何实现这一点的。需要一些指向我可以理解的文档或代码的指针。
问问题
94 次
1 回答
0
我过去也有类似的想法,并一直在寻找答案。例如,我认为您的意思是通配符作业处理。
queue.process('file:*', function(job, done){
// process any 'file:' job type e.g. 'file:move' 'file:copy'
})
看来事实并非如此。请参阅作业处理的通配符支持
然而,一种解决方法是使用作业类型作为file
部件,然后在作业数据中设置一个任务名称,然后您可以尝试自己处理。例如...
queue.process('file', function(err, done){
var taskType = job.data.taskType;
switch (taskType){
case 'move':
// do move job
break;
case 'copy':
// do copy job
break;
default:
// do something else
}
});
于 2017-02-06T16:21:07.190 回答