初识RabbitMq

目录

  • 1.初识MQ
    • 1.1.同步调用
    • 1.2.异步调用
    • 1.3.技术选型
  • 2.RabbitMQ
    • 2.1.安装
    • 2.2.收发消息
      • 2.2.1.交换机
      • 2.2.2.队列
      • 2.2.3.绑定关系
      • 2.2.4.发送消息
    • 2.3.数据隔离
      • 2.3.1.用户管理
      • 2.3.2.virtual host

1.初识MQ

1.1.同步调用

之前说过，我们现在基于OpenFeign的调用都属于是同步调用，那么这种方式存在哪些问题呢？
举个例子，我们以昨天留给大家作为作业的余额支付功能为例来分析，首先看下整个流程：

目前我们采用的是基于OpenFeign的同步调用，也就是说业务执行流程是这样的：

  • 支付服务需要先调用用户服务完成余额扣减
  • 然后支付服务自己要更新支付流水单的状态
  • 然后支付服务调用交易服务，更新业务订单状态为已支付

三个步骤依次执行。
这其中就存在3个问题：
第一，拓展性差
我们目前的业务相对简单，但是随着业务规模扩大，产品的功能也在不断完善。
在大多数电商业务中，用户支付成功后都会以短信或者其它方式通知用户，告知支付成功。假如后期产品经理提出这样新的需求，你怎么办？是不是要在上述业务中再加入通知用户的业务？
某些电商项目中，还会有积分或金币的概念。假如产品经理提出需求，用户支付成功后，给用户以积分奖励或者返还金币，你怎么办？是不是要在上述业务中再加入积分业务、返还金币业务？
。。。
最终你的支付业务会越来越臃肿：

也就是说每次有新的需求，现有支付逻辑都要跟着变化，代码经常变动，不符合开闭原则，拓展性不好。

第二，性能下降
由于我们采用了同步调用，调用者需要等待服务提供者执行完返回结果后，才能继续向下执行，也就是说每次远程调用，调用者都是阻塞等待状态。最终整个业务的响应时长就是每次远程调用的执行时长之和：

假如每个微服务的执行时长都是50ms，则最终整个业务的耗时可能高达300ms，性能太差了。

第三，级联失败
由于我们是基于OpenFeign调用交易服务、通知服务。当交易服务、通知服务出现故障时，整个事务都会回滚，交易失败。
这其实就是同步调用的级联失败问题。

但是大家思考一下，我们假设用户余额充足，扣款已经成功，此时我们应该确保支付流水单更新为已支付，确保交易成功。毕竟收到手里的钱没道理再退回去吧image.png。

因此，这里不能因为短信通知、更新订单状态失败而回滚整个事务。

综上，同步调用的方式存在下列问题：

  • 拓展性差
  • 性能下降
  • 级联失败

而要解决这些问题，我们就必须用异步调用的方式来代替同步调用。

1.2.异步调用

异步调用方式其实就是基于消息通知的方式，一般包含三个角色：

  • 消息发送者：投递消息的人，就是原来的调用方
  • 消息Broker：管理、暂存、转发消息，你可以把它理解成微信服务器
  • 消息接收者：接收和处理消息的人，就是原来的服务提供方

在异步调用中，发送者不再直接同步调用接收者的业务接口，而是发送一条消息投递给消息Broker。然后接收者根据自己的需求从消息Broker那里订阅消息。每当发送方发送消息后，接受者都能获取消息并处理。
这样，发送消息的人和接收消息的人就完全解耦了。

还是以余额支付业务为例：

除了扣减余额、更新支付流水单状态以外，其它调用逻辑全部取消。而是改为发送一条消息到Broker。而相关的微服务都可以订阅消息通知，一旦消息到达Broker，则会分发给每一个订阅了的微服务，处理各自的业务。

假如产品经理提出了新的需求，比如要在支付成功后更新用户积分。支付代码完全不用变更，而仅仅是让积分服务也订阅消息即可：

不管后期增加了多少消息订阅者，作为支付服务来讲，执行问扣减余额、更新支付流水状态后，发送消息即可。业务耗时仅仅是这三部分业务耗时，仅仅100ms，大大提高了业务性能。

另外，不管是交易服务、通知服务，还是积分服务，他们的业务与支付关联度低。现在采用了异步调用，解除了耦合，他们即便执行过程中出现了故障，也不会影响到支付服务。

