RocketMq是一款金融级别的消息中间件,作为高可靠的中间件,在需要保证消息顺序性的场景下,可不能掉链子!
那么,RocketMq是如何实现顺序消息的呢?
RocketMq并不保证Topic维度的消息顺序性,而是在Queue维度保证了消息顺序性。RocketMq的消费进程会同步消费Queue中
的消息,且消费过程会一直阻塞,直到消费者返回成功或者由于网络等原因超时,消息的状态才会改变。
那么要保证消息的顺序性,就需要消息生产者将需要保证顺序性的消息发到同一个Queue中。RocketMq客户端通过参数MessageGroup,实现了这个功能。
当然,这么做也有一个缺点,如果过于消息集中在一个Queue中,会降低消息消费的性能。
因为RocketMq设计Queue,正是为了提升消息消费的性能,使得消费者可以通过水平扩展节点数量来提升消费速度。
所以,在需要保证消息顺序性的场景中,我们依然要注意消息在不同Queue中的分散性。
标签:消费,Queue,顺序,保证,消息,RocketMq From: https://www.cnblogs.com/kingcode/p/18205161