当前位置: 首页 > news >正文

【RabbitMQ】RabbitMQ中核心概念交换机(Exchange)、队列(Queue)和路由键(Routing Key)等详细介绍

博主介绍:✌全网粉丝21W+,CSDN博客专家、Java领域优质创作者,掘金/华为云/阿里云/InfoQ等平台优质作者、专注于Java技术领域✌

技术范围:SpringBoot、SpringCloud、Vue、SSM、HTML、Nodejs、Python、MySQL、PostgreSQL、大数据、物联网、机器学习等设计与开发。

感兴趣的可以先关注收藏起来,在工作中、生活上等遇到相关问题都可以给我留言咨询,希望帮助更多的人。

RabbitMQ中核心概念交换机(Exchange)、队列(Queue)和路由键(Routing Key)等详细介绍

  • 一、概览
  • 二、核心概念
    • 2.1 交换机(Exchange)
    • 2.2 队列(Queue)
    • 2.3 路由键(Routing Key)
    • 2.4 消息的发送流程通常
  • 三、 RabbitMQ其他概念
    • 3.1 死信队列
    • 3.2 队列类型

RabbitMQ 是一个消息代理系统,使用 交换机(Exchange)队列(Queue)路由键(Routing Key)来管理消息的传递。它们分别起到不同的作用,构成了消息从生产者到消费者的传递路径。它们一起协同工作来实现消息的发布和订阅。

一、概览

三者的区别和作用总结

名称作用和功能角色区别
交换机(Exchange)接收生产者的消息并根据路由键将消息发送到一个或多个队列。交换机本身不保存消息,只负责转发消息。中间人决定消息如何分发到不同的队列
队列(Queue)用于存储消息,等待消费者来处理。消费者从队列中拉取消息进行处理。队列是消息的最终接收点,消息只能在队列中被消费一次。消费者终点存储和传递消息
路由键(Routing Key)生产者指定的一个字符串,用来决定交换机如何将消息路由到队列。路由键可以是精确匹配或模糊匹配(使用通配符)。消息路由控制决定消息走向哪些队列

三者之间的关系

  • 生产者(Producer):向 交换机 发送消息,并指定一个 路由键。
  • 交换机(Exchange):根据绑定的规则和 路由键,将消息转发到合适的 队列。
  • 队列(Queue):消息最终到达 队列,并等待消费者取出并处理。
  • 消费者(Consumer):从队列中取出消息进行处理。

二、核心概念

RabbitMQ 是一个开源的消息代理(Message Broker),用于在应用程序之间传递消息。它实现了高级消息队列协议(AMQP),提供了可靠的消息传递和消息路由机制,以支持分布式系统的开发。

2.1 交换机(Exchange)

作用:

交换机负责接收来自生产者的消息,并根据一定的路由规则将消息分发给一个或多个队列。它是生产者和队列之间的中间层,生产者永远不会直接将消息发送到队列,而是通过交换机。

种类:

RabbitMQ 中有几种类型的交换机,每种交换机的消息路由行为都不同:

  • Direct(直连交换机):根据精确匹配路由键(Routing Key)来将消息转发到绑定了相同路由键的队列。
  • Fanout(扇出交换机):不处理路由键,直接将消息广播给绑定到该交换机的所有队列。类似广播机制。
  • Topic(主题交换机):根据路由键的模式匹配(可以使用通配符)将消息路由到符合条件的队列。
  • Headers(头交换机):根据消息的 headers(头部信息)属性来路由,而不是使用路由键。

作用场景:
交换机的主要作用是 决定消息应该被发送到哪些队列,每种交换机的类型决定了消息的路由逻辑。

2.2 队列(Queue)

作用:

队列是消息的实际存储位置。消息被发送到队列后,消费者从队列中取出并处理。队列中的消息按照 先进先出(FIFO) 的顺序被消费者处理。

  • 队列是点对点通信的终点,消费者从队列中拉取消息并处理,每个消息只会被一个消费者处理(除非有特别的广播机制)。
  • 消息可以在队列中持久化(持久化队列),即使 RabbitMQ 服务器重启,消息仍然会保存在队列中。

