1.1 保证顺序性的意义
消息队列中的若干消息如果是对同一个数据进行操作,这些操作具有前后的关系,必须要按前后的顺序执行,否则就会造成数据异常。
举例:
比如通过mysql binlog
进行两个数据库的数据同步,由于对数据库的数据操作是具有顺序性的,如果操作顺序搞反,就会造成不可估量的错误。比如数据库对一条数据依次进行了 插入->更新->删除
操作,这个顺序必须是这样,如果在同步过程中,消息的顺序变成了删除->插入->更新
,那么原本应该被删除的数据,就没有被删除,造成数据的不一致问题。
1.2 出现顺序错乱的场景
我们还是以RabbitMQ为例,后续会陆续更新更多的MQ的解决方案。
1.2.1 错乱场景一
①一个queue
,有多个consumer
去消费,这样就会造成顺序的错误,consumer
从MQ
里面读取数据是有序的,但是每个consumer
的执行时间是不固定的,无法保证先读到消息的consumer
一定先完成操作,这样就会出现消息并没有按照顺序执行,造成数据顺序错误。
1.2.2 错乱场景二
一个queue
对应一个consumer
,但是consumer
里面进行了多线程消费,这样也会造成消息消费顺序错误。
1.3 保证消息的消费顺序
1.3.1 解决方案一
拆分成多个queue
,每个queue
一个consumer
,就是多一些queue
而已,确实是麻烦点;这样也会造成吞吐量下降,可以在消费者内部采用多线程的方式取消费。
1.3.2 解决方案二
或者就一个queue
但是对应一个consumer
,然后这个consumer
内部用内存队列做排队,然后分发给底层不同的worker
来处理
先自我介绍一下,小编13年上师交大毕业,曾经在小公司待过,去过华为OPPO等大厂,18年进入阿里,直到现在。深知大多数初中级java工程师,想要升技能,往往是需要自己摸索成长或是报班学习,但对于培训机构动则近万元的学费,着实压力不小。自己不成体系的自学效率很低又漫长,而且容易碰到天花板技术停止不前。因此我收集了一份《java开发全套学习资料》送给大家,初衷也很简单,就是希望帮助到想自学又不知道该从何学起的朋友,同时减轻大家的负担。添加下方名片,即可获取全套学习资料哦