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.rhkb.cn/news/158413.html

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

相关文章

POI、Easy Excel操作Excel

文章目录 1.常用的场景2.基本功能3.Excel在Java中是一个对象4. 简单的写(07版本(.xlsx)Excel)大文件写HSSF大文件写XSSF大文件写SXSSF 5. Excel读5.1 读取遇到类型转化问题该怎么解决5.2 遇到Excel公式怎么办 6. Easy Excel6.1简单…

【软件测试】性能测试工具Loadrunner

文章目录 一. Loadrunner是什么二. LoadRunner的安装三. LoadRunner的使用1. Virtual User Generator(LoadRunner脚本录制)1.1 了解WebTours系统1.2 脚本录制1.3 编译1.4 运行(回放)脚本加强1. 事务插入2. 插入集合点3. 参数化4. 打印日志 2. Controller(设计测试场景)2.1 Cont…

云上攻防-云原生篇Docker安全系统内核版本漏洞CDK自动利用容器逃逸

文章目录 云原生-Docker安全-容器逃逸&内核漏洞云原生-Docker安全-容器逃逸&版本漏洞-CVE-2019-5736 runC容器逃逸-CVE-2020-15257 containerd逃逸 云原生-Docker安全-容器逃逸&CDK自动化 云原生-Docker安全-容器逃逸&内核漏洞 细节部分在权限提升章节会详解&…

DocCMS keyword SQL注入

漏洞描述 DocCMS keyword参数存在 SQL注入漏洞,攻击者通过漏洞可以获取数据库信息 漏洞复现 访问url: 漏洞证明: 文笔生疏,措辞浅薄,望各位大佬不吝赐教,万分感谢。 免责声明:由于传播或利…

【HTML+REACT+ANTD 表格操作】处理(改变)数据,改变DOM

博主&#xff1a;_LJaXi 专栏&#xff1a; React | 前端框架 主要是一些表格DOM操作&#xff0c;数据更换 个人向 HTML <!DOCTYPE html> <html lang"en"> <link> <meta charset"UTF-8" /> <meta name"viewport" con…

flutter入门实践2——将完成的flutter软件打包为apk

将完成的flutter软件打包为apk&#xff1a; 视频版&#xff1a; 【前端教程-Flutter篇-flutter之打包安卓版本的APP】https://www.bilibili.com/video/BV11K4y1S7Sg?vd_sourcec008a8e3bd95154e374408adc754394a 文字版&#xff1a;Flutter 打包APP &#xff08;Android &am…

JUnit5 【最实用最简洁】

JUnit5 文章目录 JUnit5一、JUnit 的相关技术二、参数化三、给测试用例指定顺序四、断言五、测试套件 安装依赖&#xff1a;在Maven库中安装 为什么学了 Selenium 还要学 JUnit&#xff1f; 1、JUnit5 是单元测试框架&#xff0c;拿着一个技术写自动化测试用例&#xff08;Sele…

想要精通算法和SQL的成长之路 - 连续的子数组和

想要精通算法和SQL的成长之路 - 连续的子数组和 前言一. 连续的子数组和1.1 最原始的前缀和1.2 前缀和 哈希表 前言 想要精通算法和SQL的成长之路 - 系列导航 一. 连续的子数组和 原题链接 1.1 最原始的前缀和 如果这道题目&#xff0c;用前缀和来算&#xff0c;我们的思路…

vue 本地上传Excel文件并读取内容

陌路遇见&#xff0c;陌路告别&#xff0c;陌路问好&#xff0c;九月再见&#xff0c;十月重现! 首先我来讲解一下我的思路&#xff1a; 首先&#xff0c;在模板部分&#xff0c;我们有以下元素&#xff1a; <input type“file” change“handleFileUpload” accept“.xlsx…

ODrive移植keil(七)—— 插值算法和偏置校准

目录 一、角度读取1.1、硬件接线1.2、程序演示1.3、代码说明 二、锁相环和插值算法2.1、锁相环2.2、插值2.3、角度补偿 三、偏置校准3.1、硬件接线3.2、官方代码操作3.3、移植后的代码操作3.4、代码说明3.5、SimpleFOC的偏置校准对比 ODrive、VESC和SimpleFOC 教程链接汇总&…

