什么是 MQ

news2025/7/29 14:09:37

MQ的概念

MQ (Message Queue)消息队列,是在消息传输过程中存储消息的容器。多用于分布式系统之间的通信。
队列是基础数据结构中 “先进先出” 的一种数据结构。
消息对列,指把要传输的数据消息放在队列中,用队列机制来实现消息传递。

MQ基本模型

在这里插入图片描述
上图中,“P”是我们的生产者,“C”是我们的消费者,中间就是存放消息的消息队列。
生产者将消息发送到MQ,MQ将消息推送给指定的消费者,或者消费者去MQ 拉取特定的消息。
生产者和消费者可以当做客户端,MQ就是服务端(也可以叫作消息中间件)。

MQ的作用

1、解耦容错

未使用MQ前,库存系统、支付系统、物流系统其中任何一个子系统出现故障,都会造成下单操作异常。
在这里插入图片描述
使用MQ后,订单系统和库存系统、支付系统、物流系统进行了系统间的解耦,任何一个子系统出现故障不影响订单系统和其它子系统。比如物流系统出现故障了,需要几分钟进行修复,此时物流系统要处理的数据保存在了MQ中,用户的下单操作可以继续进行,当物流系统恢复后,继续处理订单信息即可。下单用户感受不到物流系统发生的故障,提高系统的容错性。
在这里插入图片描述

2、异步提速

未使用MQ前,库存系统、支付系统、物流系统之间是同步(必须一个接一个)处理数据的,总共花费时间是3*300ms+20ms=920ms;
在这里插入图片描述
使用MQ后,我们在库存系统处理数据的同时,可以进行支付系统、物流系统处理数据,完成系统间的异步处理数据。总共花费时间是300ms+20ms+5ms=325ms;
在这里插入图片描述

3、削峰限流

比如:订单系统最多能处理1000次/s订单,这在平常时段没问题,但在高峰期,如果有1万次下订单,此时系统是处理不了的,否则系统会发生故障。使用MQ做缓冲,这时消息会积压在MQ服务器,在高峰期过后一段时间内,消息会一直维持在服务器能承受的范围内 ,直到消费完积压的消息,提升系统的稳定性。
在这里插入图片描述

MQ劣势

1、系统可用性降低。

系统引入的外部依赖越多,系统的稳定性越差。一旦MQ宕机,就会对业务造成影响。需要利用各种收到提高MQ的高可用。

2、系统复杂度提高

大大提高了系统的复杂度,以前系统间是同步的远程调用,现在是通过MQ进行异步调用。需要处理消息被重复消费以及防止消息丢失的问题。

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

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

相关文章

spring之基于p命名c命名空间的注入

文章目录前言一、p命名空间1.1、编写一个普通的Java类1.2、spring配置文件1.3、测试1.4、运行结果二、c命名空间2.1、编写一个普通的Java类2.2、spring配置文件2.3、测试2.4、运行结果总结前言 P命名空间注入: 目的:简化set方法注入 使用p命名空间注入的…

C++ 哈希表的总结与例题

文章目录CSTL哈希表设计哈希集合设计哈希映射哈希集合例题一:只出现一次的数字例题二:快乐数哈希映射例题一:两数之和例题二:两个列表的最小索引总和例题三:字符串中的第一个唯一字符设置键例题一:字母异位…

安全进阶:虚拟防火墙基础实验

实验拓扑 网络拓扑及IP编址如上图所示; 实验需求 PC2与Server2属于一个敏感的业务,这个业务的流量要求与防火墙上的其他流量完全隔离,使用虚拟防火墙技术实现这个需求; PC2要求能够访问Server2;PC2属于Trust域&#…

Exception in thread “main“ java.lang.UnsupportedOperationException解决办法

1.首先报错UnsupportedOperationException 是因为我们用的是 List<Integer> list1 Arrays.asList(2, 3, 5);这个方式获取的集合,该集合底层没有重写一些方法,所以报错 解决方案 定义新集合接收上一步的数据,然后用新集合来操作就行 package day01;import java.util.A…

元数据管理-解决方案调研二:元数据管理解决方案——Saas/内部解决方案(1)

Saas/内部解决方案 2.1、Data Galaxy 地址&#xff1a;The 360 Data Catalog for datagovernance - DataGalaxy 特点&#xff1a;实现数据治理最佳方式 1、理解业务数据并可以共享通用定义&#xff1b;即由团队成员共同维护定义业务术语词汇的知识库 2、统一企业数据字典&…

DolphinDB Python API 离线安装教程

出于安全考虑&#xff0c;通常生产环境与互联网隔离&#xff0c;因此无法使用 pip install 在线安装 DolphinDB Python API&#xff08;以下简称 Python API&#xff09;。本文介绍如何离线安装 Python API 环境&#xff0c;包括 conda 环境和 wheel 安装两种方式。用户可根据生…

RobotFramework 接口测试实战落地

目前我在负责一个APP的测试工作。在项目中使用 RobotFramework作为工具搭建接口自动化框架&#xff0c;进行接口自动化的工作。 本文将从我个人对接口测试和自动化框架的理解以及RobotFramework在实际项目中落地两个大方面进行讲解。 对接口测试的理解 浅谈接口自动化框架 …

图片批量转为PDF怎么转?这些方法亲测实用

