RabbitMQ-学习笔记(初识 RabbitMQ)

news2025/1/20 10:57:18

本篇文章学习于 bilibili黑马 的视频 (狗头保命)

同步通讯 & 异步通讯 (RabbitMQ 的前置知识)

  • 同步通讯：类似打电话，只有对方接受了你发起的请求,双方才能进行通讯, 同一时刻你只能跟一个人打视频电话。
  • 异步通讯：类似发信息，不用对方接受,你就可以直接发信息，而且可以多线操作，同时跟多人发信息。

同步调用
在这里插入图片描述

发送方直接把消息传递给接收者, 如果中间有很多环节, 有一步出错, 那么所有操作都要回滚

同步调用的缺点:

  1. 拓展性差
  2. 性能下降
  3. 级联失败

异步调用方式其实就是基于消息通知的方式，一般包含三个角色：
消息发送者：投递消息的人，就是原来的调用方
消息Broker：管理、暂存、转发消息，你可以把它理解成微信服务器
消息接收者：接收和处理消息的人，就是原来的服务提供方
黑马的图

异步调用中, 发送方把消息发送给消息broker, 就算完成发送任务.
接收者从消息 breker 那里订阅消息
这样，发送消息的人和接收消息的人就完全解耦了。

此时, 如果发送方发送消息出错, 不需要全部回滚, 只需要将错误信息重新发布给消息代理
如果接受方接受消息过程出现错误, 那么消息代理重传就好, 发送方还是可以正常进行其他操作

异步调用的优势：

  1. 耦合度更低
  2. 性能更好
  3. 业务拓展性强
  4. 故障隔离，避免级联失败

异步通信的缺点：

  1. 完全依赖于Broker的可靠性、安全性和性能
  2. 架构复杂，后期维护和调试麻烦

消息Broker，目前常见的实现方案就是消息队列（MessageQueue），简称为MQ.
RabbitMQ是基于Erlang语言开发的开源消息通信中间件.

开启 RabbitMQ

打开这个目录(我的电脑是)
C:\Program Files (x86)\RabbitMQ Server\rabbitmq_server-3.7.4\sbin
在这里插入图片描述
双击这个文件

在这里插入图片描述

等待命令框为这个状态

在这里插入图片描述

点击跳转官网地址

RabbitMQ

RabbitMQ对应的架构

黑马的图

  • publisher：生产者，也就是发送消息的一方
  • consumer：消费者，也就是消费消息的一方
  • queue：队列，存储消息。生产者投递的消息会暂存在消息队列中，等待消费者处理
  • exchange：交换机，负责消息路由。生产者发送的消息由交换机决定投递到哪个队列。
  • virtual host：虚拟主机，起到数据隔离的作用。每个虚拟主机相互独立，有各自的exchange、queue

简单的收发消息 (exchange & queue)

1. 添加 exchange

在这里插入图片描述

2. 添加 queue

在这里插入图片描述

3. 绑定 exchange 和 queue

点击之前创建的 exchange
在这里插入图片描述

添加绑定信息
在这里插入图片描述

4. 发送消息

输入信息, 点击发送
在这里插入图片描述

5. 查看接受的消息

点击被绑定的队列
在这里插入图片描述

获取消息
在这里插入图片描述

数据隔离

基于不同用户，将管理权限分离。
基于不同的 virtual host ，将每个项目的数据隔离。

创建用户
在这里插入图片描述

此时用户没有 virtral hosts
在这里插入图片描述

退出, 重新登录
在这里插入图片描述

创建 virtual hosts
在这里插入图片描述

此时用户 zrj 已经拥有 virtual hosts 了
在这里插入图片描述

将 virtual hosts 切换到 /zrj 之后, 查看 queue, 会发现之前创建的 test.queue 已经看不见了, 这就是基于 用户和 virtual hosts 的数据隔离效果
在这里插入图片描述

Spring AMQP

RabbitMQ 基于 AMQP 协议, 因此具有跨语言的特性.
Spring 官方基于 RabbitMQ 提供了一套消息收发管理工具 ---- Spring AMQP

Spring AMQP 提供的功能

  • 自动声明队列、交换机及其绑定关系
  • 基于注解的监听器模式，异步接收消息
  • 封装了RabbitTemplate工具，用于发送消息

项目中使用 RabbitMQ

如果你很懒, 不想自己创建, 就去bilibili黑马的课程里, 找资源吧 (毕竟我也是在那里学的)

发送消息

创建项目, 导入依赖

项目目录结构
在这里插入图片描述

<dependencies>
    <dependency>
        <groupId>org.projectlombok</groupId>
        <artifactId>lombok</artifactId>
    </dependency>
    <!--AMQP依赖，包含RabbitMQ-->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-amqp</artifactId>
    </dependency>
    <!--单元测试-->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-test</artifactId>
    </dependency>
