異步任務(wù)中使用隊列

大王更新于2018-07-05

前提：
10（或更多）個商戶，總共有20（或更多）個資金池。
每個商戶下又對應(yīng)的有多個資金池。

（查詢返回慢，所以想用異步去完成，再加上任務(wù)多，再在異步http請求任務(wù)中使用隊列防重復(fù)）

業(yè)務(wù)場景簡述：
默認先在一個文件中寫死一個時間戳，主程序跑多個定時器，檢查是否有新的交易時間戳(操作完成后替換之前的時間戳)，若有，交給異步任務(wù)，異步中的程序：循環(huán)資金池，查詢資金池在"之前交易時間戳"和"當(dāng)前交易時間戳"中是否有資金到賬，若有，根據(jù)關(guān)鍵字段循環(huán)通過接口查詢是哪個商戶下的并請求接口發(fā)起充值。

現(xiàn)在異步任務(wù)用的是（http://doc.workerman.net/315283）
請問：
如果還想在里面加個隊列去處理任務(wù)的話，用https://github.com/walkor/workerman-queue好，還是用workerman文檔中推薦的隊列組件：react/zmq（或react/stomp）。
然后關(guān)于隊列的還有個問題，如何防止多個進程處理了同一個隊列中的任務(wù)，就是怎么做這個互斥。

在此，感謝大佬的回復(fù)！

 5554  1 0