前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >面试官竟然问我为啥要用消息队列,幸亏我看了参考答案

面试官竟然问我为啥要用消息队列,幸亏我看了参考答案

原创
作者头像
一灯架构
发布2022-09-16 18:10:03
2660
发布2022-09-16 18:10:03
举报
文章被收录于专栏:Java高频面试题Java高频面试题

互联网公司的项目没有不用到MQ(消息队列)的,在简历中写上项目中用到MQ,也算是亮点之一。既然你写了,面试官就会问,你对MQ到底了解多少?

一个挺着啤酒肚,身穿格子衫,发际线严重后移的中年男子,手拿着保温杯,胳膊夹着MacBook向你走来。

面试官:小伙子,我看你简历上写了,在项目中用到了MQ,你们项目为什么要引入MQ?

内心闪过一万匹马,引入MQ是我能决定的吗? CTO让我们用,我们就用了呗! 虽然事实是这样,但是如果这样直接回答,肯定让你回去等通知了。

其实这道题就是让你回答MQ的作用是什么?

MQ的作用就三个:解耦、异步、削峰。 如果你直接回答这三个作用,会给面试官一种死记硬背的嫌疑,所以要结合实际项目具体分析。

1. 解耦

面试官你好,我们公司是做电商系统的。核心是交易服务,交易服务要调用另外三个服务,订单服务、库存服务、仓储服务。

图片1.png
图片1.png

这三个服务如果有一个服务不可用,交易服务就无法正常运行,所以交易服务是强耦合另外三个服务。

引入MQ之后,交易服务只跟MQ交互,把消息发到MQ里面就行了,无需关心另外三个服务是否可用。这时候交易服务跟另外三个服务就是弱耦合的关系,耦合性被降低了。

哪怕是另外三个服务暂时不可用,也不影响交易服务的运行,只要其他服务运行起来后,把MQ里面的消息消费了就行。

图片2.png
图片2.png

2. 异步

没有引入MQ的时候,交易服务需要同步调用三个服务,如果调用一个服务需要耗时1秒,那么同步调用三个服务需要耗时3秒。在引入MQ之后,全都改成了异步调用,整个耗时不到1秒,大大提高了接口的性能。

3. 削峰

如果一秒内同时来了5000笔交易,而订单服务每秒只能处理100笔交易,那么后面的4900笔交易失败。在引入MQ之后,交易服务可以把交易数据先发送到MQ中,而订单服务再慢慢从MQ拉取交易信息处理。从而避免突发流量压垮服务器。

面试官: 小伙子,有点东西。看来准备的很充分啊,那你知道引入MQ有什么坏处吗?MQ不可能全是优点吧?

当然。我觉得引入MQ之后,会有以下三个坏处。

1. 系统可用性降低

本来整个系统有四个服务,我们只需要保证这四个服务可用就行了。现在又多引入了一个MQ,我们还要保证MQ的可用,所以整个系统的可用性降低。

2. 系统复杂性提高

本来交易服务是同步调用另外三个服务,如果另外三个服务不可用,交易服务能立即感知到。引入MQ之后,整个系统的稳定性就要靠MQ保证了。

这时候,我们就要考虑到发到MQ里面的消息怎么避免丢失的问题

顺序性消费的问题,就是同一笔交易的下单消息应该比撤单消息先处理。

重复性消费的问题,就是同一笔下单交易的消息可能被多次处理。

当然,每种问题都有具体的解决方案,

避免消息丢失可以使用MQ集群,

顺序性消费可以把消息发到同一个分区,

重复性消费可以在消费端做幂等性处理。这里不做详细阐述,

以后再讲一下每种MQ不同的具体实现方式。

3. 数据一致性问题

当服务间是同步调用的时候,我们还可以使用本地事务来控制数据的一致性。但是引入MQ之后,服务间的调用都是异步了,就没办法使用本地事务,也就无法做到数据的强一致性了。

例如,调用订单服务下单成功了,但是调用库存服务扣减库存失败,就会导致超卖,是严重的线上事故。

这时候怎么办?可以使用MQ事务消息,相当于是同步调用,会严重降低性能。 还可以使用分布式事务,可以实现数据的最终一致性,无法做到强一致性。

面试官内心竖起大拇指,小伙子可以啊,明天就来上班吧!

我在上家公司的工作还没交接完成,要不再等两周吧?

是不是嫌工资开得低了,我这就让HR加薪,明天一定要来。

图片3.jpeg
图片3.jpeg

原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。

如有侵权,请联系 cloudcommunity@tencent.com 删除。

原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。

如有侵权,请联系 cloudcommunity@tencent.com 删除。

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • 1. 解耦
  • 2. 异步
  • 3. 削峰
  • 1. 系统可用性降低
  • 2. 系统复杂性提高
  • 3. 数据一致性问题
相关产品与服务
消息队列 CMQ 版
消息队列 CMQ 版(TDMQ for CMQ,简称 TDMQ CMQ 版)是一款分布式高可用的消息队列服务,它能够提供可靠的,基于消息的异步通信机制,能够将分布式部署的不同应用(或同一应用的不同组件)中的信息传递,存储在可靠有效的 CMQ 队列中,防止消息丢失。TDMQ CMQ 版支持多进程同时读写,收发互不干扰,无需各应用或组件始终处于运行状态。
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档