“你了解RocketMQ的高级原理和源码吗？”
面试官推了推眼镜，嘴角带笑，眼神里透着一丝轻蔑。奇哥笑而不语，开始表演。
面试场景描写
公司位于高楼林立的CBD，电梯直达28楼。面试室宽敞明亮，空气中混着咖啡香与新人的焦虑气息。
面试官身穿格子衬衫，黑框眼镜，手持一杯“星爸爸”，坐在办公桌后，摆出一副“我准备教育教育你”的姿态。
而奇哥，穿着普通白T，牛仔裤，双手插兜，一副初出茅庐的“菜鸟”模样。
面试官提问
“RocketMQ你用过吗？高级特性和源码看过吗？”
奇哥先是一脸迷茫，忽然眼神一变，开启高能输出模式。
RocketMQ高级原理剖析
1. Topic与Queue结构设计
RocketMQ 使用 多队列模型 来提升吞吐量。每个 Topic 被划分为多个 Queue，生产者发送消息时通过轮询或 Hash 分发到不同的 Queue。
TopicA
└── Queue0
└── Queue1
└── Queue2
这样可以实现 负载均衡 与 并行消费。
2. Broker 架构 & 主从同步
RocketMQ 的 Broker 有以下角色：
- Master：接收生产者消息、处理消费请求；
- Slave：同步主节点数据，用于高可用。
主从同步支持同步、异步两种机制，满足不同的消息可靠性要求。
3. 消息存储机制
消息存储由 CommitLog（主文件）、ConsumeQueue（消费队列）和 IndexFile（索引文件）组成，采用 顺序写磁盘 提高性能。
- CommitLog：所有消息顺序追加写入；
- ConsumeQueue：逻辑队列，消费位移管理；
- IndexFile：支持通过Key快速定位消息。
4. 消息投递机制
RocketMQ 消息推送有两种模式：
- Push模式：消费者监听Broker回调；
- Pull模式：消费者主动拉取消息。
底层使用 长轮询机制 优化消息实时性。
源码解读关键点
消息发送源码（DefaultMQProducer）
关键方法：sendKernelImpl
涉及核心类：
MQClientInstance：维护连接、心跳、路由表；RemotingClient：底层Netty通信；MessageClientIDSetter：设置唯一标识；SendMessageRequestHeader：封装请求头。
消息存储源码（CommitLog）
关键类：
CommitLog：顺序写入消息；MappedFileQueue：管理映射文件；FlushRealTimeService：刷盘服务线程；DefaultMessageStore：协调存储、刷盘、清理等。
面试官反应
面试官原本自信满满，听着奇哥将RocketMQ机制与源码一口气梳理下来，脸上的笑容逐渐凝固，额头渗出汗珠。
“你不是说自己只用过Kafka吗……”
奇哥淡定一笑：“RocketMQ？我用Kafka时顺便看了下它的源码，凑合讲讲。”
面试结语
面试官站起身，深深地看了奇哥一眼。
“你明天能来上班吗？”
奇哥摇头：
“不了，我还要去隔壁公司吊打一个问我Kafka源码的面试官。”
总结
RocketMQ 高级特性包括：
- 多队列高并发设计；
- 高可用主从架构；
- 高性能顺序写消息存储；
- 灵活的投递模式；
- 精妙的源码设计。
面试不仅要懂“用”，更要懂“底层”。下一场面试，可能又是奇哥表演的舞台。
作者：奇哥，专注把面试官讲哭。