RabbitMQ一、RabbitMQ的介绍与安装(docker)

news2024/11/24 17:25:40

一、RabbitMQ相关名词解释

MQ

  1. MQ全称Message Queue(消息队列),是在消息的传输过程中保存消息的容器。

    • 多用于系统之间的异步通信
  2. 常见的两种通信方式:

    • 同步通信:同步通信相当于两个人当面对话,你一言我一语。必须及时回复
      在这里插入图片描述

    • 异步通信:异步通信相当于通过第三方转述对话,可能有消息的延迟,但不需要二人时刻保持联系
      在这里插入图片描述

消息

  1. 消息是两台计算机间传送的数据单位。消息可以非常简单,例如只包含文本字符串;也可以更复杂,可能包含嵌入对象。

队列

  1. 队列是数据结构中的概念。
    • 在队列中,数据先进先出,后进后出。
      在这里插入图片描述

二、RabbitMQ相对其他MQ产品的优势

  1. 应用解耦:提高系统容错性和可维护性
  2. 异步提速:提升用户体验和系统吞吐量
  3. 削峰填谷:提高系统稳定性

1、应用解耦

没有使用mq

  1. 举例:在电商平台中,用户下订单需要调用订单系统,此时订单系统还需要调用库存系统、支付系统、物流系统完成业务。此时会产生两个问题:
    • 如果库存系统出现故障,会造成整个订单系统崩溃。
    • 如果需求修改,新增了一个X系统,此时必须修改订单系统的代码。
      在这里插入图片描述

使用mq

  1. 如果在系统中引入MQ,即订单系统将消息先发送到MQ中,MQ再转发到其他系统,则会解决以下问题:
      1. 由于订单系统只发消息给MQ,不直接对接其他系统,如果库存系统出现故障,不影响整个订单系统
      1. 如果需求修改,新增了一个X系统,此时无需修改订单系统的代码,只需修改MQ将消息发送给X系统即可。
        在这里插入图片描述

2、异步提速

没有使用mq

  1. 如果订单系统同步访问每个系统,则用户下单等待时长如下:
    在这里插入图片描述

使用mq

在这里插入图片描述

3、削峰填谷

没有使用mq

  1. 假设我们的系统每秒只能承载1000请求,如果请求瞬间增多到每秒5000,则会造成系统崩溃。(此时引入mq即可解决该问题)
    在这里插入图片描述

使用mq

  1. 使用了MQ之后,限制消费消息的速度为1000,这样一来,高峰期产生的数据势必会被积压在MQ中,高峰就被“削”掉了,但是因为消息积压,在高峰期过后的一段时间内,消费消息的速度还是会维持在1000,直到消费完积压的消息,这就叫做“填谷”。
    在这里插入图片描述
    在这里插入图片描述
  • 使用MQ后,可以提高系统稳定性。

三、RabbitMQ相对其他MQ产品的劣势

在这里插入图片描述
● 系统可用性降低 系统引入的外部依赖越多,系统稳定性越差。一旦MQ宕机,就会对业务造成影响。
● 系统复杂度提高 MQ的加入大大增加了系统的复杂度,以前系统间是同步的远程调用,现在是通过MQ进行异步调用
● 一致性问题 A系统处理完业务,通过MQ给B、C、D三个系统发消息数据,如果B系统、C系统处理成功,D系统处理失败,则会造成数据处理的不一致

四、常见的 MQ 产品

在这里插入图片描述

AMQP

  1. AMQP,即 Advanced Message Queuing Protocol(高级消息队列协议),是一个网络协议,是应用层协议的一个开放标准,为面向消息的中间件设计。
    • 基于此协议的客户端与消息中间件可传递消息,并不受客户端/中间件不同产品,不同的开发语言等条件的限制。
      • 2006年,AMQP 规范发布。类比HTTP。

AMQP工作过程

  1. 生产者(Publisher)将消息发布到交换机(Exchange)
  2. 交换机根据规则将消息分发给交换机绑定的队列(Queue)
  3. 队列再将消息投递给订阅了此队列的消费者。
    在这里插入图片描述

