项目里接入了MQ消息中间件以后,我摸鱼的时间更长了~

news2024/11/27 10:34:05
V-xin:ruyuanhadeng获得600+页原创精品文章汇总PDF

一、前情回顾

之前给大家聊了一下,面试时如果遇到消息中间件这个话题,面试官上来可能问的两个问题:

  • 你们的系统架构中为什么要引入消息中间件?
  • 系统架构中引入消息中间件有什么缺点?

关于这两个问题的回答,可以参见之前的两篇文章:

  • 《 做了几年开发,你知道自己的系统为什么要用消息中间件吗?》
  • 《 别冒冒失失在项目里用MQ,里面很多坑都不知道肯定不行!》

在问完这两个问题之后,不同风格的面试官可能会展开不同的发问。

针对那种工作年限比较长的资深的同学,可能会开始就候选人所在公司使用的消息中间件,深入里面的技术细节,比如让你聊聊RocketMQ的架构原理和核心源码?

但是另外一种面试风格,会先从你们的项目和业务入手进行考察,比如像下面这样:

  • 消息中间件在你们生产项目里具体是哪个业务场景下落地的?
  • 这个业务场景有什么技术挑战?
  • 为什么必须要在这个业务场景里用消息中间件技术?
  • 具体使用消息中间件的时候是怎么来用的?

好!这篇文章,咱们从第二种风格来聊聊。


二、业务场景介绍

我们会落地到某个具体业务系统的某个场景下,看看如何使用消息中间件,然后其效果是什么。

业务场景的话,咱们就用大家都很熟悉的电商业务为例,这里为了便于理解,对其做了一定的抽象和简化。

大家还是来考虑一个下订单的业务流程,比如你下个订单,此时需要干几件事情:

  1. 更新订单状态为“待发货”(耗时20ms)
  2. 扣减商品库存(耗时100ms)
  3. 增加会员积分(耗时80ms)
  4. 附赠优惠券(耗时50ms)
  5. 仓储调度发货(耗时几十秒)。

说明一下:上述环节,为了便于大家理解,做了简化。实际真正复杂的电商系统里,整体环节和业务流程会比这个复杂很多倍,而且耗时也绝对不是上面那么简单的。

老规矩!我们还是通过一张手绘图,来看看这整个的业务流程:

在这里插入图片描述

如上图,这个下订单的业务流程中:

更新订单状态(20ms) + 扣减商品库存(100ms) + 增加会员积分(80ms) + 附赠优惠券(50ms) = 250ms。

也就是说,仅仅是这4个流程的话,也就200多毫秒的耗时。

200多毫秒的耗时,对用户下单体验来说是非常快速的,几乎就是一瞬间就完成了,不会感到过多的停顿,也就是一下子就可以看到自己下单成功了。

但是,如果加上那个调度仓储发货呢?

那个环节需要读取大量的数据、使用多仓库/多货位的调度算法、还要跟C/S架构的仓储系统进行网络通信,因此我们这里假设这个环节可能会耗时数十秒。

一旦加上那个调度仓储发货的环节到这个下单流程里,就可能导致用户要等页面卡顿几十秒后才会看到下单成功的提示,这个用户体验就相当的差了。

按照之前一篇文章《为什么要使用MQ消息中间件?这几个问题必须拿下!》的说法。对于这种场景,完全适合使用消息中间件来进行异步化调用。

也就是说,订单服务对仓储调度发货,仅仅是发送一个消息到MQ里,然后仓储服务消费消息之后再慢慢的执行调度算法,然后分配商品发货任务给对应的仓库即可。

这样的话,就可以把耗时几十秒的仓储调度发货的环节,从下单流程里摘除出去了。进而保证下单流程就仅仅是耗时200多毫秒而已。

至于那个耗时几十秒的仓储调度发货环节,我们通过异步的方式慢慢执行即可,不会影响用户下单的体验。

以上过程,我们同样来一张图,大家直观的感受一下:

在这里插入图片描述

三、初步落地

好!接下来我们就假设大家在实际生产中还没用过消息中间件,咱们从0开始,看看如何落地?

对于已经在生产中使用过消息中间件的小伙伴,不妨也看看,权当复习,温故知新!

我们以RabbitMQ为例,假如你用的消息中间件是RabbitMQ,那么我们对这个消息中间件应该如何安装和部署呢?

很简单,RabbitMQ的官方文档里提供了非常详细的安装部署步骤,你可以在自己的笔记本电脑本地安装,也可以在公司的服务器上部署。

现在假设你已经参考了官方文档并安装完成,那么接下来在代码层面应该怎么来引入RabbitMQ以及在系统里实现收发消息呢?

下面通过一些HelloWorld级别的代码和一些简单的示例图,给大家演示一下RabbitMQ是如何收发消息的。

对于很多在实际生产中使用过MQ的同学,这些代码可能对实际生产中使用过MQ的同学,显得太简单了。

不过考虑到很多初学者可能连用都没有用过MQ,甚至是才听说消息中间件不久,所以笔者认为这些demo代码以及手工绘图,还是很有必要。

