RocketMQ：面试头痛难题？一文助你搞定！

RocketMQ：面试攻略，轻松应对难题

RocketMQ架构建成解析

RocketMQ 是一套分布式消息中间件，其架构主要由三个角色组成：

1. NameServer：

• 管理和维护 Broker 集群信息，提供 Broker 地址信息。
• 接收 Broker 注册和心跳，监控集群健康状态。
• 提供负载均衡服务，将请求转发至合适 Broker。

2. Broker：

• 核心组件，存储和转发消息。
• 定期发送信息给 NameServer 更新集群信息。
• 支持多种消息存储方式（内存、磁盘）。
• 提供队列管理功能（创建、删除、查询）。

3. Producer/Consumer：

• Producer： 向 RocketMQ 发送消息。
• Consumer： 从 RocketMQ 拉取消息并消费。

消息消费模式：推模式 vs. 拉模式

RocketMQ 支持两种消息消费模式：

1. 推模式：

• Broker 主动将消息推送到 Consumer。
• 降低 Consumer 负载。
• 实时性高，适用于实时场景。

2. 拉模式：

• Consumer 主动从 Broker 拉取消息。
• 灵活控制消息消费速率。
• 消息存储在 Broker 中，断网不丢失。

推拉模式优缺点对比

1. 推模式优点：

• 实时性高。
• 降低 Consumer 负载。
• 架构简单。

2. 推模式缺点：

• 消费速度慢可能导致消息堆积。
• 断网可能导致消息丢失。

3. 拉模式优点：

• 消费速率可控。
• 消息消费精细化控制。
• 断网不丢失消息。

4. 拉模式缺点：

• 实时性较低。
• Consumer 维护连接复杂度增加。

RocketMQ 高频面试题解析

1. RocketMQ 架构是什么？

• 见架构解析。

2. Broker 角色是什么？

• 见架构解析。

3. Producer 角色是什么？

• 发送消息到 RocketMQ。

4. Consumer 角色是什么？

• 拉取消息并消费。

5. RocketMQ 消息消费模式有哪些？

• 推模式、拉模式。

6. 推拉模式区别是什么？

• 见消息消费模式。

7. 推模式优缺点是什么？

• 见推拉模式优缺点对比。

8. 拉模式优缺点是什么？

• 见推拉模式优缺点对比。

9. RocketMQ 支持哪些消息存储方式？

• 内存、磁盘。

10. RocketMQ 提供哪些消息队列管理功能？

• 创建、删除、查询队列。

总结

RocketMQ 是一套广泛应用于分布式系统的消息中间件。掌握其架构、角色和消费模式，是面试成功的关键。

常见问题解答

1. RocketMQ 适用于哪些场景？

• 分布式系统中数据同步、事件通知、消息队列等场景。

2. RocketMQ 与 Kafka 的区别是什么？

• RocketMQ 专注于高吞吐量、低延迟，Kafka 则更注重高可扩展性、高可用性。

3. RocketMQ 消费消息后，怎么保证消息不丢失？

• 拉模式下，消息存储在 Broker 中，断网不丢失。推模式下，可设置消息重试机制。

4. RocketMQ 如何处理消息堆积？

• 通过增加 Broker 数量、调整消息消费速度、使用限流机制等方式。

5. 如何监控 RocketMQ 集群健康状态？

• 通过 RocketMQ 提供的监控工具，如 dashboard、日志分析、度量指标等。