【RabbitMQ】面试题

在本篇文章中,主要是介绍RabbitMQ一些常见的面试题。对于前几篇文章的代码,都已经在码云中给出,链接是mq-test: 学习RabbitMQ的一些简单案例 (gitee.com),如果存在问题的话欢迎各位提出,望共同进步。

MQ的作用以及应用场景

简单来说,MQ的全称是Message Queue(消息队列),因此MQ的作用就是接收消息和发送消息。具体来说,MQ就是一种应用程序间的通信方法,它允许组件以异步的方式进行交互,在不同的应用场景下发挥着不同的作用。

常见的应用场景有:异步解耦、削谷削峰、消息分发、延迟通知、异步通信等。

具体介绍见【RabbitMQ】概述一文。

不同MQ的区别

业界也有许多MQ的产品,例如Kafka、RabbitMQ、RocketMQ等。

Kafka一开始是作为日志收集和传输,追求高吞吐量,性能卓越。单机吞吐量一般可达十万级,在日志领域较为成熟。但是功能比较简单,只支持简单的MQ功能。适合大数据处理、实时分析、日志聚合等应用场景。

RabbitMQ是采用Erlang语言开发,功能较为完善,几乎支持所有的主流语言,开源提供的界面非常友好,性能较好,单机吞吐量一般可达万级,社区活跃度较高,文档更新频繁。比较适合中小型公司,数据量没那么大、并且并发没那么高的场景。

RocketMQ是阿里巴巴开源的一款消息队列,后来捐赠给Apache公司,采用Java语言开发。在可用性、可靠性以及稳定性方面都非常出色,吞吐量可达十万级,在阿里巴巴内部广泛使用。但是支持的语言并不多,产品较新文档较少,并且社区活跃度一般。适合于大规模分布式系统,而且可靠性要求较高的场景,比如互联网金融。

具体介绍见【RabbitMQ】概述一文。

RabbitMQ的核心概念

 核心概念这一问题可以大概构建上述图形来简单进行介绍,我习惯先介绍生产者、消费者,然后再介绍连接、信道,最后介绍Broker以及其中的内容,VirtualHost、Exchange、Queue。

  • Producer(生产者):是RabbitMQ Server的客户端,向RabbitMQ Server发送消息。
  • Consumer(消费者):是RabbitMQ Server的客户端,从RabbitMQ Server接收消息。
  • Connection(连接):是RabbitMQ Server和客户端之间的一个TCP连接,该连接是客户端和服务端之间发送消息的基础,他负责传输客户端和服务端之间的所有数据和控制信息。
  • Channel(信道、通道):信道是连接之上的一个抽象层。在一个连接中有多个信道,每个信道都是独立的虚拟连接,消息的发送和接收就是基于信道的。信道的主要作用是将消息的读写操作复用到同一个TCP连接上,这样就可以减少建立连接和关闭连接的开销,提高性能。
  • Broker:本质上就是RabbitMQ Server这个服务端实例,主要用来接收和发送消息。
  • VirtualHost(虚拟主机):虚拟主机是一个虚拟概念,他为消息队列提供了一种逻辑上的隔离机制。对于一个RabbitMQ Server而言,可以存在多个虚拟主机。当多个不同的用户需要同一个Rabbit Server提供的服务时,可以划分出多个虚拟主机。每个用户在自己的虚拟主机上创建交换机、队列即可。
  • Exchange(交换机):消息到达Broker的第一站,她负责接收消息并且根据路由规则把消息路由到对应的消息队列中。交换机起到了消息路由的作用,她根据交换机的规则和类型来确认如何转发接收到的消息。
  • Queue(队列):用于存储消息。

具体介绍见【RabbitMQ】概述一文。

RabbitMQ的工作流程

  1. 发送消息:生产者生成了一条消息。
  2. 创建连接:生产者和RabbitMQ Server之间创建连接,并且开启一个信道。
  3. 声明交换机、队列以及绑定关系:生产者声明一个队列,用来存放消息;生产者声明一个交换机,用来路由消息;生产者指定一个绑定规则,使得消息从交换机成功路由到队列中。
  4. 发送消息:生产者将消息发送给RabbitMQ Server。
  5. 消息存储:RabbitMQ Server接收到消息之后,根据路由规则存入相应的队列中。如果未找到相应的队列,根据生产者的配置,选择丢弃或者回退给生产者。
  6. 消费消息:消费者监听队列,当消息到达时,从队列中获取消息。处理后,向Rabbit Server发送消息确认。
  7. 删除消息:RabbitMQ Server接收到消费者的确认(ACK)之后,从队列中把消息删除。

具体介绍见【RabbitMQ】概述一文。

RabbitMQ如何保证消息的可靠性

