0

我正在尝试使用 Redis 并需要队列来接收来自 Redis 的 nodejs 中的实时通知并发布到连接的客户端。为此,我使用了 Kue。阅读 Redis 文档,您订阅了您感兴趣的频道模式,想知道 Kue 是如何实现这一点的。需要一些指向我可以理解的文档或代码的指针。

4

1 回答 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 回答