什么是MQ

news2025/7/28 9:34:52

MQ概述

MQ全称 Message Queue(消息队列),是在消息的传输过程中保存消息的容器。多用于分布式系统之间进
行通信。

分布式系统之间进行通信:

远程调用:各系统间直接通过远程调用的方式;

借助第三方完成系统通信:

在这里插入图片描述

上面A系统用来发送消息的为:生产者

B系统用来接收消息的为:消费者

MQ为:中间键

小结
⚫MQ,消息队列,存储消息的中间件
⚫分布式系统通信两种方式:直接远程调用 和 借助第三方 完成间接通信
⚫发送方称为生产者,接收方称为消费者

MQ的优势和劣势

优势:

⚫应用解耦
⚫异步提速
⚫削峰填谷

劣势:

⚫ 系统可用性降低
⚫ 系统复杂度提高
⚫ 一致性问题

优势:

1.应用解耦:

我们先看一幅图:

在这里插入图片描述

客户通过订单系统下单;

上面的订单系统与其他系统是直接通过远程调用连接的:

1、如果库存系统产生了异常,那么订单系统下单的时候整个程序就执行不了,可能导致订单系统也出现一些问题,最后导致下单失败————容错性低

2、假如在程序中添加或删除系统的时候需要程序员不停的修改订单系统————可维护性低

远程调用缺点:系统的耦合性越高,容错性就越低,可维护性就越低。

再看一幅图:

在这里插入图片描述

还是用户通过订单系统下单:

上面是通过借助第三方完成系统间通信的:

1、只需要订单系统给MQ发送一条消息,这时就可以给用户放回消息“下单成功”

2、库存系统、支付系统等等会分别从MQ中取数据,在自己的系统中消费;

3、如果库存系统异常,订单系统不会受到影响,应为订单系统和库存系统已经通过MQ隔离开了

4、库存系统修复完之后,再从MQ中区数据,最终数据正常运行;————系统容错性提高

5、如果程序要添加系统,只需要被添加的系统从MQ中取数据运行就完成了————系统可维护性提高

优点:使用 MQ 使得应用间解耦,提升容错性和可维护性。

2.异步提速

首先查看直接远程调用

在这里插入图片描述

我来描述一下上面的流程:

1、用户点击下单,订单系统去到数据库查询数据用时20ms,然后依次调用库存系统,支付系统,物流系统各300ms;

一个下单操作耗时:20 + 300 + 300 + 300 = 920ms
用户点击完下单按钮后,需要等待920ms才能得到下单响应,太慢!

通过MQ:

在这里插入图片描述

通过异步提速的流程:

客户点击订单系统,订单系统查询db用时20ms,订单发信息给MQ用时5ms,订单下单成功;

用户点击完下单按钮后,只需等待25ms就能得到下单响应 (20 + 5 = 25ms)。
提升用户体验和系统吞吐量(单位时间内处理请求的数目)。

3.错峰填谷

在这里插入图片描述

如果一个系统A系统:每秒最大处理请求是1000个请求。当商家搞活动的时候,就会有很多用户点进来,请求就会瞬间增多,每秒5000个,这个时候A系统就会崩溃了;

在这里插入图片描述

如果我们再客户和A系统之间添加一个中间键MQ就可以解决这个问题;

再们添加MQ之后流量访问变化如下图所示:

在这里插入图片描述

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

MQ优势小结

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

劣势

⚫系统可用性降低
系统引入的外部依赖越多,系统稳定性越差。一旦 MQ 宕机,就会对业务造成影响。如何保证MQ的高可用?
⚫系统复杂度提高
MQ 的加入大大增加了系统的复杂度,以前系统间是同步的远程调用,现在是通过 MQ 进行异步调用。如何
保证消息没有被重复消费?怎么处理消息丢失情况?那么保证消息传递的顺序性?
⚫一致性问题
A 系统处理完业务,通过 MQ 给B、C、D三个系统发消息数据,如果 B 系统、C 系统处理成功,D 系统处理
失败。如何保证消息数据处理的一致性?

小结

既然 MQ 有优势也有劣势,那么使用 MQ 需要满足什么条件呢?

