199、在RabbitMQ管理控制台中管理 Exchange(充当消息交换机的组件) 和 Queue(消息队列),以及对默认Exchange的讲解

本文主要是介绍199、在RabbitMQ管理控制台中管理 Exchange(充当消息交换机的组件) 和 Queue(消息队列),以及对默认Exchange的讲解,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

在这里插入图片描述

使用默认的 Exchange 支持 P2P:
Exchange:把客户端发来的消息路由到消息队列去
每个虚拟机下面都默认有 Exchange ,通过这个默认的exchange就可以很好的支持 P2P 的消息。
在这里插入图片描述
在这里插入图片描述
★ JMS vs AMQP

▲ 高级消息队列协议(Advanced Message Queuing Protocol、简称AMQP)是一种平台无关的、线路级(wire-level)的消息中间件协议。▲ AMQP并不适于JMS范畴,AMQP与JMS的区别与联系:- JMS定义消息中间件的规范,从而实现对消息操作的统一;AMQP则通过制订协议来统一数据交互的格式。- JMS限定了必须使用Java语言;AMQP只制订协议,不规定实现语言和实现方式,因此是跨语言的。- JMS只制订了两种消息模型;而AMQP的消息模型更加灵活。RabbitMQ就是典型的AMQP产品,它是用Erlang语言来开发。从灵活性的角度来看,RabbitMQ比ActiveMQ更优秀;从性能上来看,RabbitMQ更是完胜ActiveMQ,因此目前很多公司都会优先选择RabbitMQ作为消息队列。

★ 自动创建的Exchange

RabbitMQ自动为每个虚拟主机自动创建7个Exchange

direct 类型的Exchange两个
fanout 类型的Exchange一个、这种类型的Exchange用于模拟JMS的Pub-Sub消息模型。
headers 类型的Exchange两个
topic 类型的Exchange两个。

在这里插入图片描述

★ 创建Exchange所支持的属性

Virtual Host: 选择在哪个虚拟主机(相当于命名空间)下创建Exchange。

Name: 指定Exchange的名称。

Type: 指定Exchange的类型,支持fanout、direct、headers、topic这些类型。

Durability: 指定该Exchange是否需要持久化保存 。

Auto delete: 指定该Exchange是否会自动删除;如果启用“自动删除”,那意味着只要该Exchange不再使用(没有消费者向它发送消息、没有Queue与它绑定),它就会自动删除。

Internal: 指定是否创建内部Exchange。如果指定为true,则客户端将不能直接向该Exchange发布消息,它只能用于与其他Exchange绑定、接受其他Exchange分发过来的消息。(Exchange可以将消息再次分发给Exchange)。

Arguments: 指定额外的创建参数。

Exchange 不仅可以把消息分发给 Queue 消息队列,
Exchange还可以将消息再次分发给Exchange,只不过ExchangeA分发给ExchangeB后,最后ExchangeB还是得把消息分发给 queue 消息队列。

控制台创建 Exchange
在这里插入图片描述
在这里插入图片描述

演示:

创建消息队列

创建4个消息队列
在这里插入图片描述

在这里插入图片描述

然后给test.direct 这个 Exchange 绑定 3个消息队列
在这里插入图片描述

在这里插入图片描述

然后给这个 exchange发送消息。
这里,还不清楚这里的消息是发送给exchange,还是exchange把消息路由发送给queue。
偏向后者。

没错,后面研究,发现虽然是在控制台的 Exchange 界面发送消息,但其实这个 Publish Message 发送消息的功能,就是把消息发送给 test.direct 这个Exchange。
在这里插入图片描述
注意:
我在纠结 Exchange 的 Publish message 发送消息这里,是把消息发在 exchange,还是 exchange把消息发送到queue。
后面研究:这里的控制台的Publish message 是把消息发送给 exchange

如图:成功发送消息路由key 是 testE-key-q1 。
提示消息已经发布成功了
在这里插入图片描述

然后这时候来看看消息队列是否有该消息。
因为如果路由key,对得上,那么这个 Q1 应该就得有消息。
在这里插入图片描述
点进Q1查看:

在这里插入图片描述

再创建一个Exchange,类型是 fanout,fanout:扇形,就是广播类型

在这里插入图片描述

给这个 exchange 绑定 Q1 和 Q4 这两个消息队列 queue
在这里插入图片描述
然后发送消息到 test.fanout 这个 exchange 进行测试:

