时间:2025-01-18 04:01:54
rocketmq消费者消息顺序
RocketMQ消费者消息顺序主要分为全局顺序消息和部分顺序消息。全局顺序消息是指某个Topic下的所有消息都要保证顺序,而部分顺序消息只要保证每一组消息被顺序消费即可。通常我们说的顺序消息是指部分顺序消息。
为了实现顺序消息,需要保证生产者有序存储和消费者有序消费。生产者有序存储可以通过实现MessageQueueSelector接口,使用Hash取模法来保证同一个订单在同一个队列中。消费者有序消费则需要按照发送的顺序来消费。例如,一个订单产生了三条消息分别是订单创建、订单付款、订单完成。消费时要按照这个顺序消费才能有意义,但是同时订单之间是可以并行消费的。RocketMQ可以严格的保证消息有序。
快测评广州东远堂信息科技有限公司版权所有 量子科技网提供支持 粤ICP备15011623号