如何保证消息的可靠性,就要看消息在传输过程中哪里出现了问题。大致分为三个方面:第一个是从生产者到交换机、再到队列的过程,第二个是RabbitMQ Server内部,第三个是从RabbitMQ Server内部到消费者的过程。RabbitMQ对这三种情况分别推出了三种解决方案:发送方确认、持久化以及消息确认。

发送方确认有两种模式:第一个是confirm模式,保证的是从生产者到交换机过程中的消息可靠性。第二个是return模式,保证的是从交换机到队列的消息可靠性。

持久化有三种方式,分别是交换机持久化、队列持久化以及消息持久化。在三个持久化中,主要注意的是队列持久化和消息持久化,如果消息持久化了但是队列没持久化是没有作用的,比较队列都没有,消息也没地方放,自然持久化也就没有用。

消息确认有两种模式:手动确认和自动确认,在SpringAMPQ中,则是有三种策略可以选择:NONE、AUTO、MANUAL。在MANUAL中,又有三种机制可供选择,分别是接收、拒绝以及批量拒绝。

具体介绍见【RabbitMQ】可靠性传输​​​​​一文。

RabbitMQ如何保证消息的顺序性

RabbitMQ中顺序性指的是生产者生产消息的顺序为msg1、msg2、msg3,那么消费者消费消息的顺序也应该依次为msg1、msg2、msg3。顺序性保障分为局部顺序性保障和全局顺序性保障。存在的解决方案有:单队列单消费者、分区消费、消息确认、业务逻辑控制(例如消费端内部实现消息排序逻辑等)。

具体介绍见【RabbitMQ】幂等性、顺序性一文。

RabbitMQ如何保证消息的幂等性

RabbitMQ中幂等性指的是一条消息,多次消费,对系统产生的影响是相同的。

在消息传递过程中,消息传输保证被分为最少一次、恰好一次、最多一次。RabbitMQ并不支持恰好一次;在业务场景比较重要的情况下,建议使用最少一次,但是在一些特殊场景下(例如消息从生产者发送出去之后出现网络故障,导致服务端没有及时返回确认机制;或者消息从服务端到消费者,消费之后并没有返回确认通知)会导致消息重复发送,从而出现一些比较严重的问题;对于最多一次来说,则会因为网络宕机等故障导致消息丢失。

一般在比较重要的业务下,我们都是以最少一次这种方式,但是如果出现消息重复传输的话,就会导致消息多次消费,因此我们为了保证幂等性,就需要一些解决方案。常见的解决方案有:

  • 使用唯一标识符来标识每一条消息
  • 使用业务逻辑判断来确认消息是否消费

具体介绍见【RabbitMQ】幂等性、顺序性一文。

RabbitMQ有哪些特性

  • 消息可靠性传输
    • 发送方确认
    • 持久化
    • 消息确认
  • 死信队列
  • 延迟队列
  • 重试机制
  • TTL

具体介绍见【RabbitMQ】系列。

介绍下RabbitMQ的死信队列

死信表示一系列无法被消费的消息。存在死信,就存在死信队列。当一个消息在队列中变成死信之后,就会通过死信交换机进入死信队列,这就是死信队列的由来。

例如队列中的消息超过最大长度、消息的TTL超时、手动确认机制下拒绝并且不予重新入队等等,都会被路由到死信队列中。

死信队列的应用场景有:消息重试(将错误的消息放入死信队列中进行重试)、日志分析(将死信队列中的消息进行收集,用户日志分析)、消息丢弃(将死信队列中的消息丢弃,避免占用资源)。

具体介绍见【RabbitMQ】死信队列、延迟队列一文。

介绍下RabbitMQ的延迟队列

延迟队列表示消息从生产者到达RabbitMQ Server之后,并不是立即到达消费者进行消费,而是经过一段时间之后再推送到消费者。

延迟队列的实现方式有两种:

  1. TTL + 死信队列(注意这里的TTL必须要设置队列的,而不是消息的)。
  2. 使用延迟队列插件。

延迟队列的应用场景有:

  • 十五分钟未支付订单取消
  • 预定会议开始前十五分钟进行通知
  • 手机遥控两个小时之后家电开始工作
  • 用户注册成功之后,三天后发送通知,提供用户活跃度
  • 用户发起退款,24小时之后商家没有行动,自动退款

具体介绍见【RabbitMQ】死信队列、延迟队列一文。

介绍下RabbitMQ的工作模式

RabbitMQ有七种工作模式,分别是:

  • 简单模式(Simple)
  • 工作队列模式(Work Queue)
  • 发布订阅模式(Publish / Subscribe)
  • 路由模式(Routing)
  • 通配符模式(Topics)
  • RPC模式(RPC)
  • 发布确认模式(Publisher Confirms)

具体介绍见【RabbitMQ】工作模式一文。

消息积压