在这里插入图片描述

查看消息队列queue
可以看出发送广播消息成功。
在这里插入图片描述

Exchange的绑定 和 Queue 的绑定
在这里插入图片描述

★ 持久化消息

▲ 持久化的Exchange能与持久化的队列结合使用,用于确保消息的持久化。
如果不使用持久化的消息,当RabbitMQ遇到服务器宕机等故障时,那些未处理的消息有可能会丢失;
使用持久化的消息则可确保消息不会丢失(无论遇到什么情况)。▲ 使用持久化消息需要3个条件:- 使用持久化的Exchange
- 使用持久化的队列
- 发送消息时设置使用持久化分发模式(将delivery Mode设为2), 

Queues 的 Get Message 讲解:
如图:这个 properties 的 delivery_model: 2 就表示这个消息是持久化消息。
在这里插入图片描述

在这里插入图片描述

★ 默认Exchange讲解

只要创建虚拟机,那么控制台就会为我们自动创建7个 Exchange,但是自动创建的 Exchange,并不代表就是默认的 Exchange。默认的Exchange只有一个。如图:
默认的Exchange是没有名字的,只是用括号表明这是个默认的Exchange。
在这里插入图片描述
点进去看有 D 和 I 的 Exchange
在这里插入图片描述

▲ 默认Exchange没有名字、类型是direct(type为direct),并且是持久化保存的Exchange(durable为true)。

▲ 默认Exchange会隐式(自动)绑定到每个Queue消息队列(以消息队列名作为绑定的路由key),而且不能执行显式绑定或解绑。
就是我们添加多少个消息队列,这个默认的 Exchange都是对这些消息队列进行绑定。
比如这里我们添加了Q1、Q2、Q3、Q4 这四个消息队列,那么这个默认的Exchange就会隐式的绑定这四个消息队列,绑定的各个路由key就是各消息队列的名字。

                   →(路由key为Q1)       Q1队列→(路由key为Q2)       Q2队列默认Exchange →(路由key为Q3)       Q3队列→(路由key为Q4)       Q4队列

由此可见:当你向默认Exchange发送任何消息时,该消息始终会被路由到与该消息的路由key同名的队列。

这意味着:
如果程序向默认Exchange发送路由key为abc的消息,该消息将被分发到名为abc的队列……
如果程序向默认Exchange发送路由key为xyz的消息,该消息将被分发到名为xyz的队列……

▲ 默认Exchange也不能被删除。

▲ RabbitMQ只要一个内置的默认Exchange即可支持JMS的P2P消息模型。
——因为程序要将消息发送到哪个队列,只要向默认的Exchange发送消息,且使用该队列的名称作为路由Key即可。

演示这句:RabbitMQ只要一个内置的默认Exchange即可支持JMS的P2P消息模型
这个控制台的exchange的 publish message,这里是将消息发送到默认的Exchange。
路由key 是 Q1。提示消息发送成功
在这里插入图片描述

查看消息队列:
Q1原本只有之前测试的一条消息,现在变成2条,说明默认的Exchange能成功的分发消息。
在这里插入图片描述

如图:
test.direct 这个 exchange 通过 路由key (testE-key-q1) 发送了一条消息给 Q1 这个消息队列。
默认的Exchange发送消息给 Q1 队列,路由 key 就是 Q1 消息队列的名字。
这里的发送消息,是先发送给这个默认的Exchange的,然后再由这个默认的Exchange自己根据路由去分发消息
在这里插入图片描述

点进这个默认的Exchange 看,发现这个默认的Exchange并没有显示的绑定任何消息队列。
那为什么可以发送消息给Q1消息队列呢?
因为这个默认的Exchange 已经自动隐式的绑定了所有消息队列,路由key 就是消息队列的名字。
在这里插入图片描述

再发送一条消息到默认的Exchange,路由key是Q3.

在这里插入图片描述

成功发送消息到默认的Exchange。

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

这篇关于199、在RabbitMQ管理控制台中管理 Exchange(充当消息交换机的组件) 和 Queue(消息队列),以及对默认Exchange的讲解的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/193575

相关文章

JS常用组件收集