</dependencies>

添加一下配置
在这里插入图片描述

Spring 中发送消息在这里插入图片描述

RabbitMQ 接收到消息
在这里插入图片描述

上面是使用管道简单的发送消息, 结构大概是这样
在这里插入图片描述

我们查看 的 convertAndSend 方法可以看到, 由于多态, 参数的选择有很多方案, 上面使用的是
convertAndSend(String routingKey, Object object)
因为所有的数据发送都是 Object , 因此我们接收方那里收到的, 也是 Object 类型, 如果想取出使用, 记得转换类型
在这里插入图片描述

接收消息

增加配置
在这里插入图片描述

编写监听代码
在这里插入图片描述

启动 consumer 类
在这里插入图片描述

publisher 中进行消息发送, 此时 consumer 中可以接收到消息
在这里插入图片描述

WorkQueues模型

简单的说就是多个消费者消费同一个队列中的消息

在这里插入图片描述

通常情况下, 队列会采用轮询的方式, 每个消费者均分 队列中的消息

两个消费者共同消费同一个队列
在这里插入图片描述

连续发送 50 条消息
在这里插入图片描述

查看结果会发现, 两个消费者虽然消费速率不同, 但是最终都消费了同样数量 (25条) 的消息
在这里插入图片描述

如何才能使得能者多劳, 不会浪费效率呐?

修改配置信息, 设定么个消费者每次获取消息的最大数量 (原先是 几个消费者 平均分掉 所有消息), 消费完成获取的消息之后才能获取下一条消息
在这里插入图片描述

引入交换机之后的 生产者消费者模型

在这里插入图片描述

注意: Exchange（交换机）只负责转发消息，不具备存储消息的能力，因此如果没有任何队列与Exchange绑定，或者没有符合路由规则的队列，那么消息会丢失！

交换机的类型：
Fanout：广播，将消息交给所有绑定到交换机的队列。我们最早在控制台使用的正是Fanout交换机
Direct：订阅，基于RoutingKey（路由key）发送给订阅了消息的队列
Topic：通配符订阅，与Direct类似，只不过RoutingKey可以使用通配符
Headers：头匹配，基于MQ的消息头匹配，用的较少。

Fanout 交换机

交换机把消息发送给 所有 绑定该交换机的队列
在这里插入图片描述

创建交换机
在这里插入图片描述

创建两个队列并绑定
在这里插入图片描述
在这里插入图片描述

发送消息, 并接收处理

消息发送方
在这里插入图片描述

消息接收方
在这里插入图片描述

消息处理
在这里插入图片描述

可以看到, Fanout 交换机把消息 广播 给了绑定它的所有队列

Direct 交换机

Direct 模型下, 队列与交换机的绑定会指定一个 RoutingKey（路由key）
消息的发送方在向 Exchange 发送消息时吗也必须指定消息的 RoutingKey
Exchange 会将消息交给具有相同 RoutingKey 的队列

在这里插入图片描述

创建交换机
在这里插入图片描述

创建队列
在这里插入图片描述

将交换机和队列进行绑定 (填写 RoutingKey)
在这里插入图片描述

消息接收
在这里插入图片描述

此时会发现, 对于不同的消息发送, 会有不同的处理

当 RoutingKey 为 red 时, 两个消费者都会进行消息处理
在这里插入图片描述
在这里插入图片描述

当 RoutingKey 为 green / blue 时, 只有绑定对应的 RoutingKey 的消费者都会进行消息处理
在这里插入图片描述
在这里插入图片描述

Tocpic 交换机

和 Direct 交换机基本类似, 但是绑定的 RoutingKey 可以使用通配符

通配符规则：

  • #：匹配一个或多个词
  • *：匹配不多不少恰好1个词

在这里插入图片描述

创建 tocpic 交换机
在这里插入图片描述

创建队列
在这里插入图片描述

将 topic 交换机与 队列 进行路由绑定
在这里插入图片描述

消息发送
在这里插入图片描述

消息接收
在这里插入图片描述

消息处理
在这里插入图片描述

声明队列和交换机

使用 Spring AMQP 提供的 API 来声明队列和交换机, 而不是使用 RabbitMQ 控制台来操作

使用 ExchangeBuilder 来创建队列和交换机
在这里插入图片描述

绑定队列和交换机
在这里插入图片描述

Fanout 实例

写一个类声明交换机和队列
在这里插入图片描述

运行 publisher 后, 可以在控制台看到 队列, 交换机, 绑定 都已完成
在这里插入图片描述
在这里插入图片描述

Direct示例 (Topic 与其几乎完全相同)

写一个类声明交换机和队列
在这里插入图片描述

运行 publisher 后, 可以在控制台看到 队列, 交换机, 绑定 都已完成
在这里插入图片描述

基于注解声明

