详解RocketMQ 顺序消费机制
💡
原文中文，约2100字，阅读约需5分钟。
📝
内容提要
本文介绍了 RocketMQ 的顺序消息机制，包括分区顺序消息和全局顺序消息。消息的顺序需要在消息发送和消费两个阶段保证，RocketMQ 支持将 Sharding Key 相同的消息序路由到一个队列中，消费者需要保证消费顺序和存储顺序一致。顺序消费需要通过三把锁的机制保证顺序，但在消费者扩容、重启或 Broker 宕机等情况下仍有可能出现乱序，因此消费者的业务逻辑需要保障幂等。
🎯
关键要点
-
顺序消息是指消息严格按照先进先出（FIFO）原则进行发布和消费。
-
顺序消息分为分区顺序消息和全局顺序消息。
-
分区顺序消息根据 Sharding Key 进行区块分区，同一分区内的消息保证顺序。
-
全局顺序消息所有消息严格按照 FIFO 原则来发布和消费。
-
分区顺序消息的并发度和性能高于全局顺序消息。
-
消息的顺序需要在发送和消费两个阶段保证。
-
顺序消息发送时，RocketMQ 支持将 Sharding Key 相同的消息路由到一个队列中。
-
消费者需要保证消费顺序和存储顺序一致。
-
顺序消费通过三把锁的机制保证顺序。
-
消费者扩容、重启或 Broker 宕机可能导致乱序，业务逻辑需保障幂等。
➡️
