rabbitmq 面试题
1.交换机类型
RabbitMQ是一个开源的消息队列系统,它支持多种交换机类型,用于在消息的生产者和消费者之间路由和分发消息
-
Direct Exchange(直接交换机):Direct交换机是最简单的交换机类型之一。它将消息按照消息的Routing Key(路由键)与绑定的队列的Routing Key进行精确匹配,并将消息发送到匹配的队列。这种交换机类型适合于一对一的消息传递。
-
Fanout Exchange(广播交换机):Fanout交换机将消息广播到绑定到它的所有队列,忽略消息的Routing Key。这种交换机类型适合于一对多的消息广播,不考虑消息的内容。
-
Topic Exchange(主题交换机):Topic交换机根据消息的Routing Key与绑定的队列的Routing Key之间的通配符匹配规则,将消息发送到一个或多个队列。这允许更复杂的消息路由和过滤。
2.为什么使用rabbitmq,使用它有什么好处?
RabbitMQ 是一个流行的消息队列中间件,用于在分布式系统中进行消息传递。
1. 解耦(Decoupling):
解耦是指将系统的各个组件或模块之间的依赖降低到最低程度。在消息队列中,解耦意味着生产者(消息发送者)和消费者(消息接收者)之间的通信不需要直接依赖于对方的状态或可用性。生产者只需要将消息发送到队列,而消费者则从队列中获取并处理消息。这种解耦方式允许系统的各个部分独立运作,不会因为某个组件的故障而影响其他组件。
2. 异步(Asynchronous):
异步是指不需要立即等待某个操作的完成,而可以继续执行其他操作。在 RabbitMQ 中,生产者可以异步地将消息发送到队列,而消费者可以异步地从队列中获取消息并进行处理。这意味着生产者和消费者之间的交互是非阻塞的,系统可以高效地处理大量的消息,而不会因为等待某个操作完成而陷入停滞。
3. 削峰(Load Leveling):
削峰是指在系统中平滑处理突发的高负载,而不会导致系统崩溃或性能下降。在 RabbitMQ 中,削峰通常是通过队列来实现的。当系统的吞吐量超过了某个组件的处理能力时,消息会积压在队列中,等待消费者逐一处理。这种方式可以帮助系统处理高峰时期的流量,而不会造成资源瓶颈。
总结起来,RabbitMQ 中的解耦异步削峰是一种设计理念,通过消息队列实现了组件之间的解耦,允许异步通信,同时使用队列来削峰,确保系统在高负载情况下稳定运行。这种方式有助于构建可扩展、可靠的分布式系统,提高系统的性能和可维护性。
3.如何保证消息不丢失的?
死信队列(Dead Letter Queue): 死信队列用于存储无法被成功处理的消息。当消息无法被消费者处理时,可以将其移动到死信队列,以便进一步的排查和处理。
1. 消息被拒绝访问,即 RabbitMQ返回 basicNack 的信号时。 或者拒绝basicReject
2. 消费者发生异常,超过重试次数 。
3. 消息的 TTL 过期时长或队列过期时间。
4. 消息队列达到最大长度
4.如何保证消息的正确发送,如何确定接收?
确保消息的正确发送:
-
消息持久化:在发送消息时,将消息标记为持久化,这样即使消息代理(如RabbitMQ)在消息发送后宕机,消息也不会丢失。
-
事务:使用事务来确保消息的原子性。在消息发送和确认接收之间,可以将一系列操作包装在事务中。如果事务成功提交,则消息发送,否则它将被回滚。
-
发送确认:大多数消息队列系统(包括RabbitMQ)支持生产者端的确认机制。在消息成功发送到队列后,生产者将获得一个确认,以指示消息已经被接收并可靠保存。
-
错误处理:处理可能发生的错误情况,如连接断开、消息队列服务不可用等。可以实现重试机制,以确保消息最终被正确发送。
确定消息的正确接收:
-
消息确认:使用消息队列的确认机制来确保消息已被消费者接收。在RabbitMQ中,消费者可以向消息代理发送确认,以告知代理消息已被处理。这种机制确保消息不会被多次处理。
-
消费者健壮性:编写健壮的消费者代码,以处理可能的异常情况,如处理失败后的消息重新入队列或记录错误信息。
-
消息幂等性:设计消息处理逻辑,以确保多次处理相同消息不会导致不一致的结果。这可以通过消息的唯一标识符或其他方法来实现。
-
监控和日志:实施监控和日志记录,以跟踪消息的处理过程。这有助于排除故障和分析问题。
-
消息超时:在消息中包含时间戳或超时信息,以确保及时处理消息。如果消息处理时间过长,可以将其标记为超时并采取适当的措施。
-
消息重试:在处理失败后,可以将消息重新放入队列以进行重试。您可以设置最大重试次数和重试间隔,以避免无限制的重试。
-
监控队列状态:监控消息队列的状态,以检测任何异常情况。您可以使用队列的监控工具或API来实时监视队列的健康状况。
综上所述,通过正确配置消息队列系统,并采取适当的消息发送和接收策略,可以确保消息的可靠发送和正确接收。这对于构建可靠的分布式系统和微服务架构至关重要。
相关文章:
rabbitmq 面试题
1.交换机类型 RabbitMQ是一个开源的消息队列系统,它支持多种交换机类型,用于在消息的生产者和消费者之间路由和分发消息 Direct Exchange(直接交换机):Direct交换机是最简单的交换机类型之一。它将消息按照消息的Rout…...

