198、RabbitMQ 的核心概念 及 工作机制概述; Exchange 类型 及 该类型对应的路由规则;了解什么是JMS。

目录

  • JMS 讲解
  • ★ RabbitMQ的核心概念
  • ★ RabbitMQ工作机制
  • ★ Connection(连接) 与 Channel(通信信道)
  • ★ Exchange
  • ★ Exchange与Queue
  • ★ Exchange的类型(4种)及 该类型对应的路由规则

看RabbitMQ 之前,可以先了解下什么是 JMS。

JMS 讲解

先简单看下 JMS 是什么,用来对比。
JMS 也是一种消息机制
JMS 规范,属于 Java EE 规范
在这里插入图片描述

在这里插入图片描述
在这里插入图片描述

在这里插入图片描述
在这里插入图片描述

在这里插入图片描述

AMQP ( Advanced Message Queuing Protocol ) 高级消息队列协议
在这里插入图片描述

★ RabbitMQ的核心概念

Connection: 代表客户端(包括消息生产者和消费者)与RabbitMQ之间的连接。

Channel: 连接内部的Channel。

Exchange: 充当消息交换机的组件。

Queue: 消息队列。

★ RabbitMQ工作机制

AMQP ( Advanced Message Queuing Protocol ) 高级消息队列协议
RabbitMQ 是一种属于 AMQP 这种协议的消息组件。
RabbitMQ 是遵循 AMQP 的一个实现

▲ 原有JMS只有三层:

消息生产者---------->消息目的---------->消息消费者

▲ AMQP(RabbitMQ)增加了一层

消息生产者----------Exchange-----------消息队列(目的)----------消息消费者

同理,无论是消息生产者,还是消息消费者,它们都使用Connection与消息Broker之间建立连接——这一点与JMS是一样。

RabbitMQ的消息生产者、消息消费者实际与消息Broker通信的是Channel,
JMS实际则使用Session。

在这里插入图片描述

★ Connection(连接) 与 Channel(通信信道)

▲ 不管是消息生产者,还是消息消费者,它们都要通过Connection建立与RabbitMQ之间的连接,因此Connection就代表客户端与RabbitMQ之间的连接。

▲ 但客户端与RabbitMQ之间实际通信所用的是Channel(信道),这是因为RabbitMQ采用了类似于Java NIO的做法,避免为应用程序中的每个线程都建立单独的连接,因此是使用Channel来复用连接,这样不仅可以降低性能开销,而且也便于管理。

简单两句话:

 - Connction代表了客户端与消息Broker之间的连接。建立连接用Connection。- Channel代表了客户端与消息Broker之间的通信信道。实际通信用Channel。Channel位于Connection之内,也就是说,Channel必须通过Connection来获得。

★ Exchange

消息生产者发送消息时,只需指定两个关键信息:

 - exchange:将该消息发送到哪个Exchange。- routing key:消息的路由key。该路由key会决定消息要被路由到哪些消息队列。

RabbitMQ的消息生产者只需指定将消息发送到哪个Exchange,Exchange相当于消息交换机,

▲ Exchange 它会根据自身的类型和消息的路由key(routing key),将消息分发到一个或多个消息队列(Queue)
消息实际依然由于消息队列来负责管理。
消息由Exchange负责分发。

▲ 简单来说:
消息生产者将消息发送给Exchange,Exchange负责将消息分发给对应的Queue,Exchange分发消息的关键在于它本身的类型和路由key。

▲ 消息生产者发送消息时,与消息队列是无关的。(只跟exchange和routing key有关)

▲ 消息消费者接收消息时,只需从指定消息队列中获取消息即可,与Exchange是无关的。
(只跟消息队列有关)

★ Exchange与Queue

▲ 为了让Exchange能将信息分发给Queue,Queue需要将自己绑定到Exchange上(也就是让Exchange来管理多个Queue),
Exchange只会将消息分发给绑定到自己的Queue,没有绑定的Queue不会得到Exchange分发的消息。

将Queue绑定到Exchange的过程,就相当于将Queue注册到Exchange的过程。

▲ 将Queue绑定到Exchange时,也需要指定一个路由key。

▲ Exchange就根据发送消息时指定的路由key、绑定Queue时指定的路由key来决定要将消息分发给哪些Queue。

【备注】:路由key(就是个字符串),两个地方需要用到:

A:将Queue绑定到Exchange时,需要指定路由key。

B:发送消息时,需要Exchange和路由key。




★ Exchange的类型(4种)及 该类型对应的路由规则


Exchange来分发消息时,要看Exchange本身的类型、消息的路由key。

fan:扇子  out:出现、向外   fanout:扇出、展开、散开、分列

