【面试宝典】消息队列如何保证顺序性?

  |   0 评论   |   9,114 浏览

面试官:在消息队列里面有一批数据需要顺序执行,如何来保证?

面试官心理剖析:
主要看你有没有思考过这个问题?这个是常见的问题,看你有没有解决思路?

回答:
这里讲讲几个MQ是如何来保证消息的顺序性的。

1、rabbitMq
问题分析:
imagepng
如图,data1和data2是有顺序的,必须data1先执行,data2后执行;这两个数据被不同的消费者消费到了,可能data2先执行,data1后执行,这样原来的顺序就错乱了。

解决方案:
imagepng
如图,在MQ里面创建多个queue,同一规则的数据(对唯一标识进行hash),有顺序的放入MQ的queue里面,消费者只取一个queue里面获取数据消费,这样执行的顺序是有序的。或者还是只有一个queue但是对应一个消费者,然后这个消费者内部用内存队列做排队,然后分发给底层不同的worker来处理。

2、kafka
问题分析:
imagepng
如图,在kafka中,你对数据指定某个key,那么这些数据会到同一个partition里面,在partition里面这些数据是有顺序的。从这里看没啥问题,插入到数据库的数据都是有序的。

但是,我们在消费端可能会使用多线程来处理,因为单线程的处理速度慢,为了加快处理时间和吞吐量,会使用thread来处理。在消费端加入线程之后,就会出现顺序不一致的情况。
imagepng
如图,就是使用了多线程之后,数据顺序不一致情况。

在使用了多线程之后,如何来解决数据顺序问题?
imagepng
如图,在消费端使用内存队列,队列里的数据使用hash进行分发,每个线程对应一个队列,这样可以保证数据的顺序。

3、rocketMq
imagepng

如图,生产者中把orderId进行取模,把相同模的数据放到messagequeue里面,消费者消费同一个messagequeue,只要消费者这边有序消费,那么可以保证数据被顺序消费。

4、activeMq
imagepng
如图,activeMq里面有messageGroups属性,可以指定JMSXGroupID,消费者会消费指定的JMSXGroupID。即保证了顺序性,又解决负载均衡的问题。

本文为博主原创文章,未经博主允许不得转载。

评论

发表评论