综上，异步调用的优势包括：

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

当然，异步通信也并非完美无缺，它存在下列缺点：

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

1.3.技术选型

消息Broker，目前常见的实现方案就是消息队列（MessageQueue），简称为MQ.
目比较常见的MQ实现：

  • ActiveMQ
  • RabbitMQ
  • RocketMQ
  • Kafka

几种常见MQ的对比：

RabbitMQActiveMQRocketMQKafka
公司/社区RabbitApache阿里Apache
开发语言ErlangJavaJavaScala&Java
协议支持AMQP，XMPP，SMTP，STOMPOpenWire,STOMP，REST,XMPP,AMQP自定义协议自定义协议
可用性高一般高高
单机吞吐量一般差高非常高
消息延迟微秒级毫秒级毫秒级毫秒以内
消息可靠性高一般高一般

追求可用性：Kafka、 RocketMQ 、RabbitMQ
追求可靠性：RabbitMQ、RocketMQ
追求吞吐能力：RocketMQ、Kafka
追求消息低延迟：RabbitMQ、Kafka

据统计，目前国内消息队列使用最多的还是RabbitMQ，再加上其各方面都比较均衡，稳定性也好，因此我们课堂上选择RabbitMQ来学习。

2.RabbitMQ

RabbitMQ是基于Erlang语言开发的开源消息通信中间件，官网地址：
Messaging that just works — RabbitMQ
接下来，我们就学习它的基本概念和基础用法。

2.1.安装

我们同样基于Docker来安装RabbitMQ，使用下面的命令即可：

docker run  -e RABBITMQ_DEFAULT_USER=shenyang  -e RABBITMQ_DEFAULT_PASS=1
23456  -v mq-plugins:/plugins  --name mq  --hostname mq  -p 15672:15672  -p 5672:5672  --network hmall  -d  rabbitmq:3.8-management

[root@centos ~]# docker images
REPOSITORY           TAG              IMAGE ID       CREATED        SIZE
mysql                8.0.32           412b8cc72e4a   8 months ago   531MB
redis                latest           31f08b90668e   8 months ago   117MB
rabbitmq             3.8-management   85e83aca5d60   2 years ago    249MB
canal/canal-server   v1.1.5           0c7f1d62a7d8   2 years ago    874MB

本地镜像命令：

要启动RabbitMQ镜像，并映射管理界面端口（默认是15672），同时设置用户和密码，你需要使用以下的 docker run 命令。这里我假设你的RabbitMQ镜像标签是 3.8-management。

首先，你需要为RabbitMQ设置环境变量来定义默认用户和密码。这可以通过在 docker run 命令中添加 -e 参数来实现：

docker run -d --name myrabbitmq \-e RABBITMQ_DEFAULT_USER=shenyang \-e RABBITMQ_DEFAULT_PASS=123456 \-p 15672:15672 \rabbitmq:3.8-management

下面是每个选项的解释：

  • -d: 运行容器在后台（detached mode）。
  • --name myrabbitmq: 给容器命名为 “myrabbitmq”。
  • -e RABBITMQ_DEFAULT_USER=shenyang: 设置环境变量来创建用户 “shenyang”。
  • -e RABBITMQ_DEFAULT_PASS=123456: 设置环境变量来为用户 “shenyang” 设置密码 “123456”。
  • -p 15672:15672: 映射本地机器的15672端口到容器中的15672端口。该端口用于RabbitMQ管理界面。
  • rabbitmq:3.8-management: 指定要运行的镜像名称和标签。

运行这个命令后，将会创建一个后台运行的容器，在本地15672端口提供RabbitMQ服务。你可以通过 http://localhost:15672 访问管理界面，并使用用户名 “shenyang” 和密码 “123456” 登录。
可以看到在安装命令中有两个映射的端口：

  • 15672：RabbitMQ提供的管理控制台的端口
  • 5672：RabbitMQ的消息发送处理接口

安装完成后，我们访问 http://192.168.193.141:15672即可看到管理控制台。首次访问需要登录，默认的用户名和密码在配置文件中已经指定了。
登录后即可看到管理控制台总览页面：
在这里插入图片描述
在这里插入图片描述