① 生产者不需要从消费者处获得反馈。引入消息队列之前的直接调用,其接口的返回值应该为空,这才让明
明下层的动作还没做,上层却当成动作做完了继续往后走,即所谓异步成为了可能。
② 容许短暂的不一致性。
③ 确实是用了有效果。即解耦、提速、削峰这些方面的收益,超过加入MQ,管理MQ这些成本。

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

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

相关文章

【GlobalMapper精品教程】019:基于DSM提取离散随机点的高程信息

本文讲解在globalmapper中,基于DSM提取离散随机点的高程信息,配套数据为data019.rar。 文章目录 1. 离散点创建2. 提取离散点高程信息3. 高程标注1. 离散点创建 本文在ArcGIS中,根据给定的范围,随机生成离散点,如下图: 拓展阅读: ArcGIS根据范围创建随机点教程:【ArcG…

关于Kdo N3,1380099-68-2,3-脱氧-D-甘露-辛酸(Kdo)相关物理化学知识了解下

基础产品数据(Basic Product Data): CAS号:1380099-68-2 中文名:2-酮基-3-脱氧辛酸叠氮糖 英文名:Kdo Azide,Kdo N3 结构式(Structural): 试剂基团反应特点&a…

基于51单片机的波形发生器proteus仿真数码管LCD12864显示

仿真图1简介: 本系统采用51单片机作为系统的MCU(具体型号见下图),该系统显示器为四位数码管,可实时显示波形的参数情况 可显示四种波形,分别是方波、正弦波、三角波、锯齿波。 该设计具有电压表功能&#…

C语言MFC导出dll回调函数方法详解

如何将回调函数导出来 这一章节主要讲述在导出函数的基础上如何将回调函数导出来。 C程序设计语言(第1-3部分)(原书第4版) 京东自营优惠价:¥119.1立即抢购 回调函数的应用相信很多C程序猿儿们都不陌生吧…

弘玑Cyclone2022年产品发布会:人人可用的数字化工作平台——弘玑工作易

近日,在弘玑Cyclone“智无边界,数字未来”发布会上,弘玑Cyclone2022年超级自动化系列产品全新亮相,首席产品官贾岿博士带领产品团队以创新技术对新时代语境下的数字生产力进行了全新解读。 本文将为大家分享本次发布会重磅推出的…

为什么要让员工入职流程实现自动化

人和人之间的第一印象非常重要,一段缘分能不能开始,就看第一印象够不够给力了。其实,公司和新员工之间也存在着这样的关系,但也有些许差别。公司对新员工的第一印象,更多是从第一次见面的时候就产生了,而新…

NodeJs实战-待办列表(4)-解决待办事项中文乱码问题

NodeJs实战-待办列表4-解决待办事项中文乱码问题乱码问题在哪里产生的定位乱码问题VSCode 启动 NodeJs 调试模式浏览器中调试JS效果图执行添加执行完成乱码问题在哪里产生的 运行第3节的server.js, 当添加中文待办事项时候,会产生中文乱码问题。乱码可能在以下地方…

一款超好用的开源密码管理器?

程序员宝藏库:https://gitee.com/sharetech_lee/CS-Books-Store DevWeekly收集整理每周优质开发者内容,包括开源项目、资源工具、技术文章等方面。 每周五定期发布,同步更新到 知乎:Jackpop 。 欢迎大家投稿,提交iss…

最新消息:2022高被引科学家名单已公布,都想成为高被引,到底应该怎么做?(附名单)

11月15日,科睿唯安发布了2022年“高被引科学家”名单。该名单旨在遴选全球自然科学和社会科学领域最具影响力的研究人员。入选“高被引科学家”名单,意味着该学者在其所研究领域具有世界级影响力,其科研成果为该领域发展作出了较大贡献。 全球…

百度全景数据采集与分析

1、百度街景是什么 全景是通过将平面数字图像转换为三维空间,从而带来拟真交互体验的地图浏览方式。 全景技术通过专业相机将现实世界的空间场景捕捉下来,利用软件将多幅平面照片拼接合成,并模拟成三维空间的360度全景景观。全景具有真实感强…