蓝桥杯(等差素数列,C++)

思路&#xff1a; 1、因为找的是长度为10&#xff0c;且公差最小的等差素数列&#xff0c;直接用枚举即可。 2、枚举用三重循环&#xff0c;第一重枚举首项&#xff0c;第二重枚举公差&#xff0c;第三重因为首项算一个&#xff0c;所以枚举九个等差素数。 代码&#xff1a;…

《从菜鸟到大师之路 正则表达式 篇》

《从菜鸟到大师之路 正则表达式 篇》 正则表达式是一个强大的文本匹配工具。但是&#xff0c;对于前端初学者来说&#xff0c;众多的符号和规则可能让人难以理解。其实&#xff0c;你不需要记住所有的正则表达式语法&#xff01;本文将分享一些简单而实用的技巧&#xff0c;帮…

ShopXO download 任意文件读取

漏洞描述 ShopXO存在任意文件读取漏洞&#xff0c;攻击者可利用该漏洞获取敏感信息 漏洞复现 访问url&#xff1a; 构造payload 漏洞证明&#xff1a; 文笔生疏&#xff0c;措辞浅薄&#xff0c;望各位大佬不吝赐教&#xff0c;万分感谢。 免责声明&#xff1a;由于传播或…

动态内存管理(malloc calloc realloc free)--- C语言

文章目录 写在前面1. malloc 和 free函数1.1 malloc函数介绍1.2 free函数介绍 2. calloc函数3. realloc函数4. 常见的动态内存错误4.1 对NULL指针的解引用操作4.2 对动态开辟空间的越界访问4.3 对非动态开辟内存使用free释放4.4 使用free释放一块动态开辟内存的一部分4.5 对同一…

低代码提速应用开发

低代码介绍 低代码平台是指一种能够帮助企业快速交付业务应用的平台。自2000年以来&#xff0c;低代码市场一直充斥着40大大小小的各种玩家&#xff0c;比如国外的Appian、K2、Pega Systems、Salesforce和Ultimus&#xff0c;国内的H3 BPM。 2015年以后&#xff0c;这个市场更是…

linux 安装python django pip 遇到的问题

Python解决SSL不可用问题 解决方案&#xff1a; 首先要明白python版本需要和openssl的版本需要相对匹配的&#xff0c;在Python3.7之后的版本&#xff0c;依赖的openssl&#xff0c;必须要是1.1或者1.0.2之后的版本&#xff0c;或者安装了2.6.4之后的libressl&#xff0c;linux…

centos7下安装elasticsearch7.8.1并配置远程连接

1、下载安装包 sudo wget https://artifacts.elastic.co/downloads/elasticsearch/elasticsearch-7.8.1-linux-x86_64.tar.gz 2、解压 sudo tar -zxvf elasticsearch-7.8.1-linux-x86_64.tar.gz 3、添加用户并设置密码 sudo useradd es sudo passwd es # 设置密码 Lida15…

Pycharm 2023 设置远程调试

pycharm 版本 &#xff1a; 2023.2.1 整体流程参考&#xff1a;https://blog.csdn.net/xuanhaolaile/article/details/128293254 首先确定远程服务器上已经安装好 requirements.txt 中所需的依赖包。 1、SSH Configurations 添加远程服务器 2、Python Interpreter 注意&…

Leetcode算法解析——查找总价格为目标值的两个商品

1. 题目链接&#xff1a;LCR 179. 查找总价格为目标值的两个商品 2. 题目描述&#xff1a; 商品价格按照升序记录于数组 price。请在购物车中找到两个商品的价格总和刚好是 target。若存在多种情况&#xff0c;返回任一结果即可。 示例 1&#xff1a; 输入&#xff1a;price …

Linux信号 signal()编程

在Linux的进程间通信中可以用signal&#xff08;&#xff09;函数进行信号与信息传递。 1.信号 信号的名字和编号&#xff1a; 每个信号都有一个名字和编号&#xff0c;这些名字都以“SIG”开头&#xff0c;例如“SIGIO ”、“SIGCHLD”等等。 信号定义在signal.h头文件中&am…