由于要绑定多个 key 的情况, 基于 @Bean 的方式声明队列和交换机会很麻烦, 因此 Spring AMQP 提供了注解的方式来声明 交换机和队列

Fanout 示例

在消费的同时声明 Fanout 交换机和队列
在这里插入图片描述

运行 publisher 后查看 RabbitMQ 控制台
在这里插入图片描述

Direct示例 (Topic 与其几乎完全相同)

在消费的同时声明 Fanout 交换机和队列
在这里插入图片描述

运行 publisher 后查看 RabbitMQ 控制台
在这里插入图片描述

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

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

Hadoop3.x完全分布式环境搭建Zookeeper和Hbase

Hadoop3.x完全分布式环境搭建Zookeeper和Hbase

先在主节点上进行安装和配置&#xff0c;随后分发到各个从节点上。 1. 安装zookeeper 1.1 解压zookeeper并添加环境变量 1&#xff09;解压zookeeper到/usr/local文件夹下 tar -zxvf /usr/local2&#xff09;进入/usr/local文件夹将apache-zookeeper-3.8.0-bin改名为zookeep…
阅读更多...
玩转Sass：掌握数据类型！

玩转Sass：掌握数据类型！

当我们在进行前端开发的时候&#xff0c;有时候需要使用一些不同的数据类型来处理样式&#xff0c;Sass 提供的这些数据类型可以帮助我们更高效地进行样式开发&#xff0c;本篇文章将为您详细介绍 Sass 中的数据类型。 布尔类型 在 Sass 中&#xff0c;布尔数据类型可以表示逻…
阅读更多...
如何将微服务注册到nacos服务上

如何将微服务注册到nacos服务上

首先可在maven的父工程的pom文件中添加maven的dependencyManagement标签&#xff0c;引入spring-cloud-alibaba-dependencies坐标 <properties><spring.cloud.alibaba.version>2.2.9.RELEASE</spring.cloud.alibaba.version></properties><!-- 管理…
阅读更多...
IntelliJ IDEA 2023.3 最新变化

IntelliJ IDEA 2023.3 最新变化

关键亮点 AI Assistant 预览阶段结束 全面推出 Ultimate JetBrains AI Assistant 现已全面推出&#xff0c;搭载大量新功能和改进&#xff0c;助力提高您在 JetBrains IDE 中的工作效率。 最新更新包括编辑器中增强的直接代码生成、无需复制代码即可回答项目相关查询的上下文…
阅读更多...
Spring Boot的日志

Spring Boot的日志

打印日志 打印日志的步骤: • 在程序中得到日志对象. • 使用日志对象输出要打印的内容 在程序中得到日志对象 在程序中获取日志对象需要使用日志工厂LoggerFactory,代码如下: package com.example.demo;import org.slf4j.Logger; import org.slf4j.LoggerFactory;public c…
阅读更多...
[VSCode] Java开发环境配置

[VSCode] Java开发环境配置

文章目录 1 VSCode & Java 安装1.1 安装 VSCode1.2 安装 JDK 2 环境变量配置3 在 VSCode 中安装 Java 扩展4 运行测试 1 VSCode & Java 安装 1.1 安装 VSCode Visual Studio Code 官方下载 地址&#xff1a; https://code.visualstudio.com/详细安装步骤这里不做赘…
阅读更多...
408——知识点大杂烩

408——知识点大杂烩

在完成专业课的一轮复习以及历年真题的学习后&#xff0c;发现选择题甚至个别大题的考点就单纯考对概念的理解&#xff0c;会就是会&#xff0c;不会想到脑壳疼都做不出来&#xff0c;而408的知识点主打一个多杂&#xff0c;所以过来整理一下笔记。本文的知识点主要是在我做题过…
阅读更多...
【扩散模型】ControlNet从原理到实战

【扩散模型】ControlNet从原理到实战

ControlNet从原理到实战 ControlNet原理ControlNet应用于大型预训练扩散模型ControlNet训练过程ControlNet示例1 ControlNet与Canny Edge2. ControlNet与Depth3. ControlNet与M-LSD Lines4. ControlNet与HED Boundary ControlNet实战Canny Edge实战Open Pose 小结参考资料 Cont…
阅读更多...
baen spring_boot maven

baen spring_boot maven

maven高级
阅读更多...
office办公技能|ppt插件使用

office办公技能|ppt插件使用

PPT插件获取&#xff1a;链接&#xff1a;https://pan.baidu.com/s/1BOmPioUKeY2TdC-1V-o3Vw 提取码&#xff1a;tdji 一、ppt插件介绍 PPT插件是一种可以帮助用户在Microsoft PowerPoint软件中添加各种额外功能和效果的应用程序。使用PPT插件可以让用户更加轻松地制作出专业、…
阅读更多...
【Flink】Flink核心概念简述

【Flink】Flink核心概念简述