消息积压指的是生产者生产消息的速度已经远远超过了消费者消费消息的速度,从而导致了消息在队列中发生了积压。

导致消息积压的原因无非就是软件和硬件的原因。对于软件来说,就是生产者生产速度太快、而消费者消费速度太慢;对于硬件来说,就是网络延迟、RabbitMQ服务器配置太低等原因。

想要解决消息积压,就是针对产生的问题进行分别解决。对于软件来说,就是提高消费者消费速率、降低生产者生产速率;对于硬件来说,就是增加服务器配置、优化参数等方案。

具体介绍见【RabbitMQ】消息积压、推拉模式一文。

推拉模式

推拉模式是RabbitMQ中向消费者发送消息的两种模式。推模式表示的是消息到达服务器之后,根据消费者监听的队列将消息推送给消费者进行消费。拉模式表示的是消息到达服务器之后,消费者主动去服务器拉取消息进行消费。

对于一般的业务来说,采取的都是推模式进行工作,其适合数据实时性要求较高的场景。拉模式则是适合消费消息时需要大量资源的的任务,拉模式允许消费者准备好之后再去进行消费,可以减少资源的浪费。

具体介绍见【RabbitMQ】消息积压、推拉模式一文。

到这里,RabbitMQ的介绍就基本结束了,其中缺的一个内容就是分布式部署,有机会的话后续进行介绍。

总的来说,在RabbitMQ这个系列中,先进行了一个概述,然后对工作模式简单介绍,后续是对高级特性(可靠性保证、TTL、重试机制、延迟队列、死信队列、事务、消息分发、幂等性、顺序性、消息积压)以及推拉模式进行了介绍,最后对一些场景面试题进行了概述。

下一个系列文章是微服务组件,欢迎大家给出修改意见,共同进步。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/pingmian/55336.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

.Net 6.0 监听Windows网络状态切换

上次发了一个文章获取windows网络状态&#xff0c;判断是否可以访问互联网。传送门&#xff1a;获取本机网络状态 这次我们监听网络状态切换&#xff0c;具体代码如下&#xff1a; public class WindowsNetworkHelper {private static Action<bool>? _NetworkStatusCh…

【课程学习】Wireless Communications

Goldsmith A. Wireless communications[M]. Cambridge university press, 2005. Wireless Communications 无线通信课程 文章目录 2-Path Loss, Shadowing, and Multipath2.4-Two-Ray Multipath Model时延扩展 delay spread P33 3-Statistical Multipath Channel Models3.3-Wid…

一站式大语言模型API调用:快速上手教程

智匠MindCraft是一个强大的AI工具及开发平台&#xff0c;支持多种大语言模型和多模态AI模型。本文将详细介绍如何通过API调用智匠MindCraft中的大语言模型&#xff0c;帮助开发者快速上手。 注册与登录 访问智匠MindCraft官网&#xff0c;注册并登录账号。 进入开发者平台&…

scrapy爬虫基础

一、初识 创建项目&#xff1a; scrapy startproject my_one_project # 创建项目命令 cd my_one_project # 先进去&#xff0c; 后面在里面运行 运行爬虫命令为&#xff1a;scrapy crawl tk spiders下创建test.py 其中name就是scrapy crawl tk &…

Cpp::STL—string类的使用与理解(上)(8)