作用场景:

队列的作用是 存储和传递消息。消息在队列中被保存,直到消费者来获取和处理消息。队列可以支持多种消费者,并且保证消息被处理一次且仅一次。

2.3 路由键(Routing Key)

作用:

路由键是生产者在将消息发送给交换机时提供的一个字符串,用来指定消息的路由路径。交换机会根据路由键的内容,决定该消息应该发送到哪些队列。

  • 在 Direct 交换机 中,路由键用于精确匹配。例如,路由键 task_queue 只会将消息发送到绑定了 task_queue 路由键的队列。
  • 在 Topic 交换机 中,路由键可以使用通配符进行模糊匹配。例如,device.* 可以匹配 device.datadevice.status,而 device.# 可以匹配多个词。

作用场景:

路由键的作用是 指定消息传递路径。交换机会根据路由键将消息发送到符合条件的队列。

2.4 消息的发送流程通常

消息的发送流程通常如下:

  • 生产者发布消息,指定交换机和路由键。

  • 交换机根据路由键将消息路由到一个或多个队列。

  • 消费者从队列中获取消息并处理它们。

通过这种方式,RabbitMQ实现了消息的可靠传递和分发,可以用于构建各种应用程序,包括消息队列、发布/订阅系统、任务分发等。

三、 RabbitMQ其他概念

AMQP:AMQP(Advanced Message Queuing Protocol)是一种协议,用于定义消息传递的规范。RabbitMQ是AMQP协议的一个流行实现之一,它允许不同的应用程序之间通过消息进行通信。

以下是一些关于 RabbitMQ 的详细知识:

  • 生产者:生产者是消息的发送方。它们创建消息并将其发布到 RabbitMQ 的交换机上。生产者通常将消息发送到一个或多个队列,以便消费者可以订阅并处理这些消息。

  • 交换机:交换机是消息的路由中心,它接收从生产者发送的消息,并根据预定义的规则将它们路由到一个或多个队列中。RabbitMQ支持多种类型的交换机,包括直连、主题、扇出和头交换机。

  • 队列:队列是消息的容器,它们用于存储消息,直到消费者准备好接收和处理它们。多个消费者可以订阅同一个队列,但只有一个消费者会接收到每条消息。

  • 消费者:消费者是消息的接收方,它们订阅队列并从中获取消息。一旦消费者接收到消息,它们可以对消息进行处理,例如执行某些任务或将数据存储到数据库中。

  • 绑定:绑定是交换机和队列之间的关联关系。它定义了如何将消息从交换机路由到队列。绑定通常使用路由键(Routing Key)来指定消息的路由规则。

  • 虚拟主机:RabbitMQ 允许创建多个虚拟主机,每个虚拟主机都是一个独立的消息代理环境。虚拟主机之间相互隔离,允许不同应用程序在同一台 RabbitMQ 服务器上使用不同的消息队列。

  • 持久化:消息和队列可以设置为持久化,这意味着它们将在 RabbitMQ 服务器重启后保留。这是确保消息不会丢失的重要方式,特别是对于关键的应用程序。

  • 确认机制:RabbitMQ 提供了消息确认机制,确保消息在发送和接收过程中不会丢失。生产者可以等待来自消费者的确认,以确保消息已成功处理。

  • 死信队列:RabbitMQ 允许定义死信队列,用于处理无法成功处理的消息。当消息无法被路由到队列时,它们可以被发送到死信队列,以后进行处理。

  • 集群:RabbitMQ 支持集群模式,允许多个 RabbitMQ 服务器一起工作以提高可用性和性能。

  • 插件系统:RabbitMQ 可以通过插件进行扩展,允许添加各种功能,如消息转换、身份验证、监控等。

RabbitMQ 是一个强大的消息代理,广泛用于分布式系统、微服务架构、任务队列、事件驱动架构等场景。了解这些基本概念可以更好地理解和使用 RabbitMQ 来构建可靠的消息通信系统。

3.1 死信队列

