2017-02-06 51 views
0

我正在嘗試使用Redis並需要隊列接收來自Redis的nodejs中的實時通知併發布到已連接的客戶端。我爲此目的使用了Kue。 閱讀Redis文檔,您訂閱了您感興趣的頻道模式,想知道Kue如何實現這一目標。需要一些指向文檔或代碼的地方,我可以理解這一點。Kue是否使用Redis訂閱任何(*)模式?

回答

0

我以前想過類似的問題,並已經找到答案。我認爲你的意思是通配作業處理,例如..

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 
    } 
}); 
相關問題