比较Visual Studio Code中的文件
目录 一、比较两个文件 1.1VS code中的文件大致分为两类: 1.2如何比较VS code中的两个文件? 二、并排差异模式:VS code中的一种差异模式 三、内联差异模式:VS code中的另一种差异模式 四、VS code忽略在行首或者行尾添加或删除…...

誉天在线项目-UML状态图+泳道图
什么是UML UML(Unified Modeling Language)是一种用于软件系统建模的标准化语言。它提供了一组图形符号和规范,用于描述和设计软件系统的结构、行为和交互。 UML图形符号包括类图、用例图、时序图、活动图、组件图、部署图等,每…...

【linux基础(六)】Linux中的开发工具(中)--gcc/g++
💓博主CSDN主页:杭电码农-NEO💓 ⏩专栏分类:Linux从入门到开通⏪ 🚚代码仓库:NEO的学习日记🚚 🌹关注我🫵带你学更多操作系统知识 🔝🔝 Linux中的开发工具 1. 前言2.…...

u盘上面 安装 ubuntu 系统
u盘上面 安装 ubuntu 系统 下载 一个 Ubuntu 22.04.3 LTS 桌面版 https://ubuntu.com/download/desktop 找到一个U盘 参考文章: 把 Ubuntu 装到U盘里随身携带,并同时支持 BIOS 和 UEFI 启动 https://www.luogu.com.cn/blog/GGAutomaton/portable-ubu…...