死信队列(Dead Letter Queue,简称DLQ)是消息队列系统中的一个重要概念,它用于处理无法成功被消费的消息。当消息无法被消费者正常处理时,通常会被发送到死信队列,以后进行进一步的处理或分析。以下是有关死信队列的详细信息:

什么是死信队列:

消息在队列中过期,即超过了一定的存活时间。

消息被拒绝(NACK)并且无法重新投递。

消息在消费者处理时发生了异常。

死信队列是一个特殊的队列,用于接收无法被消费者成功处理的消息。这些消息被认为是"死信",通常是由于以下原因之一:

为什么使用死信队列:

死信队列的主要目的是处理消息处理失败或异常情况,以防止消息丢失。通过将死信消息路由到特定的队列,你可以进行进一步的调查、日志记录、错误处理或重试。

死信队列还可以用于延迟消息处理,例如在一段时间后重新尝试处理失败的消息。

设置死信队列:

要设置死信队列,你需要创建一个普通队列,并为它配置一个死信交换机(Dead Letter Exchange)和一个死信路由键(Dead Letter Routing Key)。

当消息成为死信时,它们将被重新路由到死信交换机,并使用死信路由键发送到死信队列。

应用场景:

重试机制:当消息处理失败时,可以将消息发送到死信队列,然后在稍后的时间内重新尝试处理。

日志记录和监控:可以将失败的消息记录到日志中以进行分析和监控。

错误处理:可以通过死信队列执行自定义错误处理逻辑,例如发送通知或触发报警。

死信队列可以用于处理各种应用场景,例如:

总之,死信队列是消息队列系统中的一个关键组件,用于处理处理失败的消息,以提高系统的可靠性和容错性。通过合理配置和使用死信队列,可以更好地管理消息的生命周期和处理失败情况。不同的消息队列系统(如RabbitMQ、Kafka等)都支持死信队列的概念,但具体的配置和用法可能有所不同。

3.2 队列类型

消息队列系统通常支持多种队列类型,每种类型都适用于不同的使用场景和需求。以下是一些常见的队列类型及其特点:

  • FIFO 队列(First-In-First-Out):

特点:消息按照它们进入队列的顺序进行处理,即先进先出。

用途:适用于需要按照顺序处理消息的场景,确保消息的顺序性。

  • 优先级队列:

特点:消息可以分配不同的优先级,高优先级的消息将被优先处理。

用途:适用于需要按照优先级处理消息的场景,确保高优先级消息能够尽快处理。

  • 延迟队列(Delay Queue):

特点:消息可以设置延迟时间,在指定时间后才会被处理。

用途:适用于需要延迟处理消息的场景,如定时任务或消息重试。

  • 扇出队列(Fanout Queue):

特点:消息被广播到所有绑定的队列,每个队列都会接收一份消息的副本。

用途:用于发布/订阅模式,消息广播到多个消费者,每个消费者都可以独立处理消息。

  • 主题队列(Topic Queue):

特点:消息根据主题或通配符路由到匹配的队列。

用途:用于高度灵活的消息路由,支持复杂的消息过滤和匹配规则。

  • 直连队列(Direct Queue):

特点:消息根据指定的路由键路由到匹配的队列。

用途:用于简单的消息路由,每个队列通常与一个唯一的路由键相关联。

  • 持久队列:

特点:队列和消息可以设置为持久化,确保在消息代理重启后不会丢失。

用途:用于关键数据和任务的持久化存储,确保数据不会丢失。

  • 临时队列:

特点:队列通常是临时的,只在连接期间存在,连接断开后会自动删除。

用途:适用于一次性任务或短期通信的场景。

  • 死信队列(Dead Letter Queue):

特点:用于处理无法成功处理的消息,将失败的消息发送到死信队列以后续处理。

用途:用于处理失败的消息,执行错误处理或重试。

不同的队列类型适用于不同的业务需求和应用场景。在选择队列类型时,需要根据具体需求来权衡各种特性和限制。根据消息队列系统的不同,支持的队列类型和功能可能有所不同。