目录 一、Flink 简介二、Flink 组件栈1. API & Libraries 层2. runtime层3. 物理部署层 三、Flink 集群架构四、Flink基本编程模型五、Flink 的部署模式六、Flink 任务的执行模式五、Flink 的优点 一、Flink 简介 Apache Flink 的前身是柏林理工大学一个研究性项目&#x…
阅读更多...
原生微信小程序将字符串生成二维码图片

原生微信小程序将字符串生成二维码图片

weapp-qrcode.js再最后 inde.ts中的内容 // pages/qrCode/index.ts // 引入weapp-qrcode.js文件 var QRCode require(../../utils/weapp-qrcode) Page({/*** 页面的初始数据*/data: {orderNo:"",imagePath:},/*** 生命周期函数--监听页面加载*/onLoad(options:any)…
阅读更多...
STM32CubeIDE(CUBE-MX hal库)----RTC时钟，时钟实时显示

STM32CubeIDE(CUBE-MX hal库)----RTC时钟，时钟实时显示

系列文章目录 STM32CubeIDE(CUBE-MX hal库)----初尝点亮小灯 STM32CubeIDE(CUBE-MX hal库)----按键控制 STM32CubeIDE(CUBE-MX hal库)----串口通信 STM32CubeIDE(CUBE-MX hal库)----定时器 STM32CubeIDE(CUBE-MX hal库)----蓝牙模块HC-05&#xff08;详细配置&#xff09; 前言…
阅读更多...
⭐Unity 搭建UDP服务端（02）接收客户端消息

⭐Unity 搭建UDP服务端（02）接收客户端消息

客户端在上一篇 由于服务器逻辑写的较为简单 所以直接上代码了~ using System; using System.Net; using System.Net.Sockets; using System.Text; using UnityEngine;public class UdpServer : MonoBehaviour {public static UdpServer instance;private void Awake(){if (…
阅读更多...
SQL Server权限管理与数据恢复

SQL Server权限管理与数据恢复

SQL Server的安全机制 SOL Server 的安全性是建立在认证和访问许可两种安全机制之上的&#xff0c;其中&#xff0c;认证用来确定登录 SQlL Server 的用户的登录账户和密码是否正确&#xff0c;以此来验证其是否具有连接 SQL. Server的权限&#xff1a;访 问许可用来授予用户或…
阅读更多...
Linux本地部署1Panel服务器运维管理面板并实现公网访问

Linux本地部署1Panel服务器运维管理面板并实现公网访问

文章目录 前言1. Linux 安装1Panel2. 安装cpolar内网穿透3. 配置1Panel公网访问地址4. 公网远程访问1Panel管理界面5. 固定1Panel公网地址 前言 1Panel 是一个现代化、开源的 Linux 服务器运维管理面板。高效管理,通过 Web 端轻松管理 Linux 服务器&#xff0c;包括主机监控、…
阅读更多...
生成式AI赋能千行百业加速创新，2023亚马逊云科技re:Invent行业盘点

生成式AI赋能千行百业加速创新，2023亚马逊云科技re:Invent行业盘点

2023亚马逊云科技re:Invent全球大会已于上周圆满闭幕&#xff0c;在本次大会中&#xff0c;亚马逊云科技又为大家带来了很多功能/项目迭代更新&#xff0c;也重磅发布了很多全新的功能。今天从行业视角来盘点回顾哪些重磅发布适用于垂直行业客户&#xff0c;以及面向汽车、制造…
阅读更多...
人工智能-异步计算

人工智能-异步计算

异步计算 今天的计算机是高度并行的系统&#xff0c;由多个CPU核、多个GPU、多个处理单元组成。通常每个CPU核有多个线程&#xff0c;每个设备通常有多个GPU&#xff0c;每个GPU有多个处理单元。总之&#xff0c;我们可以同时处理许多不同的事情&#xff0c;并且通常是在不同的…
阅读更多...
使用Python实现爬虫IP负载均衡和高可用集群

使用Python实现爬虫IP负载均衡和高可用集群

做大型爬虫项目经常遇到请求频率过高的问题&#xff0c;这里需要说的是使用爬虫IP可以提高抓取效率&#xff0c;那么我们通过什么方法才能实现爬虫IP负载均衡和高可用集群&#xff0c;并且能快速的部署并且完成爬虫项目。 通常在Python中实现爬虫ip负载均衡和高可用集群需要一…
阅读更多...
微机原理14

微机原理14

一、单项选择题(本大题共15小题,每小题3分,共45分。在每小题给出的四个备选项中选出一个正确的答案,请将选定的答案填涂在答题纸的相应位置上。) 字符’A’的 ASCI 码是&#xff08;&#xff09; A. OAH B. 41H C. 61H D. OAOH 2, 8086微处理器的地址线有(&#xff09; A. 16条…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023