【推荐】SpringMVC与JSON数据返回及异常处理机制的使用
🎬 艳艳耶✌️:个人主页 🔥 个人专栏 :《【推荐】Spring与Mybatis集成整合》 ⛺️ 生活的理想,为了不断更新自己 ! 1.JSON 在SpringMVC中,JSON数据返回通常是通过使用ResponseBody注解将Java对象转换为JSO…...
SpringBoot新增拦截器详解
目录 一、拦截器使用 二、SpringMvc拦截器接口 三、SpringBoot集成拦截器 拦截器(Interceptor)通常是指在软件开发中用于处理请求和响应的中间件组件。拦截器的主要目的是在请求进入某个处理流程或在响应返回给客户端之前执行一些额外的操作或逻辑。 …...
Golang开发--select
在Go语言中,select语句用于在多个通道操作中进行选择。select语句使得程序可以同时等待多个通道的操作,并在其中任意一个通道就绪时执行相应的操作。以下是select语句的详细描述: select { case <-ch1:// 当ch1通道可读时执行的操作 case…...

贝塞尔曲线的一些资料收集
一本免费的在线书籍,供你在非常需要了解如何处理贝塞尔相关的事情。 https://pomax.github.io/bezierinfo/zh-CN/index.html An algorithm to find bounding box of closed bezier curves? - Stack Overflow https://stackoverflow.com/questions/2587751/an-algo…...

计算机网络原理 运输层
一,运输层协议概述 1,进程之间的通信 从通信和信息处理的角度看,运输层向它上面的应用层提供通信服务,它属于面向通信部分的最高层,同时也是用户功能中的最底层。当网络边缘部分的两台主机使用网络核心部分的功能进行…...

【JavaEE】多线程案例-阻塞队列
1. 前言 阻塞队列(BlockingQueue)是一个支持两个附加操作的队列。这两个附加的操作是: 在队列为空时,获取元素的线程会等待队列变为非空当队列满时,存储元素的线程会等待队列可用 阻塞队列常用于生产者和消费者的场…...

【物联网】简要介绍最小二乘法—C语言实现
最小二乘法是一种常用的数学方法,用于拟合数据和寻找最佳拟合曲线。它的目标是找到一个函数,使其在数据点上的误差平方和最小化。 文章目录 基本原理最小二乘法的求解应用举例使用C语言实现最小二乘法总结 基本原理 假设我们有一组数据点 ( x 1 , y 1 …...

慢查询SQL如何优化
一.什么是慢SQL? 慢SQL指的是Mysql中执行比较慢的SQL,排查慢SQL最常用的方法是通过慢查询日志来查找慢SQL。Mysql的慢查询日志是Mysql提供的一种日志记录,它用来记录Mysql中响应时间超过long_query_time值的sql,long_query_time的默认时间为10s. 二.查看慢SQL是否…...
UART 通信-使用VIO进行板级验证
串口系列知识分享: (1)串口通信实现-串口发送 (2)串口通信发送多字节数据 (3)串口通信实现-串口接收 (4)UART 通信-使用VIO进行板级验证 (5)串口接收-控制LED闪烁 (6)使用串口发送实现ACX720开发板时钟显示 (7)串口发送+RAM+VGA传图 文章目录 前言一、uart串口协…...
linux 查看可支持的shell
查看可支持的shell linux中支持多种shell类型,所以在shell文件的第一行需要指定所使用的shell #!/bin/bash 指定该脚本使用的是/bin/bash,这样的机制使得我们可以轻松地引用任何的解释器 查看该linux系统支持的shell cat /etc/shells/bin/sh/bin/bash/us…...

微服务简介
微服务简介 微服务架构是一种软件架构模式,它将一个大型应用程序拆分为一组小型、独立的服务,每个服务都有自己的业务逻辑和数据存储。这些服务可以独立开发、部署和扩展,通常使用HTTP或其他轻量级通信协议进行通信。 以下是微服务架构的一…...

PHP自己的框架2.0设置常量并绑定容器(重构篇三)
目录 1、设置常量并绑定容器 2、容器增加设置当前容器的实例和绑定一个类实例当容器 3、将常量绑定到容器中 4、运行效果 1、设置常量并绑定容器 2、容器增加设置当前容器的实例和绑定一个类实例当容器 //设置当前容器的实例public static function setInstance($instance){…...

重建大师提交空三后引擎状态是等待,怎么开启?
答:图片中这是在自由网空三阶段,整个AT都是等待中,可以修改任务目录和监控目录看一下,先设置引擎,再提交空三。...

【数据结构】堆的向上调整和向下调整以及相关方法
💐 🌸 🌷 🍀 🌹 🌻 🌺 🍁 🍃 🍂 🌿 🍄🍝 🍛 🍤 📃 文章目录 一、堆的概念二、堆的性质…...

【蓝桥杯选拔赛真题60】Scratch旋转风车 少儿编程scratch图形化编程 蓝桥杯选拔赛真题解析
目录 scratch旋转风车 一、题目要求 编程实现 二、案例分析 1、角色分析...

调用支付宝接口响应40004 SYSTEM_ERROR问题排查
在对接支付宝API的时候,遇到了一些问题,记录一下排查过程。 Body:{"datadigital_fincloud_generalsaas_face_certify_initialize_response":{"msg":"Business Failed","code":"40004","sub_msg…...
脑机新手指南(八):OpenBCI_GUI:从环境搭建到数据可视化(下)
一、数据处理与分析实战 (一)实时滤波与参数调整 基础滤波操作 60Hz 工频滤波:勾选界面右侧 “60Hz” 复选框,可有效抑制电网干扰(适用于北美地区,欧洲用户可调整为 50Hz)。 平滑处理&…...

华为OD机试-食堂供餐-二分法
import java.util.Arrays; import java.util.Scanner;public class DemoTest3 {public static void main(String[] args) {Scanner in new Scanner(System.in);// 注意 hasNext 和 hasNextLine 的区别while (in.hasNextLine()) { // 注意 while 处理多个 caseint a in.nextIn…...

学习STC51单片机31(芯片为STC89C52RCRC)OLED显示屏1
每日一言 生活的美好,总是藏在那些你咬牙坚持的日子里。 硬件:OLED 以后要用到OLED的时候找到这个文件 OLED的设备地址 SSD1306"SSD" 是品牌缩写,"1306" 是产品编号。 驱动 OLED 屏幕的 IIC 总线数据传输格式 示意图 …...
ip子接口配置及删除
配置永久生效的子接口,2个IP 都可以登录你这一台服务器。重启不失效。 永久的 [应用] vi /etc/sysconfig/network-scripts/ifcfg-eth0修改文件内内容 TYPE"Ethernet" BOOTPROTO"none" NAME"eth0" DEVICE"eth0" ONBOOT&q…...
Bean 作用域有哪些?如何答出技术深度?
导语: Spring 面试绕不开 Bean 的作用域问题,这是面试官考察候选人对 Spring 框架理解深度的常见方式。本文将围绕“Spring 中的 Bean 作用域”展开,结合典型面试题及实战场景,帮你厘清重点,打破模板式回答,…...

解析奥地利 XARION激光超声检测系统:无膜光学麦克风 + 无耦合剂的技术协同优势及多元应用
在工业制造领域,无损检测(NDT)的精度与效率直接影响产品质量与生产安全。奥地利 XARION开发的激光超声精密检测系统,以非接触式光学麦克风技术为核心,打破传统检测瓶颈,为半导体、航空航天、汽车制造等行业提供了高灵敏…...

渗透实战PortSwigger靶场:lab13存储型DOM XSS详解
进来是需要留言的,先用做简单的 html 标签测试 发现面的</h1>不见了 数据包中找到了一个loadCommentsWithVulnerableEscapeHtml.js 他是把用户输入的<>进行 html 编码,输入的<>当成字符串处理回显到页面中,看来只是把用户输…...

华为云Flexus+DeepSeek征文 | 基于Dify构建具备联网搜索能力的知识库问答助手
华为云FlexusDeepSeek征文 | 基于Dify构建具备联网搜索能力的知识库问答助手 一、构建知识库问答助手引言二、构建知识库问答助手环境2.1 基于FlexusX实例的Dify平台2.2 基于MaaS的模型API商用服务 三、构建知识库问答助手实战3.1 配置Dify环境3.2 创建知识库问答助手3.3 使用知…...
Spring Boot 与 Kafka 的深度集成实践(二)
3. 生产者实现 3.1 生产者配置 在 Spring Boot 项目中,配置 Kafka 生产者主要是配置生产者工厂(ProducerFactory)和 KafkaTemplate 。生产者工厂负责创建 Kafka 生产者实例,而 KafkaTemplate 则是用于发送消息的核心组件&#x…...