fanout: 广播Exchange这种类型的Exchange会将消息广播到所有与它绑定的Queue。
这种类型的Exchange在分发消息时不看路由key。
只要将消息发送到该Exchange,该消息就会被自动广播所有消息队列——这就是典型的Pub-Sub模型。

direct: 这种类型的Exchange将消息直接发送到路由key对应的队列。
direct:笔直的、径直的
消息队列绑定到Exchange时,要指定路由key;
发送消息时,也要指定路由key;
就是使用direct类型的Exchange只有当两个路由key完全相同时,该消息队列才能被分发消息

topic: 这种类型的Exchange在匹配路由key时支持通配符,相当于它是增强型的direct

【备注】:此处的topic类型的Exchange与JMS的消息主题没有半毛钱的关系。

headers: 这种类型的Exchange要根据消息自带的头信息进行路由。这种类型比较少用。




消息发送到消息队列的一些示例:

如图:假设消息生产者又发送了一条消息,路由key 是 abc , 那么这个 路由key 是 abc 的 消息,在发送到 exchange 之后,就会直接被丢弃了,因为 exchange 绑定的众多 queue 消息队列中,没有对应的 路由key 是 abc。所以这个消息不会分发给任何的消息队列。
在这里插入图片描述

 路由key通配符解释:单词与单词之间用【  .   点号】隔开, 比如:路由key是:aaa.bbb.ccc   ,就表示这个路由key是由三个单词组成的。【* . crazyit . * 】 表示这个 路由key 只能是三个单词组成,第一个和第三个单词随便,
但是中间的单词一定要是 crazyit  ,才可以匹配上。【* . org】 表示这个 路由key 只能是两个单词组成,第一个单词随便,
但是第二个单词一定要是 org,才可以匹配上【# . org】 # 号代表0-N 个单词,表示这个 路由key 是多个单词组成,或者只有一个 org 也算匹配上。org 前面有多少个单词都没问题,或者没单词也可以,只要最后一个单词是 org , 那么就可以匹配上。

在这里插入图片描述

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

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

相关文章

技术分享| 二进制部署MySQL

