RabbitMQ 常见面试题

这篇具有很好参考价值的文章主要介绍了RabbitMQ 常见面试题。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

1.RabbitMQ的三大核心

  1. 流量削峰
  2. 代码解耦
  3. 异步处理

2.RabbitMQ的五消息模型

  1. 简单消息模型
    功能:一个生产者P发送消息到队列Q,一个消费者C接收。实现了基本的消息的生产和消费。一对一。
  2. 工作队列
    功能:一个生产者,多个消费者。写法与基本消息模型类似,只不过原来是一个消费者,现在是多个消费者。多个消费者处理队列中的数据。
  3. 发布订阅模型
    功能:一个生产者发送的消息会被多个消费者获取。一个生产者、一个交换机、多个队列、多个消费者
  4. 路由模式
    功能:生产者发送消息到交换机并且要指定路由key,消费者将队列绑定到交换机时需要指定路由key。只有当两个key相匹配时,消息才会发送到对应的消费者队列。即在广播的基础上有了路由的功能
  5. 主题订阅模式
    功能:生产者P发送消息到交换机X,type=topic,交换机根据绑定队列的routing key的值进行通配符匹配; 符号#:匹配一个或者多个词 lazy.# 可以匹配 lazy.irs或者lazy.irs.cor; 符号*:只能匹配一个词 lazy.* 可以匹配 lazy.irs或者lazy.cor

3.RabbitMQ如何防止消息丢失

  1. RabbitMQ消息丢失的情况 :
    第一种:生产者弄丢了数据。生产者将数据发送到 RabbitMQ 的时候,可能数据就在半路给搞丢了,因为网络问题啥的,都有可能。
    第二种:RabbitMQ 弄丢了数据。MQ还没有持久化自己挂了
    第三种:消费端弄丢了数据。刚消费到,还没处理,结果进程挂了,比如重启了。
  2. 解决方案
    针对生产者
    1.使用confirm机制。
    2.开启RabbitMQ事务 。
    针对RabbitMQ
    1.消息持久化
    2.设置集群镜像模式
    3.消息补偿机制
    针对消费者 :ACK确认机制。

4.RabbitMQ如何保证消息不会重复消费

  1. 为什么会出现消息重复?
    生产时消息重复
    由于生产者发送消息给MQ,在MQ确认的时候出现了网络波动,生产者没有收到确认,实际上MQ已经接收到了消息。这时候生产者就会重新发送一遍这条消息。
    生产者中如果消息未被确认,或确认失败,我们可以使用消息重试
    消费时消息重复
    消费者消费成功后,再给MQ确认的时候出现了网络波动,MQ没有接收到确认,为了保证消息被消费,MQ就会继续给消费者投递之前的消息。这时候消费者就接收到了两条一样的消息。
    由于重复消息是由于网络原因造成的,因此不可避免重复消息。但是我们需要保证消息的幂等性。
  2. 如何保证消息幂等性?
    让每个消息携带一个全局的唯一ID,即可保证消息的幂等性,具体消费过程为:消费者获取到消息后先根据id去查询redis/db是否存在该消息
    如果不存在,则正常消费,消费完毕后写入redis/db
    如果存在,则证明消息被消费过,直接丢弃

5.RabbitMQ死信队列和延迟队列分别是什么?

  1. 死信队列就是一个普通的交换机,有些队列的消息成为死信后,(比如过期了或者队列满了)这些死信一般情况下是会被 RabbitMQ 清理的。但是你可以配置某个交换机为此队列的死信交换机,该队列的消息成为死信后会被重新发送到此 死信队列。至于怎么处理这个DLX中的死信就是看具体的业务场景了,死信队列中的信息可以被路由到新的队列。

消息成为死信的三种情况?

1.队列长度到达限制,无法加入新的消息
2.消费者拒接消费消息,并且不重回队列。该信息会被清除并进入死信队列
3.原队列存在消息过期设置,消息到达超时时间未被消费

  1. 延迟队列,即消息进入队列后不会立即被消费,只有到达指定时间后,才会被消费。

5.RabbitMQ如何解决消息堆积?

消息堆积原因:
1.消息堆积即消息没及时被消费,是生产者生产消息速度快于消费者消费的速度导致的。
2.消费者消费慢可能是因为:本身逻辑耗费时间较长、阻塞了。

  1. 预防措施:

生产者:
1.给消息设置年龄,超时就丢弃
2.考虑使用队列最大长度限制
3.减少发布频率

消费者:
增加消费者的处理能力 //优化代码;使用JDK的队列缓存数据,多线程去处理(一般考虑顺序问题,采用单例线程)
建立新的queue,消费者同时订阅新旧queue,采用订阅模式

  1. 使用缓存:

