面试题：RocketMQ 的广播模式与集群模式有什么区别？

一、核心区别总览

特性	集群模式 (CLUSTERING)	广播模式 (BROADCASTING)
消息分发方式	每条消息只被一个消费者实例消费	每条消息被所有消费者实例消费
消费进度存储	Broker 端集中存储	各消费者本地存储
横向扩展性	可通过增加消费者实例提高消费能力	增加实例会导致重复消费
典型应用场景	负载均衡型业务（如订单处理）	数据同步型业务（如配置推送）
消息重试机制	支持	不支持
死信队列	支持	不支持

二、工作原理解析

1. 集群模式架构

graph TD
    Producer -->|消息| Broker
    Broker -->|分配消息| Consumer1
    Broker -->|分配消息| Consumer2
    Broker -->|分配消息| Consumer3

消息分配：采用队列负载均衡机制（平均分配/一致性Hash）
进度同步：消费位点(Offset)由Broker统一管理

2. 广播模式架构

graph TD
    Producer -->|消息| Broker
    Broker -->|全量推送| Consumer1
    Broker -->|全量推送| Consumer2
    Broker -->|全量推送| Consumer3

消息推送：每个消费者实例获取全量消息
进度管理：各实例独立维护本地消费位点

三、配置方式对比

1. 集群模式配置（默认）

// 消费者配置
DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("consumer_group");
consumer.setMessageModel(MessageModel.CLUSTERING);  // 默认值可不设置
consumer.subscribe("TopicTest", "*");

2. 广播模式配置

// 消费者配置
DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("consumer_group");
consumer.setMessageModel(MessageModel.BROADCASTING);  // 显式设置广播模式
consumer.subscribe("TopicTest", "*");

四、关键差异详解

1. 消息投递机制

集群模式：
- 每个MessageQueue同一时间只分配给一个消费者
- 自动进行Rebalance保证负载均衡
广播模式：
- 所有消费者都接收全量消息
- 无消息分配均衡机制

2. 消费进度管理

集群模式：

# 查看集群消费进度
sh mqadmin consumerProgress -n namesrv:9876 -g consumer_group

广播模式：
- 进度文件存储在本地：~/.rocketmq_offsets/consumer_group/offsets.json
- 各实例进度独立，无法统一查看

3. 异常处理差异

场景	集群模式	广播模式
消费失败	自动重试（可配置次数）	直接跳过，无重试
消费者宕机	消息由其他实例接管	该实例未消费消息丢失
Broker宕机恢复	从最后提交的Offset继续消费	各实例根据本地记录恢复

五、生产环境选型建议

适合集群模式的场景

需要水平扩展的消费能力
消息处理耗时较长的业务
要求消息顺序处理的场景（配合顺序消费）
需要利用死信队列进行异常处理的业务

适合广播模式的场景

全局配置/规则变更通知
本地缓存数据刷新
需要全节点执行的操作（如日志清理）
消息量小但需要全节点感知的场景

六、高级特性对比

1. 消息堆积处理

集群模式：
- 可通过增加消费者实例分担负载
- 支持重置消费位点
广播模式：
- 每个实例都需要处理全量消息
- 无法通过扩容解决堆积问题

2. 与顺序消费的关系

集群模式：

// 可配合顺序消费使用
consumer.registerMessageListener(new MessageListenerOrderly() {...});

广播模式：
- 顺序消费在广播模式下无意义
- 各实例处理顺序无法保证全局一致

七、运维监控要点

1. 集群模式监控

# 查看消费延迟
sh mqadmin consumerStatus -n namesrv:9876 -g consumer_group

# 查看积压消息
sh mqadmin consumerProgress -n namesrv:9876 | grep DIFF

2. 广播模式监控

需要登录各消费者机器检查：

# 检查本地进度文件
cat ~/.rocketmq_offsets/consumer_group/offsets.json

# 对比Broker最新消息时间戳
sh mqadmin queryMsgByTopic -n namesrv:9876 -t TopicTest -1

八、错误使用案例

1. 广播模式误用

// 错误：在需要负载均衡的场景使用广播
consumer.setMessageModel(MessageModel.BROADCASTING);
// 导致所有节点重复处理相同订单

2. 集群模式误用

// 错误：在需要全节点通知的场景使用集群
consumer.setMessageModel(MessageModel.CLUSTERING);
// 导致部分节点收不到配置更新

正确选择消息模式需要根据业务语义而非性能考虑，广播模式虽然看起来”简单可靠”，但不适合大多数高吞吐量场景。

THE END

RocketMQ 面试题