Tag: RocketMQ
All the articles with the tag "RocketMQ".
-
RocketMQ DLedger——基于Raft的CommitLog多数派提交
解析 RocketMQ DLedger 如何将 Raft 共识协议嵌入 CommitLog 写入路径，以多数派提交替代异步复制实现自动故障切换，以及为什么 ConsumeQueue 不参与 Raft 同步。
-
RocketMQ 面试回答——架构、可靠消息、高可用与死信队列
RocketMQ 面试回答三版本：架构设计、消息可靠原理、集群高可用、死信队列的一句话结论与核心原理。
-
RocketMQ延时消息的底层实现
揭开 RocketMQ 延时消息底层实现——Broker 拦截后存入 SCHEDULE_TOPIC_XXXX 内部 Topic，ScheduleMessageService 每秒轮询到期消息恢复投递，引起约 1 秒精度偏差。
-
RocketMQ 顺序消费：从队列路由到线程绑定的完整链路
梳理 RocketMQ 顺序消费的三环接力——生产者取模路由到同一队列、Broker FIFO 存储、Consumer 分布式锁+单线程绑定，以及 SUSPEND_CURRENT_QUEUE_A_MOMENT 的可靠性设计。
-
RocketMQ 消息领域模型：Topic、Tag、MessageQueue、Group 与 Offset 的层次设计
逐层拆解 RocketMQ 五层领域模型——Topic 命名空间、Tag 二级分类、MessageQueue 物理队列、ConsumerGroup 逻辑分组与 Offset 64 位指针，纠正七个常见误解。
-
RocketMQ 消息过滤：Tag 过滤、SQL92 表达式与过滤原理
解析 RocketMQ 三级过滤漏斗——Tag 哈希在 ConsumeQueue 层 O(1)过滤不读磁盘，SQL92 表达式需读 CommitLog 但有灵活性，消费端二次过滤作为最后防线防哈希冲突。
-
RocketMQ 消息积压处理：监控、流控、扩容与 DLQ 的全链路方案
消息积压从发现到消除的全链路方案——监控指标与告警阈值、生产者流控止血、消费端扩缩容与批量优化、DLQ 兜底毒消息，以及基于 Lag 的 K8s 自动弹性伸缩。
-
RocketMQ 消息幂等性：为什么 MessageId 不可靠，以及如何真正去重
剖析 RocketMQ 消息重复的三种来源与为什么 MessageId 不可靠，对比四种幂等方案——数据库唯一索引、Redis SETNX、业务状态机与 Broker 端去重，强调消费端是最后防线。