nsq實現邏輯有序

nsq自己是無序的,若是起多個consumer消費可能會順序混亂。但實際工做中有這種場景,好比用戶更新數據,須要保證兩次更新的前後順序。 所以想到了用隊列實現,建100個隊列起100個線程去處理,nsq的consumer只作最簡單的操做,這裏作的是拿到message,用user_id對100取模,放進相應的隊列裏,而後等到隊列處理完成再手動提交避免重複消費.python # -*- coding:
相關文章
相關標籤/搜索