nsq实现逻辑有序

nsq自己是无序的,若是起多个consumer消费可能会顺序混乱。但实际工做中有这种场景,好比用户更新数据,须要保证两次更新的前后顺序。 所以想到了用队列实现,建100个队列起100个线程去处理,nsq的consumer只作最简单的操做,这里作的是拿到message,用user_id对100取模,放进相应的队列里,而后等到队列处理完成再手动提交避免重复消费.python # -*- coding:
相关文章
相关标签/搜索