当前位置：首页 > article >正文

SpringCloud系列（十）[MQ 篇] - RabbitMQ 初步学习及详细部署步骤

article 来源：原创 2023/2/5 14:38:25

RabbitMQ 的官方概念是这样的: 它是一种实现了高级消息队列协议（AMQP）的开源消息代理软件, 也称之为面向消息的中间件. 在理解RabbitMQ 之前, 先来简单了解一下 MQ 的含义: MQ 其实就是 MessageQueue 的缩写, 也就是消息队列的意思, 字面上来看也就是存放消息的队列, 比较常见的 MQ 实现有 RabbitMQ / RocketMQ / Kafka, 这样就可以将 RabbitMQ 理解为为了实现消息队列的一个技术 / 工具或者软件.

RabbitMQ

🐰关于同步通讯和异步通讯
🐰🐰MQ 技术对比
🐰🐰🐰 RabbitMQ 详细部署

🐰关于同步通讯和异步通讯

在学习 RabbitMQ 之前先来了解一下同步通讯和异步通讯的概念; 设想这样一个场景, 过年期间我们通过微信来约小伙伴去超市购物, 于是我就在发小群里面发了一条信息: “超市走不走”, 然后有的小伙伴看到了消息就回复 “走啊”, 但是也有的没 “及时” 看到消息就没有回复; 于是回复消息的我们几个就去了超市买了饮料, 然后通过微信支付付了钱, 超市那边接着提醒 “已到账 xx 元”.
其实上面这个场景就包含着同步通讯和异步通讯相关的概念, 我在群里发消息, 有的可以立即回复, 而有的不能够及时回复消息, 这就是异步通讯; 如果这里不是异步通讯的话, 我还得等着一个小伙伴回复消息后再去联系另一个小伙伴, 这样效率将大打折扣; 而在超市付款, 超市那边会接着提醒已到账 xx 元, 这就是同步通讯; 如果说付款到账提醒不是同步通讯的话, 那么将影响超市的效率, 导致排队付款的人会大量增多.
当然, 涉及到专业术语, 关于同步通讯和异步通讯的概念可以做以下总结:

同步通讯(缺点):
1 耦合度高: 当加入新的需求, 要修改原来的代码;
2 性能(吞吐能力)下降: 性能比较低, 调用者需要等待服务者的响应, 而如果调用链过长那么响应时间则会大大增加;
3 资源浪费: 调用链中的每个服务都在等待着响应过程, 不能够释放请求占用的资源, 高并发场景下会极度浪费系统资源;
4 级联失败: 如果服务者出现问题, 所有的调用方都会跟着出现问题, 甚至会导致整个集群出现故障.
优点: 时效性比较强, 可以立即得到结果.

异步通讯:
还是以例子的形式解释, 过年前我在淘宝上看上了一件羽绒服, 选择好尺码后我就下单支付成功, 这个时候淘宝方会将我购买的羽绒服订单进行修改状态, 如待发货状态, 紧接着仓库会接收到订单信息, 然后调用物流服务, 从仓库分配并准备发货;
在淘宝购物这个场景中, 我支付购买服务便是时间的发布者, 也就是 Publisher, 支付完成后只需要发布一个支付成功的事件, 并且此事件还要绑定上订单 id; 而订单服务或者物流服务则是时间的订阅者, 也就是 Consumer, 主要进行订阅支付成功的事件, 监听到事件后完成自己的业务即可.
为了解除 Publisher 和 Consumer 之间的耦合, 两者并不是直接进行通讯, 而是有一个中间人 (Broker), 发布者发布事件到 Broker, 不必关心谁来订阅这个事件; 而订阅者从 Broker 来订阅事件, 也不必关心谁发来的信息.
Broker 就像是 Vue 中的数据总线, 所有发送或者接收的数据都发到这个总线上面, 这个总线就像协议一样, 让服务间的通讯变得标准并且可控制.

缺点:
1 结构复杂: 服务间没有明确的流程线, 不易管理;
2 需要依赖 Broker 的可靠性 / 安全性等.

优点:
1 耦合度降低: 每个服务都可以灵活的调用甚至替换;
2 性能(吞吐量)提升: 发布者无需等待订阅者处理完成, 响应更迅速;
3 故障隔离: 服务间没有直接调用, 不存在级联失败的问题;
4 调用间没有阻塞: 不会造成同步通讯导致的资源浪费问题;
5 流量削峰: 无论发布者发布的事件流量多大, 都由 Broker 接收并存放, 订阅者可以按照自己的方式或者速度去处理事件.

🐰🐰MQ 技术对比

在这里插入图片描述
比较性能选择:

可用性: Kafka / RocketMQ / RabbitMQ
可靠性: RabbitMQ / RocketMQ
性能及吞吐能力: RocketMQ / Kafka
消息低延迟: RabbitMQ / Kafka

🐰🐰🐰 RabbitMQ 详细部署

&esmp; 上文已经详细介绍了 Docker 的安装, 这里我们使用 docker 来安装 RabbitMQ;
步骤一: 拉取 RabbitMQ: docker pull rabbitmq:3-management; 如果这里拉取速度太慢, 检查是否修改了本地的镜像源, 如何修改可看此文SpringCloud系列（九）[docker 篇] - Centos 7 下 Docker 的安装及基本操作指令; 如果还是慢, 那么直接下载 rabbitmq 镜像,点击此处查找镜像, 拖到虚拟机中, 执行加载镜像指令, 如: docker load -i rabbitmq.tar;
步骤二: 安装 RabbitMQ, 执行如下指令:

docker run \-e RABBITMQ_DEFAULT_USER=myRabbitMQ \-e RABBITMQ_DEFAULT_PASS=123456 \--name mq \--hostname mq1 \-p 15672:15672 \-p 5672:5672 \-d \rabbitmq:3-management

步骤三: 验证是否部署成功, 执行指令: docker images
在这里插入图片描述

查看全文

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

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

SpringCloud系列（十）[MQ 篇] - RabbitMQ 初步学习及详细部署步骤

RabbitMQ

🐰关于同步通讯和异步通讯

🐰🐰MQ 技术对比

🐰🐰🐰 RabbitMQ 详细部署

相关文章：

SpringCloud系列（十）[MQ 篇] - RabbitMQ 初步学习及详细部署步骤

Gitflow工作流：一个健壮的用于管理大型项目的框架

c语言中的常见图形打印

Python---私有化

WebRTC音频系统之audio技术栈简介-1

基于nodejs+vue社区互助平台- vscode项目

【自动驾驶100问】第一问到第三问

day03_注释丶关键字丶标识符丶常量

【千峰】React全球新闻发布管理系统

20230205英语学习

rk3288如何安装qt

Spring源码分析-Bean创建流程四

2023高质量Java面试题集锦：高级Java工程师面试八股汇总

5.1 栈Stack基于动态数组的Java实现

应用桌面图标快捷方式找不到了用命令方式找到应用并创建快捷方式

配置代理服务器

二叉树概念及基本功能实现

h5与APP交互

3.30--Redis之常用数据结构--整数集合（总结篇）------加油呀

【Python语言基础】——Python 随机模块