你们平时在整理照片的时候&#xff0c;有把多张图片转为PDF文件的需求吗&#xff1f;我因为工作需要&#xff0c;会拍摄和存储很多照片&#xff0c;而且经常需要将这些照片归类&#xff0c;整合到一个PDF文件中。可能有的小伙伴还不知道多张图片转PDF怎么转&#xff1f;别着急&…

2022全球智慧城市大会 升哲科技:以人为核心推动智慧城市建设

11 月 15 日 至 16 日&#xff0c;“全球智慧城市大会 成都”在成都召开。此次会议主题为“人民 激活 城市”&#xff0c;与“全球智慧城市大会 巴塞罗那”同期举办&#xff0c;采用线上与线下结合模式&#xff0c;链接全球 80 多个国家 600 多座城市参会代表。升哲科技&am…

三冲IPO的思派健康如何承载腾讯的互联网医疗梦?

腾讯在互联网医疗领域的“大将”思派健康10月27日向港交所主板递交第三次上市申请&#xff0c;在2021年8月6日和2022年2月25日两次“折戟”港交所后&#xff0c;此次能否如愿以偿仍未可知。 我国当前正步入老龄化社会&#xff0c;慢性病人口增加&#xff0c;市场对医疗健康方面…

2000年-2020年31省市城乡收入差距泰尔指数

2000年-2020年31省市城乡收入差距泰尔指数 1、来源&#xff1a;统计NJ和各省NJ 2、时间区间为2000-2020年 3、指标包括&#xff1a;居民人均可支配收入、城镇家庭可支配收入、农村家庭可支配收入、总人口、城镇化率、城镇总人口、农村总人口、城镇总收入、农村总收入、总收…

CAS:73342-16-2,Azide-PEG-Hydroxy,N3-PEG-OH,叠氮PEG羟基

化学试剂叠氮-聚乙二醇-羟基&#xff0c;其英文名为Azide-PEG-Hydroxy&#xff0c;N3-PEG-OH&#xff0c;它所属分类为Azide PEG Hydroxyl PEG。 叠氮PEG羟基的分子量均可定制&#xff0c;有&#xff1a;叠氮-PEG 3400-羟基、N3-PEG 2000-OH、N3-PEG 1000-OH、叠氮-聚乙二醇 1…

17.Redis系列之快照RDB方式持久化

本文学习redis两大持久化技术之一&#xff1a;RDB&#xff08;redis database&#xff09;快照方式持久化备份与还原&#xff0c;以及RDB方式的优缺点 1. RDB相关配置 首先我们先简单了解下Redis7中RDB相关配置 // save <seconds> <changes> [<seconds> &…

Python理论之一 —— 数据读写

文章目录1. Excel1.1 openpyxl 模块1.1.1 打开表格、读取/获取信息1.1.1.1 打开表格、获取表格内sheet名&#xff1a;1.1.1.2 根据sheet名获取工作表1.1.1.3 获取表格的尺寸大小&#xff1a;尺寸大小指excel表格中的数据有几行几列1.1.1.4 获取表格内某个格子的数据&#xff1a…

电影《扫黑行动》观后感

上周看了电影《扫黑行动》&#xff0c;讲述三年扫黑除恶专项行动中的一个具体事件。 记得前几年&#xff0c;估计你也听过类似新闻&#xff0c;就是大学贷&#xff0c;学生贷等等系列&#xff0c;面向学生的贷款&#xff0c;借钱的人明知道&#xff0c;学生一般是没有偿还能力的…

在家每次开门都安心,在外也能芝麻开门——云米AI智能门锁Super 2体验

很多人都遇到过出门忘带钥匙的尴尬&#xff0c;好在如今有了智能门锁这种看家好工具&#xff0c;既可以通过密码、指纹等多种方式轻松开锁&#xff0c;又可以随时通过手机APP来查看异常情况&#xff0c;确实是现在居家必备的好东西。这个月我也把家里大门上不太好用的老锁&…

IPWorks WebSockets Delphi版

IPWorks WebSockets Delphi版 IPWorks WebSocket包括一组功能强大的组件&#xff0c;用于将WebSocket通信功能集成到Web、桌面和移动应用程序中。这些组件非常适合构建需要实时数据的Web连接应用程序&#xff0c;包括聊天、多人游戏、实时金融应用程序等。 IPWorks WebSockets功…

Linux18 ---进程和线程、线程实现方法、线程的使用接口、多线程代码实现、线程并发运行

一、进程和线程&#xff1a; 1、进程和线程的相关概念&#xff1a; 进程&#xff1a;是一个正在运行的程序&#xff0c;是个动态的概念。一个进程可以实现多个线程。 线程&#xff1a;是进程内部的一条执行路径或称为执行序列&#xff0c;不同平台下线程的实现机制不相同&am…

基于Android车载系统模块资料

在从事车载Android应用开发前&#xff0c;必须要对汽车座舱的基本结构有一个大体的认知&#xff0c;只有意识到汽车座舱是一种与手机完全不同的架构&#xff0c;才能更好的助力我们日后学习车载Android应用的开发。下面就来介绍一个比较主流的车载操作系统架构。 注意&#xff…

Unity实现一个可扩展的UGUI无限滑动列表控件

采用 缓存池存储布局坐标 实现的一个可横向或纵向滑动的无限滑动列表 Demo展示&#xff1a; 功能支持&#xff1a; 可以满足大部分如背包&#xff0c;商店商城&#xff0c;工具栏&#xff0c;任务栏窗口等列表功能 支持整个列表刷新或单个对象刷新支持横向多行滑动&#xff…