五、RabbitMQ简介

  1. 2007年,Rabbit 技术公司基于 AMQP 标准开发的 RabbitMQ 1.0 发布。
    • RabbitMQ 采用 Erlang 语言开发。Erlang 语言由 Ericson 设计,专门为开发高并发和分布式系统的一种语言,在电信领域使用广泛。
  2. RabbitMQ 基础架构:
    在这里插入图片描述
  3. RabbitMQ基础结构名词解释:
    • Producer:消息的生产者。也是一个向交换机发布消息的客户端应用程序。
    • Connection:连接。生产者/消费者和RabbitMQ服务器之间建立的TCP连接。
    • Channel:信道。是TCP里面的虚拟连接。
      • 例如:Connection相当于电缆,Channel相当于独立光纤束,一条TCP连接中可以创建多条信道,增加连接效率。无论是发布消息、接收消息、订阅队列都是通过信道完成的。
    • Broker:消息队列服务器实体。即RabbitMQ服务器
    • Virtual host:虚拟主机。出于多租户和安全因素设计的,把AMQP的基本组件划分到一个虚拟的分组中。每个vhost本质上就是一个mini版的RabbitMQ服务器,拥有自己的队列、交换机、绑定和权限机制。当多个不同的用户使用同一个RabbitMQ服务器时,可以划分出多个虚拟主机。RabbitMQ默认的虚拟主机路径是/。
    • Exchange:交换机。用来接收生产者发送的消息,并根据分发规则,将这些消息分发给服务器中的队列中。不同的交换机有不同的分发规则。
    • Queue:消息队列。用来保存消息直到发送给消费者。它是消息的容器,也是消息的终点。消息一直在队列里面,等待消费者链接到这个队列将其取走。
    • Binding:消息队列和交换机之间的虚拟连接,绑定中包含路由规则,绑定信息保存到交换机的路由表中,作为消息的分发依据。
    • Consumer:消息的消费者。表示一个从消息队列中取得消息的客户端应用程序。

RabbitMQ为什么使用信道而不直接使用TCP连接通信?

  1. TCP连接的创建和销毁开销特别大。创建需要3次握手,销毁需要4次分手。高峰时每秒成千上万条TCP连接的创建会造成资源巨大的浪费。
  2. 操作系统每秒处理TCP连接数也是有限制的,会造成性能瓶颈。而如果一条线程使用一条信道一条TCP链接可以容纳无限的信道,即使每秒成千上万的请求也不会成为性能的瓶颈。

六、RabbitMQ安装(docker)

docker的使用

第一步、拉取镜像

docker pull rabbitmq:3.13-management

在这里插入图片描述

第二步、创建并运行rabbitmq容器

docker run -d -p 15672:15672 -p 5672:5672 \
        --restart=always \
        -e RABBITMQ_DEFAULT_USER=admin \
        -e RABBITMQ_DEFAULT_PASS=admin \
        --name rabbitmq\
        rabbitmq:3.13-management
  • 参数说明:
-d:表示在后台运行容器;
-p:将主机的端口 15672(Web访问端口号)对应当前rabbitmq容器中的 15672 端口,将主机的5672(应用访问端口)端口映射到rabbitmq中的5672端口;
--restart=alawys:设置开机自启动
-e:指定环境变量:
    RABBITMQ_DEFAULT_VHOST:默认虚拟机名;
    RABBITMQ_DEFAULT_USER:默认的用户名;
    RABBITMQ_DEFAULT_PASS:默认的用户密码;
--name rabbitmq:设置容器名称;

在这里插入图片描述

第三步、启动rabbitmq的web客户端:

docker exec -it rabbitmq rabbitmq-plugins enable rabbitmq_management

在这里插入图片描述

第四步、访问rabbitmq的web客户端:

  • 在浏览器上输入 ip+端口 访问rabbitmq的web客户端
  • username和password是在创建并运行rabbitmq容器的步骤使用参数指定的

在这里插入图片描述
到这里就表示安装成功了。