127. 单词接龙

127. 单词接龙 字典 wordList 中从单词 beginWord 和 endWord 的 转换序列 是一个按下述规格形成的序列 beginWord -> s1 -> s2 -> … -> sk&#xff1a; 每一对相邻的单词只差一个字母。对于 1 < i < k 时&#xff0c;每个 si 都在 wordList 中。注意&…

linux线程互斥锁

互斥量mutex 大部分情况&#xff0c;线程使用的数据都是局部变量&#xff0c;变量的地址空间在线程栈空间内&#xff0c;这种情况&#xff0c;变量归属单个线程&#xff0c;其他线程无法获得这种变量。 但有时候&#xff0c;很多变量都需要在线程间共享&#xff0c;这样的变量…

基于粒子群优化算法的冷热电联供型综合能源系统运行优化附Matlab代码

✅作者简介&#xff1a;热爱科研的Matlab仿真开发者&#xff0c;修心和技术同步精进&#xff0c;matlab项目合作可私信。 &#x1f34e;个人主页&#xff1a;Matlab科研工作室 &#x1f34a;个人信条&#xff1a;格物致知。 更多Matlab仿真内容点击&#x1f447; 智能优化算法 …

JAVA图书管理练习

目录0.前言1.书类(BOOK)1.1 Book1.2 BookList2. User类2.1 user类2.2 AdminUser类2.3 NormalUser类3.Operation类3.1 添加图书3.2 删除图书3.3 查找图书3.4 展示图书3.5 退出系统3.6 借阅图书3.7 归还图书0.前言 1.在学习了面向对象,接口继承等语法后,综合使用这些语法完成一个…

【第九章】vim 程序编辑器

文章目录vi与vimvi的使用范例按键说明一般指令模式可用的按钮说明&#xff1a;光标移动、复制贴上、搜寻取代等一般指令模式切换到编辑模式的可用的按钮说明一般指令模式切换到命令行界面的可用按钮说明vim的暂存盘、救援回复与打开时的警告讯息vi与vim 一、Linux上面的指令都…

Java#12(String中的常用方法)

目录 一.String中的方法substring 1.作用:截取字符串 2.格式:对象名.substring(开始的索引,结束的索引(没写就截到结尾)) 3.返回类型是String,所以要用一个字符串对象来接收 4.特点: 二.String中的办法replace 1.作用:替换字符串中的内容 2.格式:对象名.replace("要…

【面试题】flex布局画色子

1. flex布局 flex属性作用flex-direction设置主轴的方向justify-content设置主轴上的子元素排列方式align-items设置侧轴上的子元素排列方式flex-wrap设置子元素是否换行align-self设置子元素在侧轴的对齐方式 2. 通过flex布局画色子 <!DOCTYPE html> <html lang&qu…

Zotero文献管理软件入门使用方法:软件下载、文献导入、引文插入

本文介绍文献管理软件Zotero的基础使用方法&#xff0c;包括软件下载与安装、文献与PDF导入、在Word中插入参考文献等的方法。 在EndNote文献输出引用格式自定义修改与编辑界面解读&#xff08;https://blog.csdn.net/zhebushibiaoshifu/article/details/115221112&#xff09;…

Mysql、Hive、Sqoop的安装及配置

Mysql的安装及配置 1、查看系统安装的MariaDB rpm -qa|grep mariadb2、删除查询到的MariaDB&#xff0c;这里的mariadb-libs-5.5.68-1.el7.x86_64是通过上一步查出来的 rpm -e --nodeps mariadb-libs-5.5.68-1.el7.x86_643、执行以下命令下载并安装mysql5.7 wget http://de…

蓝桥杯刷题(一)

蓝桥杯刷题1.单词分析2.成绩统计3.最短路4.门牌制作5.数字三角&#xff08;较困难&#xff09;1.单词分析 我本人其实是比较讨厌操作字符的&#xff0c;因为比较麻烦&#xff0c;所以我将字符都用ascll码值表示。例如‘a’97,‘b’98,c‘99’&#xff0c;所以b-a1 #include<…