如何保证消息的顺序性?
MQ必问话题
一个MySQL binlog同步系统,日同步数据达到上亿.
增删改
一条数据应该得保证消息按照顺序执行的吧! 不然本来是:增加->修改->删除 你楞是换了顺序给执行成:删除->修改->增加 全错!!!
该数据同步过来,最后本该被删除,结果你搞错顺序,最后它却被保留下来了,数据同步出错!
一个queue,多个consumer,这不明显乱了
一个topic,一个partition,一个consumer,内部多线程,这也明显乱了
拆分多个queue,每个queue一个consumer 就是多一些queue而已,确实麻烦点 或者就一个queue但是对应一个consumer,然后这个consumer内部用内存队列做排队,然后分发给底层不同的worker来处理
一个topic,一个partition,一个consumer,内部单线程消费,写N个内存queue,然后N个线程分别消费一个内存queue即可