好了,今天分享到这里。希望你喜欢这次的探索之旅!不要忘记 “点赞” 和 “关注” 哦,我们下次见!🎈

本文完结!

祝各位大佬和小伙伴身体健康,万事如意,发财暴富,扫下方二维码与我一起交流!!!在这里插入图片描述

相关文章:

【RabbitMQ】RabbitMQ中核心概念交换机(Exchange)、队列(Queue)和路由键(Routing Key)等详细介绍

博主介绍:✌全网粉丝21W,CSDN博客专家、Java领域优质创作者,掘金/华为云/阿里云/InfoQ等平台优质作者、专注于Java技术领域✌ 技术范围:SpringBoot、SpringCloud、Vue、SSM、HTML、Nodejs、Python、MySQL、PostgreSQL、大数据、物…...

【AI知识】过拟合、欠拟合和正则化

一句话总结: 过拟合和欠拟合是机器学习中的两个相对的概念,正则化是用于解决过拟合的方法。 1. 欠拟合: 指模型在训练数据上表现不佳,不能充分捕捉数据的潜在规律,导致在训练集和测试集上的误差都很高。欠拟合意味着模…...

计算机毕设-基于springboot的航空散货调度系统的设计与实现(附源码+lw+ppt+开题报告)

博主介绍:✌多个项目实战经验、多个大型网购商城开发经验、在某机构指导学员上千名、专注于本行业领域✌ 技术范围:Java实战项目、Python实战项目、微信小程序/安卓实战项目、爬虫大数据实战项目、Nodejs实战项目、PHP实战项目、.NET实战项目、Golang实战…...

视图、转发与重定向、静态资源处理

目录 视图 默认视图 视图机制原理 自定义视图 请求转发与重定向 静态资源处理 视图 每个视图解析器都实现了 Ordered 接口并开放出一个 order 属性 可以通过 order 属性指定解析器的优先顺序,order 越小优先级越高 默认是最低优先级,Integer.MAX_…...

优选算法——分治(快排)

1. 颜色分类 题目链接:75. 颜色分类 - 力扣(LeetCode) 题目展示: 题目分析:本题其实就要将数组最终分成3块儿,这也是后面快排的优化思路,具体大家来看下图。 这里我们上来先定义了3个指针&…...

【Linux系统】文件系统

Windows 和 Linux 的文件系统: windows:NTFS —> NTFS:磁盘大于目录:目录是磁盘的一部分。ubuntu :EXT4 —> EXT4: 目录大于磁盘:磁盘是目录的一部分。 Windows文件系统的特点 基于分区的文件系统: Windows…...

javaweb的基础

文章的简介: 页面的展示(HTML)页面的修改、绑定、弹窗(js的dom、bom等)页面的请求(Ajax) 1、在HTML中用标签和css样式实现了浏览器页面。 2、用JS实现页面内容(图片,复选框、文本颜色内容)的修改和弹框&…...

家里养几条金鱼比较好?

金鱼,作为备受喜爱的家庭水族宠物,其饲养数量一直是众多养鱼爱好者关注的焦点。究竟养几条金鱼最为适宜,实则需要综合考量多方面因素,方能达到美观、健康与和谐的理想养鱼境界。 从风水文化的视角来看,金鱼数量有着诸…...

写作词汇积累:差池、一体两面、切实可行极简理解

