【RabbitMQ】RabbitMQ面试热点

发布时间:2024年01月22日

使用RabbitMQ有什么好处?

异步处理
解耦
流量削峰

RabbitMQ 结构(如何发送消息?)

整体结构如下图所示:

在这里插入图片描述

结构介绍

Server:又称为broker,接受客户端连接,RabbitMQ 节点;
Connection:连接,应用程序与brokder建立网络连接;
channel:网络通道,几乎所有的操作都是在channel中进行的,是进行消息对象的通道,客户端可以建立 多个通道,每一个channel表示一个会话任务
Virtual Host:虚拟机,一个节点由若干个虚拟机组成;
Exchange:交换机,一个虚拟机由若干个交换机组成;
Queue:消息队列,和交换机通过routing key绑定

发送消息流程

生产者把生产的消息通过channel发送到Exchange上,Exchange通过绑定的router key来选择Queue,消费者监听到Queue上有新的消息,就消费调此消息;

如何保证消息不丢失?(可靠性)

首先搞清楚消息丢失会在哪些场景?其实在发送消息的每一个场景都会发生消息丢失情况:

  1. 生产者发送消息时,有可能没发送到MQ;
  2. 消息到达MQ了,但是MQ宕机,消息丢失;
  3. 消费者消费消息时,消费者宕机;

那么对应解决办法如下:

  1. 生产者发送消息确认机制,确认消息发送到MQ
  2. MQ开启持久化,确保消息未消费前在队列中不丢失(交换机持久化、队列持久化、消息持久化)
  3. 消费者确认机制
  4. 开启消费者失败重试机制,多次重试失败投递异常交换机

如何解决消息重复消费问题?(消息幂等性)

给每条消息设置一个唯一的标识id

其他解决方案

利用数据库唯一约束:消费数据写入数据库,可以先根据主键查询数据是否已经存在,如果已经存在了就没必要插入了。或者直接插入也没问题,因为可以利用主键的唯一性来保证数据不会重复插入,重复插入只会报错,但不会出现脏数据
还有其他解决方案,后续遇到会进行补充~~~

介绍 MQ 中延时队列?(死信交换机)

利用TTL结合死信交换机,我们实现了消息发出后,消费者延迟收到消息的效果。这种消息模式就称为延迟队列(Delay Queue)模式

延迟队列 = 死信交换机 + TTL(生存时间)

使用场景:
● 延迟发送短信
● 用户下单,如果用户在15 分钟内未支付,则自动取消
● 预约工作会议,20分钟后自动通知所有参会人员
● 定时发布抖音作品

死信交换机

满足下面条件之一就被称为死信:

  1. 消费者拒绝消费
  2. 超时未消费
  3. 消息堆积满了,最早的消息成为死信

图解:

在这里插入图片描述

代码实现:

在这里插入图片描述

TTL

在这里插入图片描述

看如下代码,就是消息设置了过期时间:

在这里插入图片描述

延迟队列插件

需要保证 RabbitMQ 已经安装了插件,这里不展开叙述。具体可以谷歌一下

在这里插入图片描述

如何解决消息堆积问题?

消息堆积发生原因是什么?是因为生产者发送消息过快,而消费者不能及时消费,导致消息堆积。那么解决办法如下:

  1. 增加消费者进行消费
  2. 消费者方可以添加线程池加快消息处理速度
  3. 使用惰性队列,可以在MQ中保存更多消息

惰性队列特征:

  1. 接收到消息后直接存入磁盘而不是内存
  2. 消费者消费消息时才会从磁盘中读取并加载到内存
  3. 支持数百万条的消息存储

惰性队列优点:

  1. 基于磁盘存储,消息上限高
  2. 没有间歇性page-out,性能稳定

惰性队列缺点:

  1. 由于存储在磁盘,消息时效性会降低
  2. 性能受限于磁盘的IO

惰性队列使用:
在这里插入图片描述

RabbitMQ 高可用机制?(集群模式)

普通集群(不采用)
镜像集群
仲裁队列

在这里插入图片描述

参考链接

https://blog.csdn.net/zw791029369/article/details/109561457
https://www.bilibili.com/video/BV1yT411H7YK?p=58

文章来源:https://blog.csdn.net/weixin_44078354/article/details/135742336
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。