我正在尝试使用Redis和所需的队列,以便在nodejs中接收来自Redis的实时通知,并发布到连接的客户端。我使用Kue就是为了这个目的。阅读Redis文档,你订阅了一个你感兴趣的渠道模式,想知道Kue是如何做到这一点的。需要一些我可以理解的文档或代码的指针。
发布于 2017-02-07 00:21:07
我以前也想过类似的问题,并四处寻找答案。例如,我假设您指的是通配符作业处理。
queue.process('file:*', function(job, done){
// process any 'file:' job type e.g. 'file:move' 'file:copy'
})但看起来is并非如此。请参阅Wildcard support for job processing
然而,一种解决方法是使用作业类型作为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
}
});https://stackoverflow.com/questions/42071021
复制相似问题