如何保证消息不丢不重？一次打通三大MQ
你是不是也经常遇到MQ面试的‘灵魂拷问’：‘RabbitMQ 和 Kafka 怎么选？’，‘怎么保证消息不丢不重？’。很多人背了一堆八股文，但面试官换一个花样问，就支支吾吾。再深入追问一下不同MQ产品的区别，就更说不清了。。”
“今天这个视频，就是带你一次性通关。我们会从面试官最关心的核心痛点出发，把 MQ 三巨头（RabbitMQ、Kafka、RocketMQ）的看家本领扒个底朝天，最后再给你一份可以直接‘抄作业’的选型指南。看完保证你，下次再聊 MQ，就是你给面试官‘上课’！”
[核心痛点]
“首先，面试官为啥总揪着‘消息不丢不重’不放？因为它就是 MQ 的命门！”
“你看这两个场景：”
“消息丢失，放电商场景就是用户付了钱，你却没发货；放金融场景，就是转账指令丢了，这可是要上社会新闻的！”
“消息重复更搞笑，用户下了一单，你发了两次货，老板得气得跳起来；转账扣了两次款，用户就该跳起来了。”
“所以，当面试官问你‘如何保证消息可靠性’时，他真正想听的，是你如何从生产者、Broker（服务端）、消费者这三个环节，构建一个完整的‘不丢不重’的保障体系。这，就是考察你的技术深度！”
[RabbitMQ 讲解]
“好，搞懂了核心矛盾，我们来看第一位选手——RabbitMQ，我称它为‘英伦绅士’。”
“为啥这么说？因为它非常严谨，遵守 AMQP 协议，每一步都想做到万无一失。”
“你看它的防丢策略：”
- “生产者用 Confirm 机制，确保每条消息都亲眼看着它进了 Broker 的大门。”
- “Broker 自己也很靠谱，开启持久化，把消息存进硬盘，就算宕机重启，消息也还在。再配上镜像队列，搞个备份，简直是双保险！”
- “消费者这边，不能傻傻地拿了消息就完事，得等我自己的业务逻辑（比如数据库操作）都搞定了，再手动发送一个 ACK（确认信号），告诉 Broker：‘我搞定了，你可以放心删了’。”
“面试加分点来了：当面试官问 RabbitMQ 如何去重？标准答案是：‘它本身不保证，主要靠消费端自己实现幂等性。’比如用订单 ID 做唯一键存入 Redis，每次消费前都查一下，处理过就不再处理。这个回答一出口，面试官就知道你真实战过！”
[Kafka 讲解]
“接下来，第二位选手——Kafka，这位可是个‘暴躁老哥’，天生就是为了高吞吐量而生！”
“它的设计哲学跟 RabbitMQ 完全不同，追求的是极致的性能。”
(依次指着屏幕上的四个要点)
- “生产者端，想让消息最可靠？直接把确认级别 acks 设置为 all！意思是，不仅 Leader 副本收到了，所有小弟（ISR 副本）都说收到了，我才放心。虽然慢了点，但稳如老狗！”
- “Broker 端，它的分区副本机制是精髓。一个 Topic 分成好几个 Partition，每个 Partition 又有好几个副本，主打一个‘鸡蛋不放一个篮子’，随便挂，数据丢不了。”
- “消费者端，它通过手动提交 Offset（消费位点）来控制进度，这给了我们极大的灵活性。”
“面试王炸来了：Kafka 怎么去重？你可以回答：‘Kafka 引入了幂等性生产者和事务。’ 幂等性保证了单分区、单会话内消息不重；而事务，则实现了跨分区的原子性写入。把‘幂等性’和‘事务’这两个词一说，面试官看你的眼神都会变得温柔！”
[RocketMQ 讲解]
“最后，我们的国产之光，阿里出品的 RocketMQ！我愿称之为‘六边形战士’，全能型选手！”
“它吸取了 Kafka 和 RabbitMQ 的优点，特别适合国内复杂的电商和金融场景。”
- “在可靠性上，它有同步刷盘机制，消息必须写到磁盘才算成功，非常可靠。”
- “高可用方面，它有 Dledger 主从架构，能实现主节点宕机后的自动选举和切换，金融级保障！”
- “功能上，它简直是宝藏！支持事务消息、顺序消息、延迟消息，这些在电商的下单、支付、定时任务场景里，简直是神器。”
“面试高光时刻：当被问到 RocketMQ 的亮点时，你一定要提 ‘事务消息’！你可以说：‘RocketMQ 的两阶段提交事务消息机制，能完美解决分布式事务中，本地事务执行与消息发送的原子性问题。’ 这句话一说完，Offer 可能就离你不远了，因为这代表你思考的深度已经触及到分布式系统的核心难题了！”
[选型总结]
“好了，三位选手的看家本领都展示完了。现在，回到最初的那个‘灵魂拷问’：到底该选谁？”
“别纠结，标准答案就在这！”
“如果是中小型项目，业务不复杂，但对可靠性要求高，并发量不大，选 RabbitMQ 这双‘精致小皮鞋’，优雅又稳妥。”
“如果你的场景是海量日志收集、大数据分析、实时计算，需要的是极致的吞吐量，那就上 Kafka 这台‘越野大卡车’，力大砖飞！”
如果你的业务是大型的分布式系统，比如复杂的电商、金融核心链路，需要事务、延迟、顺序等各种高级功能，那 RocketMQ 这辆‘全能 SUV’，绝对是你的不二之选！
“记住，没有最好的，只有最适合的。把这个场景化选型思路抛给面试官，他绝对会为你点赞！”
[结尾]
“看到这里，相信你对消息队列的理解已经上了一个新台阶。”
“最后，我想用一句话来总结我们今天的内容：”
“技术选型，是现代程序员的第一道考题。”
因为有了AI的加持，各种功能的具体实现已经变得非常简单。但是技术选型、业务架构这些成了现代普通程序员的基本功。
“它考验的不仅是你的知识广度，更是你对业务场景的洞察和权衡利弊的智慧。”
“MQ 通关指南就到这里，需要的朋友截图保存，另外别忘了一键三连，要不以后就翻不到了。
最后 大家听完还有什么问题欢迎交流，我这边给大家整理了一份120万字的项目场景面试宝典，里面有类似的几百个项目场景面试问题，最近要面试的同学留下888。