在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

好!看完了代码,这个时候,我们可以通过一张图来想象一下两个服务之间的通信。

订单服务你可以启动多个,不同的订单服务都可以往一个RabbitMQ的queue里推送消息。

仓储服务你也可以启动多个,多个仓储服务会采用round-robin的轮询算法,每个服务实例都可以从RabbitMQ queue里消费到一部分的消息。

在这里插入图片描述

上面的图里,订单服务在MQ专业术语中叫做“生产者”,英文是“Producer”,意思就是这个服务是专门负责生产消息投递到MQ的。

仓储服务在MQ专业术语中叫做“消费者”,英文是“Consumer”,意思就是这个服务专门是负责从MQ消费消息然后处理的。

这个时候,这套异步通信的架构就可以跑起来了。

好了,到目前为止,虽然这个代码还存在不少问题,但是没关系,大体上我们已经给一些不太熟悉MQ技术的同学,从一个比较形象易于理解简化后的电商业务场景出发,通过HelloWorld级别的示例代码和手工绘图,将MQ这个技术落地跑起来了。

更进一步,各位同学完全可以参照这个文章里的案例,思考一下:自己负责的项目里,有没有类似的业务场景可以使用MQ的?

然后想办法在自己的项目里落地使用MQ的技术来做一下异步化,提升核心流程的性能。

这样未来在跳槽面试的时候,才可以做到游刃有余,有自己的一套东西可以说。

V-xin:ruyuanhadeng获得600+页原创精品文章汇总PDF

另外推荐儒猿课堂的1元系列课程给您,欢迎加入一起学习~

互联网Java工程师面试突击课(1元专享)

SpringCloudAlibaba零基础入门到项目实战(1元专享)

亿级流量下的电商详情页系统实战项目(1元专享)

Kafka消息中间件内核源码精讲(1元专享)

12个实战案例带你玩转Java并发编程(1元专享)

Elasticsearch零基础入门到精通(1元专享)

基于Java手写分布式中间件系统实战(1元专享)

基于ShardingSphere的分库分表实战课(1元专享)

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

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

相关文章

零跑汽车股价终于盼来了期望

近期零跑股价上涨,给其它汽车产业带来了危机。9月29日,零跑汽车作为第四位登陆港股的新势力车企,终于胜利敲钟。但是,紧接着等待零跑的却是刷新新势力纪录的开盘破发。 继开盘首日暴跌33%之后,9月30日收盘,…

Linux权限---用户权限切换与文件权限更改(附目录,哪里不懂点哪里)--- 第一期

目录 1. Linux权限的概念 1.1 什么是权限 1.2 所以权限的操作一共分为两类 1.3 Linux中,默认有两类用户 2. root与普通用户切换指令 2.1 如果想从普通用户转为超级用户可以进行下面操作 2.2 如果想从超级用户转为普通用户可以进行下面操作 2.3 禁止来回切换用…

阿里技术官耗时半年总结出“满分”架构笔记,拿捏分布式到微服务

第 1 章:深入理解网络 讲解分布式的基础一-网络, 对国际互联网、NIO、AIO、网络传输中的对象序列化问题、HTTP 的前世今生、TCP/IP、从 CDN 到 SD-WAN 等知识进行深入讲解。 详细章节介绍: 从国际互联网开始 NIO, 一本难念的经 AIO,大道至…

Redis 非关系型数据库

关系型数据库与非关系型数据库 Redis支持的键值数据类型 Redis中文网 2. 哈希类型 hash 删除:hdel key field 3. 列表类型 list:可以添加一个元素到列表的头部(左边)或者尾部(右边) 列表类型相当于队列 4. 集合…

Vue--》vue-router的导航守卫使用讲解

目录 前言 vue-router中编程式导航API 导航守卫 全局守卫 独享路由守卫 组件路由守卫 前言 在浏览器中点击链接实现导航的方式&#xff0c;叫做声明式导航。例如&#xff1a;普通网页中点击<a>链接、vue项目中点击<router-link>都属于声明式导航。 在浏览器…

0基础转软件测试该学些什么?

有很多人员会不断问自己&#xff0c;自己到底要不要学测试&#xff0c;或者要不要转行做测试&#xff0c;测试的职业发展到底怎么样&#xff1f;如果你还在迷茫&#xff0c;在到处找各种大牛问类似的问题&#xff0c;我希望这篇文章&#xff0c;你看完能够结束你的这个烦恼&…

从 0 到 1 搞一个 Compose Desktop 版本的玩天气之踩坑

从 0 到 1 搞一个 Compose Desktop 版本的玩天气之踩坑 大家好&#xff0c;好久不见&#xff0c;接下来一段时间我会系统性地写一套关于 Compose Desktop 的文章&#xff0c;带大家从头到尾写一个桌面版的天气应用&#xff0c;并且打好包让别人也可以进行使用&#xff0c;接下…

java判断选择的日期是否在某个时间区间

