MQ消息队列面试题

什么是消息队列

消息队列，就是指保存消息的一个容器。类似于数据库、缓存等，用来保存数据的。
消息队列，就是一个使用队列来通信的组件

为什么需要消息队列，消息队列的应用场景

提供系统性能首先考虑的是数据库的优化，但是数据库因为历史原因，横向扩展是一个非常复杂的工程，所以我们一般会尽量把流量都挡在数据库之前。
消息队列就可以将流量挡在前面，有如下的应用场景

异步处理：异步发送邮件、短信等
应用解耦：订单系统和库存系统解耦
流量削峰：秒杀
消息通讯：聊天室，在一个主题下实现点对点、群聊
海量数据同步(日志)：kafka，binglog同步
任务调度：延迟队列、死信队列的应用。订单超时30分钟取消订单
分布式事务：RabbitMQ(comfirm，手动ack)、RocketMQ(支持事务)

消息队列的优缺点

优点：解耦、异步、削峰等场景
缺点：保证MQ可用性、系统复复杂度提升、一致性问题

如何保证消息队列的高可用

集群部署

RabbitMQ集群部署有两种模式：镜像队列模式、普通模式(通过共享元数据实现集群，所以普通模式不能实现高可用，某个节点挂了，这个节点上的消息将无法被消费)
Kafka：通过zookeeper管理Broker与consumer的动态加入与离开
RocketMQ：通过NameServer管理Broker。NameServer和Zookeeper的作用差不多

如何保证消息的可靠性，如何保证消息不丢失

RabbitMQ：
第一种：事务(不推荐)
第二种：
生产端开启Comfirm
Broker 持久化交换机、队列、消息
消费端手动ACK
Kafka：Kafka消息一直存储在磁盘中，定时清理，可以重复消费。由Consumer自己保存状态，也不要任何确认，consumer可以再次获取消息
RocketMQ：
事务消息，手动ACK都可以

如果处理重复消息（幂等性）

幂等处理：每一个消息用一个唯一的表示区分，消费前先判断标识有没有被消费，若已消费，直接ACK

如何保证消息的有序性

RabbitMQ：将消息放入同一个交换机，交给一个队列，这个队列只有一个消费者，消费者只允许同时开启一个线程
Kafka：partition是一个有序队列，所以消息发送给一个partition，group中就有一个消费者，实现有序
RocketMQ：支持顺序消费，将消费发送给一个queue，一个单线程的消费者

如果处理消息堆积

消息堆积往往是因为生产者生产速度和消费者消费速度不匹配造成的。
首先需要先定位消费慢的原因，如果是bug先处理bug。如果是消费者本身能力弱，我们需要优化消费者能力，比如之前一条一条消费，改成批量消费
如果优化完毕，还是慢，那就需要水平扩容了，增加Topic数据和消费者数量。如果是bug影响的那么就可以增加临时队列提高消费速度，恢复之后，在将临时队列和consumer停掉