• 25 articles

RocketMQ

核心源码深度剖析，涵盖 Broker 存储、消息流转与高可用机制解析。

All Articles in RocketMQ

Broker 存储含 commitlog、consumequeue、index、config 目录。采用混合存储架构，所有消息顺序写 CommitLog，异步构建消费队列与索引，使用 mmap 与 PageCache 提升性能。

支持三种发送方式与六种消息类型。拉取 Topic 路由，按轮询 + 故障规避选队列。sendKernelImpl 完成编码发送，提供消息级与生产者级故障规避及重试机制。

DefaultMQProducer 启动时校验配置，获取 MQClientInstance 并注册生产者。添加默认主题，启动客户端实例，开启网络、定时拉取路由、清理、负载均衡等后台服务。

DefaultMQProducer 为生产者门面，委托 DefaultMQProducerImpl 执行。包含生产者组、重试次数、超时、压缩阈值等配置。Message 承载 topic、body、属性等消息内容。

Broker 每 30 秒注册路由信息，NameServer 存入五张 Map。每 10 秒扫描剔除 120 秒无心跳 Broker。客户端每 30 秒主动拉取路由，NameServer 不主动推送。

ConsumeMessageConcurrentlyService 使用线程池并发消费。按批次提交任务，执行钩子与业务逻辑，处理成功更新进度，失败回退 Broker 并重试。