RabbitMQ对应的架构如图：
image.png
其中包含几个概念：

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

上述这些东西都可以在RabbitMQ的管理控制台来管理。

2.2.收发消息

2.2.1.交换机

我们打开Exchanges选项卡，可以看到已经存在很多交换机：
image.png
我们点击任意交换机，即可进入交换机详情页面。仍然会利用控制台中的publish message 发送一条消息：
image.png
image.png
这里是由控制台模拟了生产者发送的消息。由于没有消费者存在，最终消息丢失了，这样说明交换机没有存储消息的能力。

2.2.2.队列

我们打开Queues选项卡，新建一个队列：
image.png
命名为hello.queue1：
image.png
再以相同的方式，创建一个队列，密码为hello.queue2，最终队列列表如下：
image.png
此时，我们再次向amq.fanout交换机发送一条消息。会发现消息依然没有到达队列！！
怎么回事呢？
发送到交换机的消息，只会路由到与其绑定的队列，因此仅仅创建队列是不够的，我们还需要将其与交换机绑定。

2.2.3.绑定关系

点击Exchanges选项卡，点击amq.fanout交换机，进入交换机详情页，然后点击Bindings菜单，在表单中填写要绑定的队列名称：
image.png
相同的方式，将hello.queue2也绑定到改交换机。
最终，绑定结果如下：
image.png

2.2.4.发送消息

再次回到exchange页面，找到刚刚绑定的amq.fanout，点击进入详情页，再次发送一条消息：
image.png
回到Queues页面，可以发现hello.queue中已经有一条消息了：
image.png
点击队列名称，进入详情页，查看队列详情，这次我们点击get message：
image.png
可以看到消息到达队列了：
image.png
这个时候如果有消费者监听了MQ的hello.queue1或hello.queue2队列，自然就能接收到消息了。

2.3.数据隔离

2.3.1.用户管理

点击Admin选项卡，首先会看到RabbitMQ控制台的用户管理界面：
在这里插入图片描述
这里的用户都是RabbitMQ的管理或运维人员。目前只有安装RabbitMQ时添加的itheima这个用户。仔细观察用户表格中的字段，如下：

  • Name：shenyang，也就是用户名
  • Tags：administrator，说明shenyang用户是超级管理员，拥有所有权限
  • Can access virtual host： /，可以访问的virtual host，这里的/是默认的virtual host

对于小型企业而言，出于成本考虑，我们通常只会搭建一套MQ集群，公司内的多个不同项目同时使用。这个时候为了避免互相干扰， 我们会利用virtual host的隔离特性，将不同项目隔离。一般会做两件事情：

  • 给每个项目创建独立的运维账号，将管理权限分离。
  • 给每个项目创建不同的virtual host，将每个项目的数据隔离。

比如，我们给测试用例创建一个新的用户，命名为shenjie：
在这里插入图片描述

你会发现此时hmall用户没有任何virtual host的访问权限：
)

别急，接下来我们就来授权。

2.3.2.virtual host

我们先退出登录：
切换到刚刚创建的shenjie用户登录，然后点击Virtual Hosts菜单，进入virtual host管理页：
在这里插入图片描述

可以看到目前只有一个默认的virtual host，名字为 /。
我们可以创建一个单独的virtual host，而不是使用默认的/。
在这里插入图片描述

创建完成后如图：
在这里插入图片描述

由于我们是登录shenjie账户后创建的virtual host，因此回到users菜单，你会发现当前用户已经具备了对/shen这个virtual host的访问权限了：
在这里插入图片描述

此时，点击页面右上角的virtual host下拉菜单，切换virtual host为 /hmall：

然后再次查看queues选项卡，会发现之前的队列已经看不到了：
在这里插入图片描述

这就是基于virtual host 的隔离效果。

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

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

相关文章

「构」向云端 - 我与 2023 亚马逊云科技 re:Invent 大会

「构」向云端 - 我与 2023 亚马逊云科技 re:Invent 大会

授权声明：本篇文章授权活动官方亚马逊云科技文章转发、改写权，包括不限于在 亚马逊云科技开发者社区, 知乎，自媒体平台，第三方开发者媒体等亚马逊云科技官方渠道 2023年亚马逊AWS re:Invent大会宣布一项Amazon Q的创新项目&#x…
阅读更多...
vmware安装Linux虚拟机设置固定IP地址