文章目录 前言一、string类对象的构造函数string()string(const char* s)string(size_t n, char c)string(const string& s)string(const string& str&#xff0c;size_t pos&#xff0c;size_t len npos) 二、string类对象的容量操作size与lengthcapacitycapacity返回…

缓存穿透、击穿、雪崩及解决方案

在分布式系统中&#xff0c;尤其是使用缓存的系统中&#xff0c;缓存雪崩、缓存穿透和缓存击穿是常见的问题。下面详细说明这三者的定义和解决方案&#xff1a; 1. 缓存穿透 定义&#xff1a;缓存穿透是指请求的数据在缓存和数据库中都不存在。由于每次请求都会直接查询数据库…

Docekrfile和docker compose编写指南及注意事项

Dockerfile 基础语法 我们通过编写dockerfile,将每一层要做的事情使用语法固定下来&#xff0c;之后运行指令就可以通过docker来制作自己的镜像了。 构建镜像的指令&#xff1a;docker build /path -t imageName:tag 注意&#xff0c;docker build后的path必须是dockerfile…

阿里云对象存储OSS 速学

目录 1.创建一个Bucket 2.创建密钥AccessKey 3.在文档中心打开阿里云对象存储OSS 4.参考上传文件示例 以官网的文档为主&#xff0c;我的文章教学为辅 官网有详细的视频介绍&#xff1a; OSS快速入门_对象存储(OSS)-阿里云帮助中心 (aliyun.com)https://help.aliyun.com/…

25考研咨询周开启,西安电子科技大学是否改考408??

学长这几天帮大家问了西安电子科技大学是否会从833、834、953改考为408&#xff1f; 西电老师回复&#xff1a;根据上级文件要求&#xff0c;招生简章以及专业目录会在网上报名开始前公布&#xff0c;专业课不会又大变动&#xff01; 因为大家安心复习即可&#xff0c;保证今…

java解决跨域问题时的403报错

什么是跨域问题&#xff1f; 当一个请求的url的协议&#xff0c;域名&#xff0c;端口三者之间任意一个与当前页面url不同 即为跨域 问题背景&#xff1a; 如图&#xff0c;前端端口为8090&#xff0c;而后端端口为8099&#xff0c;形成跨域&#xff0c;无法对接 试图利用Spr…

【数据库】数据库课程设计mysql

数据库课程设计MySQL是一个涉及多方面内容的综合性项目&#xff0c;旨在通过实践加深对MySQL数据库的理解和应用。以下是一个基于MySQL的数据库课程设计概览&#xff0c;包括设计步骤、关键技术和操作示例。 一、数据库设计步骤 需求分析&#xff1a; 确定系统的功能需求和数据…

爬虫——爬取小音乐网站

爬虫有几部分功能&#xff1f;&#xff1f;&#xff1f; 1.发请求&#xff0c;获得网页源码 #1.和2是在一步的 发请求成功了之后就能直接获得网页源码 2.解析我们想要的数据 3.按照需求保存 注意&#xff1a;开始爬虫前&#xff0c;需要给其封装 headers {User-…

卫生间门口墙皮天天掉,是墙面“返潮”造成的?

业主说房子装修好5年了&#xff0c;卫生间防水出问题了&#xff0c;去现场看一下&#xff0c;看看能怎么处理。      到了工地以后&#xff0c;业主说卫生间门口两侧的墙皮都已经脱落了&#xff0c;天天往下掉&#xff0c;实在没办法了&#xff0c;就在墙上钉了几块纸壳子。…

linux基础指令的认识

在正式学习linux前&#xff0c;可以简单认识一下linux与win的区别 win&#xff1a;是图形界面&#xff0c;用户操作更简单&#xff1b;在刚开始win也是黑屏终端 指令操作&#xff0c;图形界面就是历史发展的结果。Linux&#xff1a;也存在图形界面比如desktop OS&#xff1b;但…

Ubuntu24.04桌面版下的网络管理

systemd-networkd组件 注意&#xff1a;systemd-network和NetworkManager组件两者冲突 使用systemd-networkd之前&#xff0c;需要先关闭其他网络管理器&#xff0c;如NetworkManager, netctl&#xff0c;dhcp daemon&#xff0c;dhcpcd, dhclient等 systemctl stop NetworkM…

【C++】模拟实现红黑树

&#x1f984;个人主页:修修修也 &#x1f38f;所属专栏:实战项目集 ⚙️操作环境:Visual Studio 2022 目录 一.了解项目功能 二.逐步实现项目功能模块及其逻辑详解 &#x1f4cc;实现RBTreeNode类模板 &#x1f38f;构造RBTreeNode类成员变量 &#x1f38f;实现RBTreeNode类构…

Flutter modal_bottom_sheet 库:介绍与使用指南

Flutter的官方showModalBottomSheet方法虽然功能强大&#xff0c;但在某些场景下可能不够灵活。为了解决这个问题&#xff0c;社区提供了一个非常实用的第三方库——modal_bottom_sheet。这个库扩展了官方的ModalBottomSheet功能&#xff0c;提供了更多的自定义选项和更丰富的用…

异常场景分析

优质博文&#xff1a;IT-BLOG-CN 为了防止黑客从前台异常信息&#xff0c;对系统进行攻击。同时&#xff0c;为了提高用户体验&#xff0c;我们都会都抛出的异常进行拦截处理。 一、异常处理类 Java把异常当做是破坏正常流程的一个事件&#xff0c;当事件发生后&#xff0c;…

C 语言预处理详解:从宏替换到条件编译

目录&#xff1a; 前言1. 什么是预处理&#xff1f;2. 头文件展开3. 去注释4. 宏替换4.1 什么是宏&#xff1f;4.2 宏的作用范围4.3 使用宏的小Tips4.4 # 和 ##4.5 宏替换 vs 去注释 5. 条件编译5.1 什么是条件编译&#xff1f;5.2 条件编译的使用5.3 条件编译的作用 总结 前言…

什么是区块链桥?

什么是区块链桥&#xff1f; 区块链桥是一种实现资产从一个区块链转移至另一个区块链的工具&#xff0c;它解决了区块链技术中不同网络之间缺乏互操作性的问题。区块链桥通过创建代表另一区块链资产的合成衍生品&#xff0c;使得原本互不兼容的区块链资产能够相互连接和转移。…