2019年12道RabbitMQ高频面试题你都会了吗？（含答案解析）

RabbitMQ 面试题

一、什么是 rabbitmq

二、为何要使用 rabbitmq

三、使用 rabbitmq 的场景

四、如何确保消息正确地发送至 RabbitMQ？ 如何确保消息接收方消费了消息？

5.如何避免消息重复投递或重复消费？

六、消息基于什么传输？

七、消息如何分发？

八、消息怎么路由？

九、如何确保消息不丢失？

十、使用 RabbitMQ 有什么好处？

十一、RabbitMQ 的集群

十二、mq 的缺点

一、什么是 rabbitmq

采用 AMQP 高级消息队列协议的一种消息队列技术,最大的特色就是消费并不须要确保提供方存在,实现了服务之间的高度解耦

 

二、为何要使用 rabbitmq

（1）在分布式系统下具有异步,削峰,负载均衡等一系列高级功能;

（2）拥有持久化的机制，进程消息，队列中的信息也能够保存下来。

（3）实现消费者和生产者之间的解耦。

（4）对于高并发场景下，利用消息队列可使得同步访问变为串行访问达到必定量的限流，利于数据库的操做。

（5）可使用消息队列达到异步下单的效果，排队中，后台进行逻辑下单。

 

三、使用 rabbitmq 的场景

（1）服务间异步通讯

（2）顺序消费

（3）定时任务

（4）请求削峰

 

四、如何确保消息正确地发送至 RabbitMQ？ 如何确保消息接收方消费了消息？

发送方确认模式

将信道设置成 confirm 模式（发送方确认模式），则全部在信道上发布的消息都会被指派一个惟一的 ID。

一旦消息被投递到目的队列后，或者消息被写入磁盘后（可持久化的消息），信道会发送一个确认给生产者（包含消息惟一 ID）。

若是 RabbitMQ 发生内部错误从而致使消息丢失，会发送一条 nack（notacknowledged，未确认）消息。

发送方确认模式是异步的，生产者应用程序在等待确认的同时，能够继续发送消息。当确认消息到达生产者应用程序，生产者应用程序的回调方法就会被触发来处理确认消息。

 

接收方确认机制

消费者接收每一条消息后都必须进行确认（消息接收和消息确认是两个不一样操做）。只有消费者确认了消息，RabbitMQ 才能安全地把消息从队列中删除。

这里并无用到超时机制，RabbitMQ 仅经过 Consumer 的链接中断来确认是否须要从新发送消息。也就是说，只要链接不中断，RabbitMQ 给了 Consumer 足够长的时间来处理消息。保证数据的最终一致性；

下面罗列几种特殊状况

（1）若是消费者接收到消息，在确认以前断开了链接或取消订阅，RabbitMQ 会认为消息没有被分发，而后从新分发给下一个订阅的消费者。（可能存在消息重复消费的隐患，须要去重）

（1）2若是消费者接收到消息却没有确认消息，链接也未断开，则 RabbitMQ 认为该消费者繁忙，将不会给该消费者分发更多的消息。

 

5.如何避免消息重复投递或重复消费？

在消息生产时，MQ 内部针对每条生产者发送的消息生成一个 inner-msg-id，做为去重的依据（消息投递失败并重传），避免重复的消息进入队列；在消息消费时，要求消息体中必需要有一个 bizId（对于同一业务全局惟一，如支付 ID、订单 ID、帖子 ID 等）做为去重的依据，避免同一条消息被重复消费。

 

六、消息基于什么传输？

因为 TCP 链接的建立和销毁开销较大，且并发数受系统资源限制，会形成性能瓶颈。RabbitMQ 使用信道的方式来传输数据。信道是创建在真实的 TCP 链接内的虚拟链接，且每条 TCP 链接上的信道数量没有限制。

 

七、消息如何分发？

若该队列至少有一个消费者订阅，消息将以循环（round-robin）的方式发送给消费者。每条消息只会分发给一个订阅的消费者（前提是消费者可以正常处理消息并进行确认）。经过路由可实现多消费的功能

 

八、消息怎么路由？

消息提供方->路由->一至多个队列消息发布到交换器时，消息将拥有一个路由键（routing key），在消息建立时设定。经过队列路由键，能够把队列绑定到交换器上。消息到达交换器后，RabbitMQ 会将消息的路由键与队列的路由键进行匹配（针对不一样的交换器有不一样的路由规则）；

经常使用的交换器主要分为一下三种：

fanout：若是交换器收到消息，将会广播到全部绑定的队列上

direct：若是路由键彻底匹配，消息就被投递到相应的队列

topic：可使来自不一样源头的消息可以到达同一个队列。 使用 topic 交换器时，可使用通配符

 

九、如何确保消息不丢失？

消息持久化，固然前提是队列必须持久化

RabbitMQ 确保持久性消息能从服务器重启中恢复的方式是，将它们写入磁盘上的一个持久化日志文件，当发布一条持久性消息到持久交换器上时，Rabbit 会在消息提交到日志文件后才发送响应。一旦消费者从持久队列中消费了一条持久化消息，RabbitMQ 会在持久化日志中把这条消息标记为等待垃圾收集。若是持久化消息在被消费以前 RabbitMQ 重启，那么 Rabbit 会自动重建交换器和队列（以及绑定），并从新发布持久化日志文件中的消息到合适的队列。

 

十、使用 RabbitMQ 有什么好处？

（1）服务间高度解耦

（2）异步通讯性能高

（3）流量削峰

 

十一、RabbitMQ 的集群

镜像集群模式

你建立的 queue，不管元数据仍是 queue 里的消息都会存在于多个实例上，而后每次你写消息到 queue 的时候，都会自动把消息到多个实例的 queue 里进行消息同步。

好处在于，你任何一个机器宕机了，没事儿，别的机器均可以用。坏处在于，第一，这个性能开销也太大了吧，消息同步全部机器，致使网络带宽压力和消耗很重！第二，这么玩儿，就没有扩展性可言了，若是某个 queue 负载很重，你加机器，新增的机器也包含了这个 queue 的全部数据，并无办法线性扩展你的 queue

 

十二、mq 的缺点

（1）系统可用性下降

系统引入的外部依赖越多，越容易挂掉，原本你就是 A 系统调用 BCD 三个系统的接口就行了，人 ABCD 四个系统好好的，没啥问题，你偏加个 MQ 进来，万一MQ 挂了咋整？MQ 挂了，整套系统崩溃了，你不就完了么。

（2）系统复杂性提升

硬生生加个 MQ 进来，你怎么保证消息没有重复消费？怎么处理消息丢失的状况？怎么保证消息传递的顺序性？头大头大，问题一大堆，痛苦不已

（3）一致性问题

A 系统处理完了直接返回成功了，人都觉得你这个请求就成功了；可是问题是，要是 BCD 三个系统那里，BD 两个系统写库成功了，结果 C 系统写库失败了，咋整？你这数据就不一致了。

因此消息队列实际是一种很是复杂的架构，你引入它有不少好处，可是也得针对它带来的坏处作各类额外的技术方案和架构来规避掉，最好以后，你会发现，妈呀，系统复杂度提高了一个数量级，也许是复杂了 10 倍。可是关键时刻，用，仍是得用的。

欢迎你们关注个人公众号【程序员追风】，2019年多家公司java面试题整理了1000多道400多页pdf文档，文章都会在里面更新，整理的资料也会放在里面。

 

 

最后

欢迎你们一块儿交流，喜欢文章记得关注我点个赞哟，感谢支持！