vmware安装Linux虚拟机设置固定IP地址

Linux虚拟机设置固定IP 近期工作需要，本地用VMware安装了三台Linux-centos虚拟机，来搭建rocketmq集群。但是IP地址每天关机重启之后就会比变化，很是恼火。找到了一个修改的教程，亲测有效！！！&am…
阅读更多...
Java生成带log的二维码

Java生成带log的二维码

生成二维码案例 1.引入依赖 <!-- zxing生成二维码 --> <dependency><groupId>com.google.zxing</groupId><artifactId>core</artifactId><version>3.3.3</version> </dependency><dependency><groupId>co…
阅读更多...
1.了解数据结构和算法

1.了解数据结构和算法

1.了解数据结构和算法 1.1 二分查找 二分查找&#xff08;Binary Search&#xff09;是一种在有序数组中查找特定元素的搜索算法。它的基本思想是将数组分成两半&#xff0c;然后比较目标值与中间元素的大小关系&#xff0c;从而确定应该在左半部分还是右半部分继续查找。这个…
阅读更多...
java 探针两种模式实战

java 探针两种模式实战

分为两种 程序运行前的agent&#xff1a;premain 程序运行中的agent&#xff1a;agentmain 在程序运行前的agent javaagent是java命令的一个参数&#xff0c;所以需要通过-javaagent 来指定一个jar包&#xff08;就是我们要做的代理包&#xff09;能够实现在主程序运行前来执行…
阅读更多...
前端自定义验证码，校验验证码，验证码时效

前端自定义验证码，校验验证码，验证码时效

最近做的项目&#xff0c;不需要后端接口&#xff0c;只需要前端验证&#xff0c;如图 初始页面 获取验证码 验证码的文件&#xff0c;直接复制就行 <template><div class"s-canvas"><canvasid"s-canvas":width"contentWidth":…
阅读更多...
HTML---列表.表格.媒体元素

HTML---列表.表格.媒体元素

文章目录 目录 文章目录 一.列表 无序列表 有序列表 自定义列表 二.表格 表格的兼并 三.媒体元素 视频标签 音频标签 四.内联框架 五.拓展标签 总结 一.列表 无序列表 HTML中的无序列表&#xff08;Unordered List&#xff09;用于显示一组项目&#xff0c;每个项目之前…
阅读更多...
shell(49) : 多个服务器批量设置相互免密

shell(49) : 多个服务器批量设置相互免密

写在前面 CentOS Linux release 7.9.2009 (Core) 系统已验证默认root账户, 其他账户无效创建[auto_mm.sh]必须vi创建文件然后粘贴 1.安装expect 1.1.在线安装 yum install -y tcl yum install -y expect 1.2.离线安装(选其中一个即可) 1.2.1.在能联通公网的机器导出rpm包到…
阅读更多...
【Pytorch】Transposed Convolution

【Pytorch】Transposed Convolution

文章目录 1 卷积2 反/逆卷积3 MaxUnpool / ConvTranspose4 encoder-decoder5 可视化 学习参考来自&#xff1a; 详解逆卷积操作–Up-sampling with Transposed Convolution PyTorch使用记录 https://github.com/naokishibuya/deep-learning/blob/master/python/transposed_co…
阅读更多...
每天五分钟计算机视觉：Inception网络是由多个Inception模块构成

每天五分钟计算机视觉：Inception网络是由多个Inception模块构成

本文重点 inception从另一种角度来提升训练结果：能更高效的利用计算资源，在相同的计算量下能提取到更多的特征，从而提升训练结果。可以简单的理解为Inception 网络是由一个一个的Inception模块构建成的，我们来看一下。 Inception模块 如上就是Inception模块的 通过一个1…
阅读更多...
采埃孚4D成像雷达拆解

采埃孚4D成像雷达拆解

1 基本信息 品牌&#xff1a;海外Tier1采埃孚 • 应用&#xff1a;上汽飞凡中高端纯电平台 • 数量&#xff1a;单车2个&#xff0c;安装在前后保内部 • 最远探测距离&#xff1a;350米 拆解来看&#xff0c;4D雷达主要可以分为4个部分&#xff0c;分别为数字接口板及结构件…
阅读更多...
JAVA对文档加密

JAVA对文档加密