生产者端缓存数据,在mq被消费完后再发送到mq,打破发送循环条件。设置合适的qos值(channel.BasicQos()方法:每次从队列拉取的消息数量),当qos值被用光,而新的ack没有被mq接收时,就可以跳出发送循环,去接收新的消息。
消费者主动block接收进程,消费者感受到接收消息过快时主动block,利用block和unblock方法调节接收速率,当接收线程被block时,跳出发送循环。文章来源地址https://www.toymoban.com/news/detail-466706.html

到了这里,关于RabbitMQ 常见面试题的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • 常见面试题之HashMap

    1.1 二叉树概述 二叉树,顾名思义,每个节点最多有两个“叉”,也就是两个子节点,分别是左子节点和右子节点。不过,二叉树并不要求每个节点都有两个子节点,有的节点只有左子节点,有的节点只有右子节点。 二叉树每个节点的左子树和右子树也分别满足二叉树的定义

    2024年02月16日
    浏览(37)
  • springboot常见面试题

    Spring Boot是一个开源Java-based框架,用于创建微服务。它是由Pivotal团队创建的,用于快速开发生产级的Spring应用。Spring Boot让你可以不用或者只需要很少的Spring配置就能创建一个应用。 与Spring Framework相比,Spring Boot具有以下特点: 自动配置 :Spring Boot可以根据在类路径上的j

    2024年02月12日
    浏览(82)
  • MYSQL常见面试题汇总

    英杰社区 https://bbs.csdn.net/topics/617804998 1、三大范式 2、DML 语句和 DDL 语句区别 3、主键和外键的区别 4、drop、delete、truncate 区别 5、基础架构 6、MyISAM 和 InnoDB 有什么区别? 7、推荐自增id作为主键问题 8、为什么 MySQL 的自增主键不连续 9、redo log 是做什么的? 10、redo log 的刷盘时

    2024年02月16日
    浏览(36)
  • Redis常见面试题

    用缓存,主要有两个用途: 高性能 、 高并发 。 高性能 假设这么个场景,你有个操作,一个请求过来,吭哧吭哧你各种乱七八糟操作 mysql,半天查出来一个结果,耗时 600ms。但是这个结果可能接下来几个小时都不会变了,或者变了也可以不用立即反馈给用户。那么此时咋办

    2023年04月09日
    浏览(47)
  • Redis 常见面试题

    答案:Redis是一个开源的使用ANSI C语言编写的、支持网络、可基于内存亦可持久化的日志型、Key-Value数据库,并提供多种语言的API。它通常被称为数据结构服务器,因为值(value)可以是 字符串(string)、哈希(Hash)、列表(list)、集合(sets)、有序集合(sorted sets)等类型。Redis因其出色

    2024年04月12日
    浏览(28)
  • Redis的常见面试题

    目录 前言 Redis支持哪些数据类型 五种核心类型  Zset为什么用跳表不用红黑树 ? Redis常见的应用场景?   如何检测Redis的连通性? 如何设置key的过期时间?  Redis为什么是单线程模型?  Redis里的IO多路复用是什么?  RDB的持久化机制有哪些?  AOF的重写机制是怎么样的?

    2024年02月22日
    浏览(43)
  • python常见面试题

    可变类型: 列表(list) 字典(dict) 集合(set) 可以在原地修改值 不可变类型: 数字(int、float、complex) 布尔值(bool) 字符串(str) 元组(tuple) 不可变集合(frozenset) 不能原地修改,只能重新赋值 1.1 字符串 常见内置函数: 查找 string.find(str, beg=0, end=len(string)):检测

    2024年02月05日
    浏览(29)
  • unity常见面试题

    1.封装(Encapsulation) : 封装是面向对象编程的基本特性之一,它将数据(属性)和操作(方法)捆绑在一起,形成一个类,同时限制了外部对于类内部数据和操作的直接访问。通过封装,我们可以隐藏对象的内部状态,只暴露必要的接口给外部使用。 作用: 保护了对象的内

    2024年04月27日
    浏览(56)
  • web前端常见面试题

    DOCTYPE(文档类型)是 HTML 文档的开头,它指定了 HTML 文档使用的 HTML 版本及文档类型,告诉浏览器以哪种规范来解析 HTML 文档。它的作用有以下几个方面: 声明 HTML 版本:DOCTYPE 声明可以让浏览器知道使用哪个 HTML 版本来解析当前文档,从而根据规范来处理文档中的元素和属

    2024年02月07日
    浏览(38)
  • Docker常见面试题 | 答案

    目录 1、Docker 是什么? 2、Docker的三大核心是什么? 3、仓库、镜像、容器的关系是? 4、Docker与虚拟机的区别 5、Docker容器的集中状态 6、如何把主机的东西拷贝到容器内部? 7、进入容器的方法有哪些? 8、如何让容器随着 Docker 服务启动而自动启动? 9、如何指定容器的端口映

    2024年01月20日
    浏览(44)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包