rabbitMq 入门及面试大全

1，什么是mq

a: mq 就是消息队列，是基础数据结构的 ”先进先出“ 的一种数据结构，

一般用来解决，解耦、异步消息、流量削峰，等问题，高可用、可伸缩和最终一致性架构。

1，解耦：一个业务需要多个模块共同实现，或者一条消息有读个系统对应处理，只需要在住业务完成以后，发送一条mq, 其余模块消费mq 消息，即可实现业务，降低模块之间的耦合

异步：主要业务执行结束后，从属业务通过mq 异步处理，减少业务的响应时间，提高用户体验。

削峰：高并发下，业务异步处理，提供高峰期业务处理额能力，避免瘫痪。

（这也是mq 三个特性）

2， mq 是怎么实现消息传递的？

a: 生产者产生消息并把输出的数据放在队列中，用队列机制来实现消息传递，消费者可以把指定的队列拉去消息，或者订阅队列，或者mq 服务端推送消费者。

3 ，为什么要用mq ?

a: 这个问题很关键，面试关的意图就是想知道，你真实项目中，是否用到了mq ，举出业务场景，解决了什么问题，不用这种mq 会有什么麻烦，类似常用的场景还有哪些？

我举个例子，我们有个业务用到阿里的隐私号服务，隐私号电话接通挂断以后会生产电话记录录音文件等信息，阿里提供里回调地址和订阅两种方式，我们收到推送电话记录但是，其中有一个录音文件地址，收到后并未生成（其实这应该阿里的一个bug ）但是我们接到推送了会做一系列业务操作和入库处理，由于没有第一时间收到录音文件，我们使用了mq 先通话记录的callid 和地址放到mq 中10分钟，
AMQ_SCHEDULED_DELAY 这里用力activemq 的 属性，broker 会延迟设定时间投递，
消费者消费时候如果还未生产文件，则延时20分钟投递，... 这里就利用到了mq 的异步，和解耦。

削峰：假设双十一，秒杀这种场景，到某个时候，瞬间数据库，访问量上来，mysql数据库的访问效率是 2k/s 个，现在来了五万个直接崩溃，这里直接使用mq 将访问消息放到队列中， mysql 每次取2k/s 消费，。。。就可以避免击穿，但是当mq 中消息堆积了也不行，可以考虑分布式，多节点处理。

mq 的四大消费问题？消息不丢失，消息积压，消费顺序性

rabbitMq ，

1，生存之把消息发送打mq serve 的过程丢失

从生产者发送消息的角度，提供了一个confirm 消息确认机制，生产者发送消息到server 以后，如果消息处理成功， server端会返回一个ack 消息，客户端可以根据消息的处理结果决定是否要做消息的重新发送，从而确保消息一定到达rabbit server 上。

2，rabbitmq server 收到消息后在持久化之前宕机，数据未到达队列导致数据丢失

在发布消息时候，可以设置消息持久化属性，使其在rabbit mq 服务器宕机后仍然保存在磁盘上，这样即时服务宕机消息仍会保存看病冲洗服务后回复，使用事务来确保消息的持久化和发送的原子性，开启事务后，mq 会等待消息完全写入磁盘才确认发布成功

3，队列中的数据还未被消费就宕机，独立的数据消息丢失

创建丢列有属性可以设置持久化，这样在mq 宕机时，未消费的消息也会将被持久化到磁盘，回复到队列中。

4，消费端收到消息还没来及处理宕机，导致mq serve 认为这个消息已经签收

把消息的自动确认机制改成手动，也就是消费端只有手动调用消息确认方法才表示消息已经签收。

Mq 百万消息持续积压

消息积压的原因生产者的消息生产速度大于消费者速度，遇到这个问题的时候，需要排查具体的原因再提出解决问题方案。