持续更新中

RocketMQ常见面试题

RocketMQ原理、对比、MetaQ原理

RocketMQ作为阿里巴巴开源的分布式消息中间件，在面试中经常被问到。以下是一些常见的面试题目及其简要解析，帮助你准备相关面试：

基本概念与架构

1. RocketMQ是什么？它的主要特点有哪些？
   • RocketMQ是阿里巴巴开源的分布式消息中间件，具有低延迟、高吞吐、高可用、可扩展的特点。它支持多种消息模式，如点对点、发布/订阅，并且特别适合大规模分布式系统中的消息传输。
2. RocketMQ的架构组成部分有哪些？
   • 主要包括NameServer集群、Broker集群、Producer、Consumer四大组件。NameServer负责管理路由信息；Broker负责消息的存储与转发；Producer负责发送消息；Consumer负责消费消息。

消息模型与特性

1. RocketMQ支持哪几种消息模型？
   • 支持普通消息（Queue模型）、顺序消息、广播消息、延迟消息、事务消息等。
2. RocketMQ如何保证消息的顺序性？
   • 通过顺序消息模型实现，生产者在同一个队列内发送消息，消费者按序消费。对于需要全局顺序的场景，可以使用单队列的方式。
3. 事务消息的工作原理是什么？
   • 事务消息通过半事务消息、提交或回滚操作实现。首先发送半事务消息到Broker，然后根据业务执行结果决定提交或回滚，确保消息最终一致。

高可用与性能

1. RocketMQ如何保证高可用？
   • 通过Broker的主从部署、多Master部署、NameServer集群、消息刷盘策略（SYNC/ASYNC）、Broker自动发现与故障转移等机制确保高可用。
2. RocketMQ的性能优化措施有哪些？
   • 批量发送与消费、异步刷盘、消息压缩、合理的队列与主题设计、消息预取、使用ConsumeThread池等。

深入技术点

1. RocketMQ的消息存储机制是怎样的？
   • RocketMQ使用CommitLog作为主要的消息存储文件，同时有ConsumeQueue用于快速定位消息，以及IndexFile用于消息查询。
2. 如何理解RocketMQ的Rebalance机制？
   • Rebalance是指Consumer端在订阅关系发生变化（如新增Consumer实例、主题变化）时，重新分配队列给Consumer的过程，以确保消息公平消费。
3. RocketMQ如何实现消息的持久化与缓存？
   • 消息首先写入CommitLog（磁盘），然后通过ConsumeQueue（也是磁盘存储）进行索引，同时Broker还维护了内存映射文件（MappedByteBuffer）以提高消息读取效率。

掌握以上知识点，并结合实际项目经验进行阐述，将有助于在面试中展现你的RocketMQ理解和应用能力。