账号管理——角色说明

  1. 添加账户:
    在这里插入图片描述
  • 角色说明
      1. 超级管理员(administrator) 可登陆管理控制台,可查看所有的信息,并且可以对用户,策略(policy)进行操作。
      1. 监控者(monitoring) 可登陆管理控制台,同时可以查看rabbitmq节点的相关信息(进程数,内存使用情 况,磁盘使用情况等)
      1. 策略制定者(policymaker) 可登陆管理控制台, 同时可以对policy进行管理。但无法查看节点的相关信息(上图红 框标识的部分)。
      1. 普通管理者(management) 仅可登陆管理控制台,无法看到节点信息,也无法对策略进行管理。
      1. 其他 无法登陆管理控制台,通常就是普通的生产者和消费者。

RabbitMQ二、RabbitMQ的六种模式

RabbitMQ三、springboot整合rabbitmq(消息可靠性、高级特性)

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

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

相关文章

SD321BF 低功耗单运算放大器芯片IC

一般说明 SD321为低功耗系统带来性能和经济性。具有高单位增益频率和保证0.4V/在此情况下,静态电流仅为430μa/aef(5V)。输入通用模式范围包括地面,因此该设备能够在单电源应用和双电源应用中工作。它还能够舒适地驱动大容量负载。 SD32…

【环境栏Composer】Composer常见问题(持续更新)

1、执行composer install提示当前目录中没有 composer.lock 文件时 No composer.lock file present. Updating dependencies to latest instead of installing from lock file. See https://getcomposer.org/install for more information. Composer 在执行 install 命令时会…

单投币的充电桩如何加装一个扫码模块

充电桩需要投币才能充电,可是现在的人们很少有带硬币的习惯,扫码成为了一个常规的手段。我们也会发现有的充电桩无法扫码,或者说扫码无效,那是因为充电桩没有安装扫码模块,那么充电桩该如何加装扫码模块。 首先将充电桩…

搭建智慧互联网医院系统教学:源码解析与在线问诊APP开发

本篇文章,小编将以“源码解析与在线问诊APP开发”为切入点,详细介绍搭建智慧互联网医院系统的过程。 一、智慧互联网医院系统的架构设计 系统架构概述 -前端 -后端 -数据库 功能模块划分 -用户 -预约 -挂号 -问诊、 -病历 -管理 -药品 -配送…

家长必看:学生如何正确使用台灯?精选适合学生写作业的台灯

中国目前面临着严重的近视问题,各学段学生的近视率普遍偏高,且高度近视的占比也不容忽视,儿童近视的问题已经成为了一个不容忽视的社会问题。为了让孩子在学习的过程中拥有更好的视力保护,不少家长会选择购买性价比高、健康护眼的…

深入解析:海外短剧推广平台的流媒体传输技术挑战与应对策略

在海外短剧推广平台的建设和运营过程中,流媒体传输技术扮演着至关重要的角色。然而,由于网络环境的复杂性和多样性,流媒体传输技术面临着诸多挑战。本文将深入解析这些挑战,并提出相应的应对策略。 一、流媒体传输技术的挑战 带…

令人瞠目结舌的8个ChatGPT-4o提示词

博主猫头虎的技术世界 🌟 欢迎来到猫头虎的博客 — 探索技术的无限可能! 专栏链接: 🔗 精选专栏: 《面试题大全》 — 面试准备的宝典!《IDEA开发秘籍》 — 提升你的IDEA技能!《100天精通鸿蒙》 …

【关于傅里叶变换的一系列问题】

1. 为什么频率分辨率是 f s N \frac{f_s}{N} Nfs​​? 因为采样率 f s {f_s} fs​ 决定了最大频率范围(奈奎斯特频率)。时域信号长度 𝑁决定了频域中的离散点数。DFT对长度为 𝑁的时域信号进行变换,得到…

LVGL的移植

对这个源文件进行一定的裁剪,其余文件保留: 之后将examples中得文件进行裁剪,只保留输入输出设备文件porting 流程: 1,确定输入输出的设备 2,确定所需的可选功能 3,准备LVGL库、历程 4&#xf…

