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 , 那么就可以匹配上。

相关文章:
 
198、RabbitMQ 的核心概念 及 工作机制概述; Exchange 类型 及 该类型对应的路由规则;了解什么是JMS。
目录 JMS 讲解★ RabbitMQ的核心概念★ RabbitMQ工作机制★ Connection(连接) 与 Channel(通信信道)★ Exchange★ Exchange与Queue★ Exchange的类型(4种)及 该类型对应的路由规则 看RabbitMQ 之前&#x…...
 
怎样理解伦敦金交易的点差
不管大家做的是什么投资品种,只要过程中有中间商提供了一定的服务,那么就需要支付一定的费用,这也是十分合理的事情。在伦敦金的市场上,交易平台主要通过点差的形式,向客户征收一定的投资服务费用。 伦敦金买卖过程中的…...
 
mysql主从工作原理、搭建
目录 一、mysql为什么要用主从架构? 二、mysql数据库主从复制原理是什么? 详细的主从复制过程如下图: 主从复制过程概述: 三、mysql主从如何搭建? 本次安装的数据库版本为mysql5.7 1、准备两台服务器(…...
PHP实现赛邮【SUBMAIL】短信通知
接口文档地址:https://www.mysubmail.com/documents 实现短信通知实例: $url https://api-v4.mysubmail.com/sms/xsend;//接口地址 $appId XXX;//APPID $appkey XXX;//APPKEY $phone XXX;//发送手机号 $project XXX;//模板ID $data …...
 
完整的电商平台后端API开发总结
对于开发一个Web项目来说,无论是电商还是其他品类的项目,注册与登录模块都是必不可少的;注册登录功能也是我们在日常生活中最长接触的,对于这个业务场景的需求与逻辑大概是没有什么需要详细介绍的,市面上常见的邮箱注册…...
 
游戏中的随机——“动态平衡概率”算法
前言 众所周知计算机模拟的随机是伪随机,但在结果看来依然和现实中的随机差别不大。 例如掷硬币,连续掷很多很多次之后,总有连续七八十来次同一个面朝上的情况出现,计算机中一般的随机函数也能很好模拟这一点。 但在游戏中&…...
AUTOSAR汽车电子嵌入式编程精讲300篇-基于 FIFO 和优先级序列 CAN 总线系统(续)
目录 4.1.2 理想模型的 FIFO 序列分析 4.2 仅有一个缓冲区的模型的可调度性分析...
 
C# InformativeDrawings 生成素描画
效果 项目 下载 可执行程序exe下载 源码下载...
关于网络协议的若干问题(一)
1、当网络包到达一个网关的时候,可以通过路由表得到下一个网关的 IP 地址,直接通过 IP 地址找就可以了,为什么还要通过本地的 MAC 地址呢? 答:IP报文端到端的传输过程中,在没有NAT情况下,目的地…...
 
电脑重做系统---win10
电脑重做系统---win10 前言制作启动U盘材料方法打开网址下载启动盘制作工具参照官方说明进行制作使用U盘重做系统 常用软件官网地址 前言 记得最早学习装电脑还是04年左右,最为一个啥也不知道的大一傻白胖,花了几百大洋在电脑版把了个“电脑组装与维修”…...
 
HTML基础入门02
目录 1.格式化标签 2.图片标签: img 3.超链接标签: a 4.综合案例: 展示博客2 5.表格标签 5.1基本使用 5.2合并单元格 6.列表标签 1.格式化标签 加粗:strong标签和b标签 倾斜:em标签和i标签 删除线:del标签和s标签 下划线:i…...
 
【C++】如何使用RapidXML读取和创建XML文件
2023年10月11日,周三下午 目录 RapidXML的官网使用rapidXML读取XML文件中的元素的属性和值此次要读取的XML文件:ReadExample.xml用于读取此XML文件的C代码运行结果使用rapidXML创建XML文件用于创建XML文件的C代码 如果上面的代码无法运行运行结果编辑…...
 
《UnityShader入门精要》学习3
笛卡尔坐标系(Cartesian Coordinate System) 二维笛卡儿坐标系 一个二维的笛卡儿坐标系包含了两个部分的信息: 一个特殊的位置,即原点,它是整个坐标系的中心。两条过原点的互相垂直的矢量,即x轴和y轴。这…...
使用Python将MP4视频转换为图像
介绍: 在计算机视觉和机器学习领域,我们经常需要处理视频数据。有时候,我们可能需要将视频转换为图像序列,以便进行后续的分析和处理。本文将介绍如何使用Python和OpenCV库将MP4视频文件转换为图像序列。 步骤: 导入…...
【Vue Router 3】入门
简介 Vue Router让SPA(Single-page Application)的构建更加容易。 Vue Router的功能: 嵌套的路由/视图映射模块化的、基于组件的router配置route params, query, wildcards由Vue过渡系统支持的视图过渡效果细粒度(fine-grained…...
SpringMVC中@RequestMapping注解的详细说明
RequestMapping 是Spring MVC中一个用于映射HTTP请求和控制器方法之间关系的注解。它用于定义控制器方法如何响应特定的HTTP请求,包括GET、POST、PUT、DELETE等。以下是RequestMapping注解的详细说明: 基本用法: RequestMapping("/examp…...
Java - 发送 HTTP 请求的及其简单的方法模块 - hutool
目录 一、POST 传递简单的字符串内容 .body(params)二、POST 传递 Json 数据,以表单类型传递 .form(params)二、POST 传递 Json 数据,以表单类型传递 .form(params) 和 .body(params) 方法效果等效的思路四、传统接口带 token 验证的代码模板参考链接 一…...
Nie et al. 2010 提出的不等式定理
这里写自定义目录标题 定理 定理 For any vector a a a and b b b, we have ∥ a ∥ 2 − ∥ a ∥ 2 2 2 ∥ b ∥ 2 ≤ ∥ b ∥ 2 − ∥ b ∥ 2 2 2 ∥ b ∥ 2 \|a\|_{2} - \frac{\|a\|_{2}^{2}}{2\|b\|_{2}} \leq \|b\|_{2} - \frac{\|b\|_{2}^{2}}{2\|b\|_{2}} ∥a∥2−…...
chatGLM2-6B模型LoRA微调数据集实现大模型的分类任务
【TOC】 1.chatglm介绍 ChatGLM 模型是由清华大学开源的、支持中英双语问答的对话语言模型,并针对中文进行了优化。该模型基于 General Language Model(GLM)架构,具有 62 亿参数。结合模型量化技术,用户可以在消费级的显卡上进行本地部署。 ChatGLM 具备以下特点: 充…...
Elasticsearch6实践
目录 目录 一、需求 二、ES索引设计 三、页面搜索条件 四、ES的分页搜索DSL语句 五、其他 一、需求 公告列表,需要支持以下搜索 1、根据文本输入,模糊搜索公告标题和公告正文。 2、支持公告类型搜索,单选 3、支持根据公告所在省市区搜…...
 
JavaScript 中的 ES|QL:利用 Apache Arrow 工具
作者:来自 Elastic Jeffrey Rengifo 学习如何将 ES|QL 与 JavaScript 的 Apache Arrow 客户端工具一起使用。 想获得 Elastic 认证吗?了解下一期 Elasticsearch Engineer 培训的时间吧! Elasticsearch 拥有众多新功能,助你为自己…...
c++ 面试题(1)-----深度优先搜索(DFS)实现
操作系统:ubuntu22.04 IDE:Visual Studio Code 编程语言:C11 题目描述 地上有一个 m 行 n 列的方格,从坐标 [0,0] 起始。一个机器人可以从某一格移动到上下左右四个格子,但不能进入行坐标和列坐标的数位之和大于 k 的格子。 例…...
 
【CSS position 属性】static、relative、fixed、absolute 、sticky详细介绍,多层嵌套定位示例
文章目录 ★ position 的五种类型及基本用法 ★ 一、position 属性概述 二、position 的五种类型详解(初学者版) 1. static(默认值) 2. relative(相对定位) 3. absolute(绝对定位) 4. fixed(固定定位) 5. sticky(粘性定位) 三、定位元素的层级关系(z-i…...
什么是EULA和DPA
文章目录 EULA(End User License Agreement)DPA(Data Protection Agreement)一、定义与背景二、核心内容三、法律效力与责任四、实际应用与意义 EULA(End User License Agreement) 定义: EULA即…...
Java多线程实现之Thread类深度解析
Java多线程实现之Thread类深度解析 一、多线程基础概念1.1 什么是线程1.2 多线程的优势1.3 Java多线程模型 二、Thread类的基本结构与构造函数2.1 Thread类的继承关系2.2 构造函数 三、创建和启动线程3.1 继承Thread类创建线程3.2 实现Runnable接口创建线程 四、Thread类的核心…...
 
Linux 中如何提取压缩文件 ?
Linux 是一种流行的开源操作系统,它提供了许多工具来管理、压缩和解压缩文件。压缩文件有助于节省存储空间,使数据传输更快。本指南将向您展示如何在 Linux 中提取不同类型的压缩文件。 1. Unpacking ZIP Files ZIP 文件是非常常见的,要在 …...
 
C++_哈希表
本篇文章是对C学习的哈希表部分的学习分享 相信一定会对你有所帮助~ 那咱们废话不多说,直接开始吧! 一、基础概念 1. 哈希核心思想: 哈希函数的作用:通过此函数建立一个Key与存储位置之间的映射关系。理想目标:实现…...
 
【免费数据】2005-2019年我国272个地级市的旅游竞争力多指标数据(33个指标)
旅游业是一个城市的重要产业构成。旅游竞争力是一个城市竞争力的重要构成部分。一个城市的旅游竞争力反映了其在旅游市场竞争中的比较优势。 今日我们分享的是2005-2019年我国272个地级市的旅游竞争力多指标数据!该数据集源自2025年4月发表于《地理学报》的论文成果…...
深入解析 ReentrantLock:原理、公平锁与非公平锁的较量
ReentrantLock 是 Java 中 java.util.concurrent.locks 包下的一个重要类,用于实现线程同步,支持可重入性,并且可以选择公平锁或非公平锁的实现方式。下面将详细介绍 ReentrantLock 的实现原理以及公平锁和非公平锁的区别。 ReentrantLock 实现原理 基本架构 ReentrantLo…...
 
基于Python的气象数据分析及可视化研究
目录 一.🦁前言二.🦁开源代码与组件使用情况说明三.🦁核心功能1. ✅算法设计2. ✅PyEcharts库3. ✅Flask框架4. ✅爬虫5. ✅部署项目 四.🦁演示效果1. 管理员模块1.1 用户管理 2. 用户模块2.1 登录系统2.2 查看实时数据2.3 查看天…...
