RocketMQ的高级特性包括事务消息、顺序消息、SQL消费模式和定时消息。事务消息通过两阶段提交和事务补偿机制实现,保证生产者和消费者的本地事务一致性。顺序消息通过时间轮实现,保证生产和消费的顺序一致性。SQL消费模式可以根据SQL语句过滤消费目标消息,提高性能。定时消息可以指定消息在发送后一定时间后才对消费者可见。RocketMQ还提供了全局高可用技术解决方案,支持异地多活架构。
本文介绍了 RocketMQ 的顺序消息机制,包括分区顺序消息和全局顺序消息。消息的顺序需要在消息发送和消费两个阶段保证,RocketMQ 支持将 Sharding Key 相同的消息序路由到一个队列中,消费者需要保证消费顺序和存储顺序一致。顺序消费需要通过三把锁的机制保证顺序,但在消费者扩容、重启或 Broker 宕机等情况下仍有可能出现乱序,因此消费者的业务逻辑需要保障幂等。
完成下面两步后,将自动完成登录并继续当前操作。