效果展示&#xff1a; 具体代码&#xff1a; String startTimeZoom "08:00";//时间区间-开始时间 String endTimeZoom "22:00";//时间区间-结束时间String startTimeChoice "08:00";//时间区间-选择的开始时间 String endTimeChoice "2…

Java中的异常(Exception)

目录 一、什么是异常(Exception)&#xff1f; 二、解决方案&#xff1a;try-catch 三、异常的概念 四、异常的体系图(重点) 小结&#xff1a; 五、常见的五大运行时异常 1、NullPointerException空指针异常 2、ArithmeticException数学运算异常 3、ArrayIndexOutOfBounds…

【MySQL进阶】浅谈InnoDB中的BufferPool

【MySQL进阶】浅谈InnoDB中的BufferPool 文章目录【MySQL进阶】浅谈InnoDB中的BufferPool一、前言——缓存的重要性二、InnoDB的Buffer Pool1&#xff1a;BufferPool 简介2&#xff1a;BufferPool内部组成3&#xff1a;free链表的管理4&#xff1a;flush链表的管理5&#xff1a…

PCA与PCoA

通过分析坐标轴中样本和样本间的距离可看到 2 个样本或 2 组样本间的差异性。若2个样本或2组样本之间的直线距离较近&#xff0c;则表示这2个样本或2组样本差异性较小&#xff1b;相反则表示差异性较大。因此PCA和PCoA 具有直观性(直接看两点之间的距离)和完整性(呈现所有样本)…

spring中i18n国际化处理多语言

前言 在项目中&#xff0c;往往用户会存在多语言的述求&#xff0c;比如说一个系统既有中文的用户&#xff0c;又有英文的用户。怎么来实现多语言呢&#xff1f; 首先前后端分离的项目&#xff0c;前端会有自己的多语言实现方案&#xff0c;大致效果就是&#xff0c;用户切换…

rocketmq源码-pull模式拉取消息、同步拉取消息

前言 上一篇博客&#xff0c;记录的是push模式&#xff0c;异步发送netty请求拉取消息的代码&#xff0c;这篇博客主要记录consumer发送同步netty请求&#xff0c;去拉取消息的逻辑&#xff0c;但是对于同步发送请求&#xff0c;需要结合LitePullConsumer来看 在Lite PullCon…

C语言基础—运算符及优先级

本章主要讲解运算符的优先级和结合顺序 知识点&#xff1a; 运算符分类&#xff0c;记忆了解13种运算符注意运算符的易错点运算符的优先级 运算符及优先级运算符分类❗ 运算符易错不能直接连续判断“< 值 <”关于判断两个浮点数是否相等逻辑表达式&#xff08;布尔型&am…

CSS:border-image

border-image属性对图像的规格和比例比较高&#xff0c;导致使用成本比较高。另外&#xff0c;常见的场景中&#xff0c;大家更倾向于扁平化而不是非拟物化&#xff0c;边框装饰通常在项目中不会出现。 border-image是由多个CSS属性缩写的&#xff0c;比如: border-image-sou…

hc32和stm32 can波特率设置

前言 笔者在调试一款新的mcu的can通信时候&#xff0c;最麻烦的是波特率设置。由于没有弄明白其计算原理&#xff0c;经常出错&#xff0c;且不同的波特率有不同的采样点的要求。浪费了不少时间。这次一次搞明白can波特率的计算公式。 can波特率计算 在ISO 11898-1-2015 标准…

音视频基础概念(2)——音频

目录 1. 基本知识 2.采样率和采样位数 3.音频编码 4. 声道数 5. 码率 6. 音频格式 日常生活中&#xff0c;音视频随处可见&#xff0c;包括视频、音频、编解码、封装容器、音视频等概念。 1. 基本知识 音频数据的承载方式最常用的是脉冲编码调制&#xff0c;即PCM。于…

JAVA面试(2022年Java常见面试问题)

1、谈谈你对Spring中IOC和AOP的理解。 答案&#xff1a; 2、谈谈Spring的bean的创建过程和生命周期。 答案&#xff1a; 3、谈一下JVM的内存分配和垃圾回收机制。 答案&#xff1a; 4、谈一下你使用比较多的设计模式和场景。 答案&#xff1a; 5、谈一些mysql的事务隔离。 …

什么是文件系统?

【推荐阅读】 一文了解Linux上TCP的几个内核参数调优 一文剖析Linux内核中内存管理 分析linux启动内核源码 文件系统是操作系统用于明确存储设备&#xff08;常见的是磁盘&#xff0c;也有基于NAND Flash的固态硬盘&#xff09;或分区上的文件的方法和数据结构&#xff0c;…

传奇列表上传登录器公告小窗口怎么修改

传奇列表上传登录器公告小窗口怎么修改 很多小伙伴不会上传列表&#xff0c;我是艾西今天给大家分享下怎么上传列表 我们开始实操&#xff08;纯教学分享&#xff09; 在我们的网站文件夹里创建一个列表.txt 在浏览器里找一个列表模板例&#xff1a;www.pkp123.cn:88&#xff…