一、介绍 ​MySQL是一个关系型数据库管理系统,由瑞典MySQL AB 公司开发,属于 Oracle 旗下产品。MySQL 是最流行的关系型数据库管理系统之一,在 WEB 应用方面,MySQL是最好的 RDBMS (Relational Database Management System&#x…

拼多多历史价格数据接口,拼多多商品历史价格接口,拼多多API接口

采集拼多多商品历史价格接口可以采用以下方式: 使用价格监控工具。价格监控工具是一种可以自动监测商品价格变化的工具,它可以帮助消费者快速采集拼多多商品价格信息,还可以提供价格变动趋势的图表分析,使消费者更好地掌握商品价…

PLL的环路滤波器

本篇文章仅为分享PLL学习过程及一些公式推导,如有错误,还请批评指正! 文章目录 1、一阶RC低通滤波器(II类锁相环)2、二阶RC低通滤波器A、加电容型B、加RC低通滤波器型 3、三阶低通滤波器 锁相环3大组成部分&#xff1…

Unity 表面凝结水珠效果(无需编码案例分享)

文章目录 前言正文1、准备工作2、瓶子的表面会先慢慢变白3、身周围的物体的反射会慢慢变得模糊4、周围的反射又会慢慢的变回清晰5、出现一个个不跪着的小水珠 结语 前言 今天跟大家分享一一个非常简单的使用Unity制作出在物体便面凝结小水珠的过程动画,老规矩先上图…

JMeter三种常用的逻辑控制器

一. 如果(if)控制器 1.1 使用js语法来判断: ## 1.2 使用jexl3函数来判断性能好: 二. 循环控制器 三. ForEach控制器 ForEach控制器一般和用户自定义变量或者正则表达式提取器一起使用,其在用户自定义变量或者从正…

c++视觉处理---均值滤波

均值滤波 cv::blur()函数是OpenCV中用于应用均值滤波的函数。均值滤波是一种简单的平滑技术,它计算每个像素周围像素的平均值,并用该平均值替代原始像素值。这有助于降低图像中的噪声,并可以模糊图像的细节。 以下是cv::blur()函数的基本用…

如何在手机上设置节日提醒和倒计时天数?

在平淡的生活和工作中,时不时有各种各样节日的点缀,为我们的日常增添了一些仪式感,例如春节、元宵节、情人节、端午节、七夕节等。此外还有一些特殊的日子也值得纪念,例如恋爱纪念日、结婚纪念日、亲朋好友生日等。面对这些节日&a…

【数据结构】算法的空间复杂度

🦄个人主页:修修修也 🎏所属专栏:数据结构 ⚙️操作环境:Visual Studio 2022 算法空间复杂度的定义 算法的时间复杂度和空间复杂度是度量算法好坏的两个重要量度,在实际写代码的过程中,我们完全可以用空间来换时间,比如说,我们要判断某某年是不是闰年,大…

css实现一行N个元素动态布局(以4个为例)

昨日同事问了我一个前端问题,前端开发的尺寸都不按照UI图上面还原的吗? 我了解了其中原由,告知UI图并不会考虑到所有的场景,只能给个案例,画图是死的,代码写出来的得是活的。就像他遇到的案例,请…

GTX312L比TSM12更具优势的智能门锁触摸芯片方案

韩国GreenChip(绿芯)GTX312L是一款高灵敏、超强抗干扰能力具有自动灵敏度校准的12通道电容传感器,电源电压范围为1.8V~5.0V,支持单键/多点触控;采用I2C通信协议;内部控制寄存器可以使用I2C读写接…

华为云云耀云服务器L实例评测使用 | 云耀云服务器L实例Docker可视化Portainer容器管理

一、使用背景 之前一直在用阿里云或者腾讯云的服务器,现在接触了一下华为云的服务器实例,点开产品列表发现有弹性云服务器ECS、云耀云服务器HECS等,本文主要使用云耀云服务器,看到官方简介: 华为云耀云服务器&#x…

uniapp小程序中给web-view页面添加授权弹窗(使用cover-view组件覆盖实现该功能)

效果图: web-view是承载网页的容器。会自动铺满整个小程序页面,个人类型的小程序暂不支持使用。 再看下面一个提示: 每个页面只能有一个 web-view,web-view 会自动铺满整个页面,并覆盖其他组件。 也就是说,…

Android Studio版本升级后的问题 gradle降级、jdk升级

Cannot use TaskAction annotation on method IncrementalTask.taskAction$gradle_core() because interface org.gradle.api.tasks.incremental.IncrementalTaskInputs is not a valid parameter to an action method. 修改下面两处地方分别为7.0.3、7.3.3Android Gradle plu…

前端-Vue-开发指南

VueJS 开源文档 拉入vscode安装node.js安装vue脚手架components : 组件router:路由创建新组建 :assets: 系统图片存放地址main.js: vue脚手架对象存放地 (新的包要放在里面)属性 computedslot 插槽error St…

Hadoop-2.5.2平台环境搭建遇到的问题

文章目录 一、集群环境二、MySQL2.1 MySQL初始化失败2.2 MySQL启动报错2.3 启动时报不能打开日志错2.4 mysql启动时pid报错 二、Hive2.1 Hive修改core-site.xml文件后刷新权限2.2 Hive启动元数据时报错2.3 Hive初始化MySQL报错2.3.1 报错信息2.3.2 错误原因2.3.3 参考文档 2.4 …

React的类式组件和函数式组件之间有什么区别?

React 中的类组件和函数组件是两种不同的组件编写方式,它们之间有一些区别。 语法和写法:类组件是使用类的语法进行定义的,它继承自 React.Component 类,并且需要实现 render() 方法来返回组件的 JSX。函数组件是使用函数的语法进…

【SCSS篇】Vite+Vue3项目全局引入scss文件

文章目录 前言一、安装与使用1.1 安装1.2 scss 全局文件编写1.2.1 概述 1.3 全局引入和配置1.4 组件内使用 vue2 项目引入 sass附:忽略ts类型检测 前言 Sass 是世界上最成熟、最稳定、最强大的专业级CSS扩展语言!在日常项目开发过程中使用非常广泛&…

数据库:Hive转Presto(五)

此篇将所有代码都补充完了,之前发现有的代码写错了,以这篇为准,以下为完整代码,如果发现我有什么考虑不周的地方,可以评论提建议,感谢。代码是想哪写哪,可能比较繁琐,还需要优化。 …

Maven - 5 分钟快速通关

目录 一、Maven 1.1、 基础语法 1.2、聚合 1.3、继承 1.4、自定义属性 一、Maven 1.1、 基础语法 <?xml version"1.0" encoding"UTF-8"?> <project xmlns"http://maven.apache.org/POM/4.0.0"xmlns:xsi"http://www.w3.org/…

MVVM 与 MVC区别和应用场景?

MVVM 和 MVC 1. MVC2. MVVM 1. MVC MVC 是 Model View Controller 的缩写 Model&#xff1a;模型层&#xff0c;是应用程序中用于处理应用程序数据逻辑的部分。通常模型对象负责在数据库中存取数据。View&#xff1a;视图层&#xff0c;用户界面渲染逻辑&#xff0c;通常视图…