当 Word 文档中包含无法公开的机密信息时&#xff0c;我们可以对其进行加密&#xff0c;使其在没有密码的情况下无法打开。本文将向您介绍如何使用 Spire.Doc for Java 加密 Word 文档和移除 Word 密码保护。 加密 Word 文档删除 Word 密码保护 安装 Spire.Doc for Java 首先…
阅读更多...
eclipse连接mysql数据库（下载eclipse，下载安装mysql，下载mysql驱动）

eclipse连接mysql数据库（下载eclipse，下载安装mysql，下载mysql驱动）

前言&#xff1a; 使用版本&#xff1a;eclipse2017&#xff0c;mysql5.7.0&#xff0c;MySQL的jar建议使用最新的&#xff0c;可以避免警告&#xff01; 1&#xff1a;下载安装&#xff1a;eclipse&#xff0c;mysql在我之前博客中有 http://t.csdnimg.cn/UW5fshttp://t.csdn…
阅读更多...
富文本内容图片点击实现多图预览

富文本内容图片点击实现多图预览

实现思路: 获取到富文本中所有的img标签&#xff0c;方面给图片添加类名方便后面取dom&#xff1b; 获取所有的img类 给每个img绑定点击事件 利用数组的splice方法&#xff0c;将当前点击的图片放置数组的第一项 调用vant预览方法 import { showImagePreview } from vant;<p…
阅读更多...
云上丝绸之路| 云轴科技ZStack成功实践精选（西北）

云上丝绸之路| 云轴科技ZStack成功实践精选（西北）

古有“丝绸之路” 今有丝绸之路经济带 丝路焕发新生&#xff0c;数智助力经济 云轴科技ZStack用“云”护航千行百业 沿丝绸之路&#xff0c;领略西北数字化。 古丝绸之路起点-陕西 集历史与现代交融&#xff0c;不仅拥有悠久的历史文化积淀&#xff0c;而且现代化、数字化发…
阅读更多...
创建k8s账号与RBAC授权使用

创建k8s账号与RBAC授权使用

创建账号 1、创建私钥[rootkub-k8s-master ~]# (umask 077; openssl genrsa -out soso.key 2048) Generating RSA private key, 2048 bit long modulus ............................... .......................... e is 65537 (0x10001) ​ 用此私钥创建一个csr(证书签名请求…
阅读更多...
【setDS】牛客小白月赛83 E

【setDS】牛客小白月赛83 E

登录—专业IT笔试面试备考平台_牛客网 题意 思路 首先&#xff0c;一个必要步骤是把它转化为两个序列&#xff0c;这样就变成了一个序列DS问题 我们的答案是一个位置 pos 后面还有多少位置和这个位置的颜色相同&#xff0c;考虑得到这个答案我们需要维护什么东西 我们只需要…
阅读更多...
springboot rabbitmq 发布订阅 广播模式

springboot rabbitmq 发布订阅 广播模式

根据amqp协议、rabbitmq入门、springboot集成rabbitmq 可知&#xff0c;rabbitmq的广播模式关键是使用fanout类型的exchange&#xff0c;fanout exchange会忽略message中的routing-key、queue中的binding-key&#xff0c;发给绑定exchange的全部queue。 创建fanout类型的excha…
阅读更多...
Jmeter，提取响应体中的数据：正则表达式、Json提取器

Jmeter，提取响应体中的数据：正则表达式、Json提取器

一、正则表达式 1、线程组--创建线程组&#xff1b; 2、线程组--添加--取样器--HTTP请求&#xff1b; 3、Http请求--添加--后置处理器--正则表达式提取器&#xff1b; 4、线程组--添加--监听器--查看结果树&#xff1b; 5、线程组--添加--取样器--调试取样器。 响应体数据…
阅读更多...
Axure动态面板的使用以及示例分享

Axure动态面板的使用以及示例分享

目录 一. 什么是动态面板 二. 动态面板教程——以轮播图为例 2.1 创建动态面板 2.2 动态面板自适应大小 2.3 重复状态&#xff0c;将图片导入 2.4 添加交互事件——图片切换 2.5 效果展示 三. 多方式登录示例展示 四. 后台主界面左侧菜单栏示例展示 一. 什么是动态面板…
阅读更多...
最新文章

Copyright @ 2022~2023