面试总结【消息队列篇】

消息队列篇

• - 聊聊什么消息队列
• - 说下消息队列有哪些模型
• - 解释下生产者、消费者概念
• - 如何保证消息不丢失
• - 如何处理消息重复
• - 如何处理消息堆积的问题

- 聊聊什么消息队列

是一个用队列来进行通信的组件，用来解决异步处理、服务解耦、流量控制的一个消息中间件；

- 说下消息队列有哪些模型

队列模型：RabbitMQ ，类似一对一聊天
发布订阅模型：RocketMQ、kafka ，类似群聊

- 解释下生产者、消费者概念

消息发送方~生产者
接收消息放~消费者
消息会从生产者发送消息至消息队列服务端，消费者会从服务端拉取消息进行消费，又或者服务端会主动推送消息给消费者消费

- 如何保证消息不丢失

三个角色的处理：
生产者向服务端发消息时，需要等待服务端响应，做好失败重发的机制
服务端存消息：刷盘成功再给生产者响应；
消费者消费：完成业务逻辑后，再给服务端响应

消息的可靠性上去了，性能自然下降，因此需要结合实际业务，如果只是日志生成，可以考虑是否可以舍弃一点可靠性

- 如何处理消息重复

首先消息重复的情况是必然的存在的，只能通过在消费端的 *** 作具备幂等性来处理，例如银行转账的业务，增加一个转账记录表，利用转账单id和收款人id联合起来建一个唯一索引，这样重复消息就会更新失败；

- 如何处理消息堆积的问题

消费堆积出现的原因是，生产者生产消息的速度远大于消费速度，首先检查是不是消费逻辑代码性能过慢，对应优化，还可以考虑水平扩容增加消费者的数量