Tag: RocketMQ
All the articles with the tag "RocketMQ".
-
RocketMQ死信队列——16次重试后的最终兜底
解析 RocketMQ 死信队列作为 16 次重试后的最终防线——延迟递增重试策略防止资源浪费,DLQ 隔离毒消息保障正常流,人工介入修复后手动回放。
-
RocketMQ架构——为什么CommitLog所有Topic共用一份文件
剖析 RocketMQ 三个核心架构取舍——CommitLog 单文件顺序追加实现极致写性能,ConsumeQueue 固定 20 字节二级索引换一次随机读,NameServer 无主设计换零运维。
-
RocketMQ 延时消息原理:18 级延时与 SCHEDULE_TOPIC_XXXX 揭秘
拆解 RocketMQ 18 级延时消息的完整生命周期——从写入 SCHEDULE_TOPIC_XXXX 按 delayLevel 分 Queue,到 ScheduleMessageService 定时扫描投递,展示时间分桶替代独立计时的架构取舍。
-
RocketMQ 刷盘机制:同步刷盘、异步刷盘与顺序写磁盘
详解 RocketMQ 同步刷盘与异步刷盘的区别,深入 mmap 内存映射文件与顺序写磁盘如何实现高吞吐,以及 GroupCommit 组提交优化同步刷盘性能。
-
RocketMQ事务消息——Half Message的两阶段提交
拆解 RocketMQ 事务消息的 Half Message 二阶段提交机制——消息先写 RMQ_SYS_TRANS_HALF_TOPIC 不可见,本地事务执行后 Commit/Rollback,回查机制兜底网络丢包。
-
RocketMQ vs Kafka:性能、功能与适用场景的全维度对比
全维度对比 RocketMQ 与 Kafka 的性能、存储模型、功能矩阵与生态差异——为什么 Kafka 怕多 Topic,以及 sendfile 与 mmap 零拷贝实现的不同取舍。
-
RocketMQ ConsumeQueue 索引:20 字节条目如何精准定位消息
深入解析 ConsumeQueue 固定 20 字节索引条目的设计精妙——8 字节 CommitLog 偏移+4 字节大小+8 字节 Tag 哈希,实现 O(1)消息定位的二级索引体系。