0
我正在嘗試使用Redis並需要隊列接收來自Redis的nodejs中的實時通知併發布到已連接的客戶端。我爲此目的使用了Kue。 閱讀Redis文檔,您訂閱了您感興趣的頻道模式,想知道Kue如何實現這一目標。需要一些指向文檔或代碼的地方,我可以理解這一點。Kue是否使用Redis訂閱任何(*)模式?
我正在嘗試使用Redis並需要隊列接收來自Redis的nodejs中的實時通知併發布到已連接的客戶端。我爲此目的使用了Kue。 閱讀Redis文檔,您訂閱了您感興趣的頻道模式,想知道Kue如何實現這一目標。需要一些指向文檔或代碼的地方,我可以理解這一點。Kue是否使用Redis訂閱任何(*)模式?
我以前想過類似的問題,並已經找到答案。我認爲你的意思是通配作業處理,例如..
queue.process('file:*', function(job, done){
// process any 'file:' job type e.g. 'file:move' 'file:copy'
})
而且看起來並不是這樣。請參閱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
}
});