核心概念高频问答

面试问题：什么是消息队列？它的核心作用是什么？

面试官考察点：考察对消息队列本质的理解，是否清楚引入消息队列能解决哪些分布式系统痛点（耦合、耗时、流量），以及可能引入的新问题（复杂度、一致性）。

回答框架

1. 一句话定义：消息队列是一种异步通信的中间件，用于在系统之间传递数据。
2. 三大核心作用：
   – 解耦：上下游系统不直接依赖，通过消息队列隔离变化。
   – 异步：非阻塞处理，提高系统吞吐和响应速度。
   – 削峰填谷：平缓流量突刺，保护后端系统。
3. 补充说明：引入后需考虑消息丢失、重复消费、顺序保证等挑战。

简短示例回答（约80字）：

消息队列是异步通信组件，核心解耦、异步、削峰。例如秒杀场景，前端请求入队后立即返回，后端按能力消费，避免流量冲垮订单库。当然，也带来消息丢失、重复消费等挑战，需配合ACK机制和幂等设计。

可能追问

• 消息队列如何保证消息不丢失？（生产端/服务端/消费端）
• 消息重复了怎么办？幂等性如何实现？
• 什么时候不该用消息队列？

面试问题：点对点模型和发布订阅模型的区别？

面试官考察点：是否理解两种模型的核心差异（消费关系、消息路由），以及在实际系统中如何选择。考察对 Group 概念的理解。

回答框架

1. 核心区别：
   – 点对点（Queue）：一条消息只能被一个消费者消费（竞争消费）。
   – 发布订阅（Topic）：一条消息可以被多个消费者组消费，每个组内只有一个消费者收到。
2. 选型依据：点对点适合任务分配、异步处理；发布订阅适合事件广播、多系统同步。
3. 关键机制：Consumer Group 实现广播与负载均衡的结合。

简短示例回答（约75字）：

点对点模型每条消息只有一个消费者拉取，适合订单处理等任务分发；发布订阅模型通过 Consumer Group 实现广播，每个组都能收到全量消息，适合日志同步、缓存更新。核心差别是消费方是否需要“重复消费”。

可能追问

• 同一个 Consumer Group 内如何分配 Partition？
• 如果某个消费者挂了，消息会丢失吗？
• 如何实现“每条消息被多个独立应用消费”？

面试问题：请解释消息队列中常用术语：Producer、Consumer、Topic、Partition、Offset、Broker。

面试官考察点：考察对消息队列基本架构的了解程度，是否能用简洁语言串联各组件关系，隐含对消息存储和位移管理的理解。

回答框架

1. 架构链路：Producer → Broker(Topic + Partition) → Consumer。
2. 术语逐个解释：
   – Producer：消息生产方，负责发送数据到指定 Topic。
   – Consumer：消息消费方，从 Partition 拉取数据并维护 Offset。
   – Broker：消息存储服务器，负责持久化和读写服务。
   – Topic：消息分类逻辑单元，一 Topic 分多个 Partition。
   – Partition：物理上的分片，实现并发和顺序的子队列。
   – Offset：消息在 Partition 中的唯一序号，用于定位消费进度。
3. 关系总结：Topic 是逻辑池，Partition 是物理桶，Offset 是桶内指针，Broker 是桶仓库。

简短示例回答（约95字）：

Producer 发消息到 Broker 的指定 Topic，Topic 下有多个 Partition 实现并行；Consumer 从 Partition 拉取数据，通过 Offset 记录消费位置。Broker 负责存储和路由。比如 RocketMQ，一个 Topic 默认8个 Partition，每个 Partition 内消息有序，Offset 由消费者维护。

可能追问

• Offset 存储在客户端还是服务端？各有什么优劣？
• Partition 数量如何确定？太多或太少有什么后果？
• Broker 宕机后 Partition 的 leader 选举流程？