OSG天空图代码

osgEarth // 创建天空选项osgEarth::Util::SkyOptions skyOptions;// 设置天空的坐标系统(可选)skyOptions.coordinateSystem() osgEarth::Util::SkyOptions::COORDSYS_ECEF;// 设置一天中的小时数(可选)skyOptions.hours() 12.…

Vulnhub-DC-3

joomla3.7.0的提权 信息收集 靶机IP:192.168.20.136 kaliIP:192.168.20.128 网络有问题的可以看下搭建Vulnhub靶机网络问题(获取不到IP) 首先nmap扫端口和版本,dirsearch跑下目录,wappalyzer也可以用下 发现服务器用的ubuntu,JoomlaCMS…

实验9 浮动静态路由配置

--名称-- 一、 原理描述二、 实验目的三、 实验内容四、 实验配置五、 实验步骤 一、 原理描述 浮动静态路由也是一种特殊的静态路由,主要考虑链路冗余。浮动静态路由通过配置一条比主路由优先级低的静态路由,用于保证在主路由失效的情况下,…

RabbitMQ小结

MQ分类 Acitvemq kafka 优点:性能好,吞吐量高百万级,分布式,消息有序 缺点:单机超过64分区,cpu会飙高,消费失败不支持重试 , Rocket 阿里的mq产品 优点:单机吞吐量也…

PHP质量工具系列之php-depend

php-depend是一个开源的静态代码分析工具,它的主要功能包括: 代码质量分析 复杂度度量:计算类、方法和函数的Cyclomatic Complexity(循环复杂度),帮助识别潜在的复杂代码段。 耦合度度量:分析类…

pytorch笔记:自动混合精度(AMP)

1 理论部分 1.1 FP16 VS FP32 FP32具有八个指数位和23个小数位,而FP16具有五个指数位和十个小数位Tensor内核支持混合精度数学,即输入为半精度(FP16),输出为全精度(FP32) 1.1.1 使用FP16的优缺…

【AR开发-开源框架】使用Sceneform-EQR快速开发AR应用,当前接入了AREngine、ORB-SLAM,可快速地适配不同的安卓设备

Sceneform-EQR Sceneform 概览 Sceneform是一个3D框架,具有基于物理的渲染器,针对移动设备进行了优化,使您可以轻松构建增强现实应用程序,而无需OpenGL。 借助 Sceneform,您可以轻松地在 AR 应用和非 AR 应用中渲染…

【C语言】10.C语言指针(4)

文章目录 1.回调函数是什么?2.qsort 使⽤举例2.1 使⽤qsort函数排序整型数据2.2 使⽤qsort排序结构数据 3.qsort函数的模拟实现 1.回调函数是什么? 回调函数就是一个通过函数指针调用的函数。 如果你把函数的指针(地址)作为参数…

如何为律师制作专业的商务名片?含电子名片二维码

律师关注细节,律师名片也不例外。它们不仅仅是身份的象征,更是律师专业形象的代表,传递专业知识和信任。今天就来和我们一起来看看制作律师商务名片的注意事项,以及如何制作商务名片上的电子名片二维码? 一、名片的主…

kafka学习笔记 @by_TWJ

目录 1. 消息重复消费怎么解决1.1. 确保相同的消息不会被重复发送(消费幂等性)1.2. 消息去重1.3. 消息重试机制1.4. kafka怎么保证消息的顺序性1.4.1. 利用分区的特征:1.4.2. 解决办法:1.4.3. 分区分配策略1.4.3.1. RangeAssignor (每组(Topi…

Windows下安装和配置Redis

目录 1、下载redis压缩包 2、解压redis文件 3、启动redis临时服务 4、打开Redis客户端进行连接 5、使用一些基础操作来测试 5.1、输入ping命令来检测redis服务器与redis客户端的连通性 5.2、使用set和get命令测试redis数据库进行数据存储和获取 5.3、在命令中通过shut…