收集了一些平时遇到的前端比较优秀的组件,方便以后开发的时候查找!!! 函数工具: Lodash 页面固定: stickUp、jQuery.Pin 轮播: unslider、swiper 开关: switch 复选框: icheck 气泡: grumble 隐藏元素: Headroom

hdu1180(广搜+优先队列)

此题要求最少到达目标点T的最短时间,所以我选择了广度优先搜索,并且要用到优先队列。 另外此题注意点较多,比如说可以在某个点停留,我wa了好多两次,就是因为忽略了这一点,然后参考了大神的思想,然后经过反复修改才AC的 这是我的代码 #include<iostream>#include<algorithm>#include<string>#include<stack>#include<

禁止平板,iPad长按弹出默认菜单事件

通过监控按下抬起时间差来禁止弹出事件,把以下代码写在要禁止的页面的页面加载事件里面即可     var date;document.addEventListener('touchstart', event => {date = new Date().getTime();});document.addEventListener('touchend', event => {if (new

综合安防管理平台LntonAIServer视频监控汇聚抖动检测算法优势

LntonAIServer视频质量诊断功能中的抖动检测是一个专门针对视频稳定性进行分析的功能。抖动通常是指视频帧之间的不必要运动,这种运动可能是由于摄像机的移动、传输中的错误或编解码问题导致的。抖动检测对于确保视频内容的平滑性和观看体验至关重要。 优势 1. 提高图像质量 - 清晰度提升:减少抖动,提高图像的清晰度和细节表现力,使得监控画面更加真实可信。 - 细节增强:在低光条件下,抖

如何在页面调用utility bar并传递参数至lwc组件

1.在app的utility item中添加lwc组件: 2.调用utility bar api的方式有两种: 方法一,通过lwc调用: import {LightningElement,api ,wire } from 'lwc';import { publish, MessageContext } from 'lightning/messageService';import Ca

Android实现任意版本设置默认的锁屏壁纸和桌面壁纸(两张壁纸可不一致)

客户有些需求需要设置默认壁纸和锁屏壁纸  在默认情况下 这两个壁纸是相同的  如果需要默认的锁屏壁纸和桌面壁纸不一样 需要额外修改 Android13实现 替换默认桌面壁纸: 将图片文件替换frameworks/base/core/res/res/drawable-nodpi/default_wallpaper.*  (注意不能是bmp格式) 替换默认锁屏壁纸: 将图片资源放入vendo

软考系统规划与管理师考试证书含金量高吗?

2024年软考系统规划与管理师考试报名时间节点: 报名时间:2024年上半年软考将于3月中旬陆续开始报名 考试时间:上半年5月25日到28日,下半年11月9日到12日 分数线:所有科目成绩均须达到45分以上(包括45分)方可通过考试 成绩查询:可在“中国计算机技术职业资格网”上查询软考成绩 出成绩时间:预计在11月左右 证书领取时间:一般在考试成绩公布后3~4个月,各地领取时间有所不同

安全管理体系化的智慧油站开源了。

AI视频监控平台简介 AI视频监控平台是一款功能强大且简单易用的实时算法视频监控系统。它的愿景是最底层打通各大芯片厂商相互间的壁垒,省去繁琐重复的适配流程,实现芯片、算法、应用的全流程组合,从而大大减少企业级应用约95%的开发成本。用户只需在界面上进行简单的操作,就可以实现全视频的接入及布控。摄像头管理模块用于多种终端设备、智能设备的接入及管理。平台支持包括摄像头等终端感知设备接入,为整个平台提

poj 3190 优先队列+贪心

题意: 有n头牛,分别给他们挤奶的时间。 然后每头牛挤奶的时候都要在一个stall里面,并且每个stall每次只能占用一头牛。 问最少需要多少个stall,并输出每头牛所在的stall。 e.g 样例: INPUT: 51 102 43 65 84 7 OUTPUT: 412324 HINT: Explanation of the s

poj 2431 poj 3253 优先队列的运用

poj 2431: 题意: 一条路起点为0, 终点为l。 卡车初始时在0点,并且有p升油,假设油箱无限大。 给n个加油站,每个加油站距离终点 l 距离为 x[i],可以加的油量为fuel[i]。 问最少加几次油可以到达终点,若不能到达,输出-1。 解析: 《挑战程序设计竞赛》: “在卡车开往终点的途中,只有在加油站才可以加油。但是,如果认为“在到达加油站i时,就获得了一