差池 【差池】可以是名词,是指意外的事或错误。 【差池】也可以是形容词,是指参差不齐、差劲或不行。 1. 由于操作不当,导致这次实验出现了【差池】,我们需要重新分析原因并调整方案。(名词,表示意外的事…...

移远EC200A-CN的OPENCPU使用GO开发嵌入式程序TBOX

演示地址: http://134.175.123.194:8811 admin admin 演示视频: https://www.bilibili.com/video/BV196q2YQEDP 主要功能 WatchDog 1. 守护进程 2. OTA远程升级 TBOX 1. 数据采集、数据可视化、数据上报(内置Modbus TCP/RTU/ASCII,GPS协…...

LEED绿色建筑认证最新消息

关于LEED绿色建筑认证的最新消息,可以从以下几个方面进行概述: 一、认证体系更新与发展 LEED认证体系不断更新和完善,以更好地适应全球绿色建筑的发展趋势。例如,LEED v4能源更新已通过投票,并于2024年3月1日全面启用…...

SpringBoot中集成常见邮箱中容易出现的问题

本来也没打算想写得。不过也是遇到一些坑&#xff0c;就记录一下吧&#xff0c;也折腾了小半天 1.maven配置 <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-mail</artifactId></dependency>2…...

webstorm开发uniapp(从安装到项目运行)

1、下载uniapp插件 下载连接&#xff1a;Uniapp Tool - IntelliJ IDEs Plugin | Marketplace &#xff08;结合自己的webstorm版本下载&#xff0c;不然解析不了&#xff09; 将下载到的zip文件防在webstorm安装路径下&#xff0c;本文的地址为&#xff1a; 2、安装uniapp插…...

C# 探险之旅:第七节 - 条件判断(三元判断符):? : 的奇妙冒险

嘿&#xff0c;勇敢的探险家们&#xff01;欢迎来到 C# 编程世界的奇妙之旅的第七节。今天&#xff0c;我们要探索的是一个神秘而强大的宝藏——三元判断符 ? :。别怕&#xff0c;它听起来复杂&#xff0c;但实际上比找宝藏还简单&#xff01; 场景设定&#xff1a;宝藏的选择…...

FlinkCDC实战:将 MySQL 数据同步至 ES

&#x1f4cc; 当前需要处理的业务场景: 将订单表和相关联的表(比如: 商品表、子订单表、物流信息表)组织成宽表, 放入到 ES 中, 加速订单数据的查询. 同步数据到 es. 概述 1. 什么是 CDC 2. 什么是 Flink CDC 3. Flink CDC Connectors 和 Flink 的版本映射 实战 1. 宽表查…...

debug小记

红框&#xff1a; 步过&#xff1a;遇到方法不想进入方法 绿框&#xff1a;代码跑在第几行也可以看见 蓝框&#xff1a;可以显示变量的值&#xff0c;三种方式都可以看变量的值...

Qt C++ 显示多级结构体,包括结构体名、变量名和值

文章目录 mainwindow.hmainwindow.cppstructures.hmain.cpp QTreeView 和 QStandardItemModel 来实现。以下是实现这一功能的步骤和示例代码&#xff1a; 定义多级结构体&#xff1a; 假设你有一个多级结构体&#xff0c;如下所示&#xff1a; struct SubStruct {int subValue…...

【JAVA】旅游行业中大数据的使用

一、应用场景 数据采集与整合&#xff1a;全面收集旅游数据&#xff0c;如客流量、游客满意度等&#xff0c;整合形成统一数据集&#xff0c;为后续分析提供便利。 舆情监测与分析&#xff1a;实时监测旅游目的地的舆情信息&#xff0c;运用NLP算法进行智能处理&#xff0c;及…...

【AI+网络/仿真数据集】1分钟搭建云原生端到端5G网络

导语&#xff1a; 近期智慧网络开放创新平台上线了端到端网络仿真能力&#xff0c;区别于传统的网络仿真工具需要复杂的领域知识可界面操作&#xff0c;该平台的网络仿真能力主打一个小白友好和功能专业。 https://jiutian.10086.cn/open/​jiutian.10086.cn/open/ 端到端仿…...

微服务-01【续】

1.OpenFeign 上篇文章我们利用Nacos实现了服务的治理&#xff0c;利用利用RestTemplate实现了服务的远程调用。但是远程调用的代码太复杂了&#xff1a; 而且这种调用方式&#xff0c;与原本的本地方法调用差异太大&#xff0c;编程时的体验也不统一&#xff0c;一会儿远程调用…...

AI-调查研究-01-正念冥想有用吗?对健康的影响及科学指南

点一下关注吧&#xff01;&#xff01;&#xff01;非常感谢&#xff01;&#xff01;持续更新&#xff01;&#xff01;&#xff01; &#x1f680; AI篇持续更新中&#xff01;&#xff08;长期更新&#xff09; 目前2025年06月05日更新到&#xff1a; AI炼丹日志-28 - Aud…...

Admin.Net中的消息通信SignalR解释

定义集线器接口 IOnlineUserHub public interface IOnlineUserHub {/// 在线用户列表Task OnlineUserList(OnlineUserList context);/// 强制下线Task ForceOffline(object context);/// 发布站内消息Task PublicNotice(SysNotice context);/// 接收消息Task ReceiveMessage(…...

理解 MCP 工作流:使用 Ollama 和 LangChain 构建本地 MCP 客户端

&#x1f31f; 什么是 MCP&#xff1f; 模型控制协议 (MCP) 是一种创新的协议&#xff0c;旨在无缝连接 AI 模型与应用程序。 MCP 是一个开源协议&#xff0c;它标准化了我们的 LLM 应用程序连接所需工具和数据源并与之协作的方式。 可以把它想象成你的 AI 模型 和想要使用它…...

Objective-C常用命名规范总结

【OC】常用命名规范总结 文章目录 【OC】常用命名规范总结1.类名&#xff08;Class Name)2.协议名&#xff08;Protocol Name)3.方法名&#xff08;Method Name)4.属性名&#xff08;Property Name&#xff09;5.局部变量/实例变量&#xff08;Local / Instance Variables&…...

鸿蒙中用HarmonyOS SDK应用服务 HarmonyOS5开发一个医院挂号小程序

一、开发准备 ​​环境搭建​​&#xff1a; 安装DevEco Studio 3.0或更高版本配置HarmonyOS SDK申请开发者账号 ​​项目创建​​&#xff1a; File > New > Create Project > Application (选择"Empty Ability") 二、核心功能实现 1. 医院科室展示 /…...

2025盘古石杯决赛【手机取证】

前言 第三届盘古石杯国际电子数据取证大赛决赛 最后一题没有解出来&#xff0c;实在找不到&#xff0c;希望有大佬教一下我。 还有就会议时间&#xff0c;我感觉不是图片时间&#xff0c;因为在电脑看到是其他时间用老会议系统开的会。 手机取证 1、分析鸿蒙手机检材&#x…...

第 86 场周赛:矩阵中的幻方、钥匙和房间、将数组拆分成斐波那契序列、猜猜这个单词

Q1、[中等] 矩阵中的幻方 1、题目描述 3 x 3 的幻方是一个填充有 从 1 到 9 的不同数字的 3 x 3 矩阵&#xff0c;其中每行&#xff0c;每列以及两条对角线上的各数之和都相等。 给定一个由整数组成的row x col 的 grid&#xff0c;其中有多少个 3 3 的 “幻方” 子矩阵&am…...

智能分布式爬虫的数据处理流水线优化:基于深度强化学习的数据质量控制

在数字化浪潮席卷全球的今天&#xff0c;数据已成为企业和研究机构的核心资产。智能分布式爬虫作为高效的数据采集工具&#xff0c;在大规模数据获取中发挥着关键作用。然而&#xff0c;传统的数据处理流水线在面对复杂多变的网络环境和海量异构数据时&#xff0c;常出现数据质…...

STM32---外部32.768K晶振(LSE)无法起振问题

晶振是否起振主要就检查两个1、晶振与MCU是否兼容&#xff1b;2、晶振的负载电容是否匹配 目录 一、判断晶振与MCU是否兼容 二、判断负载电容是否匹配 1. 晶振负载电容&#xff08;CL&#xff09;与匹配电容&#xff08;CL1、CL2&#xff09;的关系 2. 如何选择 CL1 和 CL…...

脑机新手指南(七):OpenBCI_GUI:从环境搭建到数据可视化(上)

一、OpenBCI_GUI 项目概述 &#xff08;一&#xff09;项目背景与目标 OpenBCI 是一个开源的脑电信号采集硬件平台&#xff0c;其配套的 OpenBCI_GUI 则是专为该硬件设计的图形化界面工具。对于研究人员、开发者和学生而言&#xff0c;首次接触 OpenBCI 设备时&#xff0c;往…...