聊聊mq的使用场景
mq的作用
- 通过异步方式对系统解耦
- 增加系统的并发处理能力
通过异步方式对系统解耦
以用户注册为例,一般情况下:
分下一下,上面过程存在的一些问题:
- 注册过程会调用4个服务(注册服务、邮件服务、短信服务、积分服务),服务之间依赖性太强,任何一个服务不可用,直接影响整个注册业务
- 接口耗时太长,每个服务耗时100ms,注册流程耗时400ms
- 对用户来说,用户信息入库是主要的业务流程,其他并不是响应用户过程中直接关注的逻辑,可以异步进行处理
采用mq的方式实现:
过程:
- 调用注册服务,注册信息入库,耗时100ms
- 投递注册消息到mq
- 返回注册成功
- 对于用户来说耗时200ms
- 其他3个操作(发邮件、发短信、增加积分)从消息队列中拉取消息进行处理,对于主流程来说是异步操作
将依赖于3个服务转换为只依赖于mq服务,只需要保证注册服务、mq服务高可用,即可以保证注册服务的高可用,相比保证其他3个服务高可用上容易了许多。
增加系统的并发处理能力
以电商中的秒杀场景为例,采用同步处理:
- 用户点击秒杀
- 调用订单服务,验证库存、锁定库存
- 跳转到支付页面进行支付
分析一下,存在的问题:
- 验证库存、锁定库存会访问数据库
- 秒杀场景,商品数量有限,请求量非常大,每个请求来了都做以上处理,直接会把数据库压垮,导致数据库无法对外提供服务,数据库的不可用直接导致整个业务的不可用,秒杀活动打水漂。
- 大量请求会同时到达,同时去访问数据库,数据库连接有限,导致很多请求会处于等待状态,导致并发性能急剧下降
- 大量用户同时操作库存,存在争抢数据库锁的情况,容易导致死锁
- 秒杀中数量一般是有限,大量用户抢购,其实最终只有很少的用户能够抢购到
大家都有在银行办理业务的经验,银行处理业务的流程:领号、排队、等待叫号办理业务。
秒杀中我们也可以参考银行办理业务的流程:
- 用户点击描述
- 系统接受到用户请求后,生成一个唯一的编号,然后投递一条消息(秒杀下单)到mq
- 响应用户:秒杀正在处理中
- 秒杀系统从mq中拉取消息进行处理,处理完成之后告知用户,这步操作对于用户来说是异步处理的过程
从上面可以看出,从接受用户请求到响应用户请求,未访问数据库,只有生成编号和发送消息的操作,这部分处理速度是非常快的,不存在性能的问题,数据库也不存在压力的问题了,所有用户的请求都被作为一条消息投递到mq进行异步处理;从而解决了秒杀中同步处理遇到的各种问题。
其他一些使用场景
- 系统日志的处理
系统手机日志,异步发送到mq,日志服务队从mq中拉取消息进行各种处理,关于这个以后我们会专门讨论。 - 通过事件驱动的一些业务,也可以使用mq实现
- 分布式事务中,使用异步消息,达到最终一致性,这个后面会专门介绍
总结
- mq是采用异步的方式来解决系统耦合性的问题,并发处理的问题;重点是在于异步,那么什么情况下使用异步呢?当调用方不强依赖于被调用方的结果的时候,可以采用异步的方式进行处理,此时可以使用mq。
- 当调用方强依赖于被调用方的结果的时候,需要使用同步的方式,不能使用mq
mq系列整个内容,我们将讨论:
- mq的使用场景
- 业务系统中投递消息的几种方式?
- 如何确保投递消息一定成功?
- 消息消费的几种方式
- 如何确保消息至少消费一次
- 如何保证消息消费的幂等性
路人甲Java,只生产干货,公众号:javacode2018
,喜欢的关注一下。
低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。
持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。
转载内容版权归作者及来源网站所有,本站原创内容转载请注明来源。
- 上一篇
坚持探索与落地并重,阿里巴巴云原生之路全景揭秘
阿里妹导读:阿里云已经成功地规模化落地云原生,26日的 KubeCon 大会上,CNCF TOC 和阿里云资深技术专家李响发表主题演讲,分享了阿里巴巴在规模扩展、可靠性、开发效率、迁移策略等方面的经验,并探讨云原生的落地及应对若干技术挑战。 为什么要做云原生?云原生究竟能带来什么价值?从最初的独自摸索到如今拥抱开源回馈社区,阿里巴巴走过了怎样的云原生旅程?又有哪些技术心得?今天,将全部分享出来。 多年沉淀,坚持探索与落地并重 阿里巴巴从2011年开始通过容器实践云原生技术体系,在整个业界都还没有任何范例可供参考的大背境下,逐渐摸索出了一套比肩全球一线技术公司并且服务于整个阿里集团的容器化基础设施架构。这个探索历程虽然孤独,但却被始终如一的坚持至今。这正是在这个孤注一掷的技术探索与奋进的过程中,阿里巴巴的技术团队完整的经历了云原生技术浪潮
- 下一篇
聊聊业务系统中投递消息到mq的几种方式
背景 电商中有这样的一个场景: 下单成功之后送积分的操作,我们使用mq来实现 下单成功之后,投递一条消息到mq,积分系统消费消息,给用户增加积分 我们主要讨论一下,下单及投递消息到mq的操作,如何实现?每种方式优缺点? 方式一 step1:start transactionstep2:生成订单step3:投递消息到mqstep4:commit transaction 这种方式是将发送消息放在了事务提交之前,可能存在的问题: step3发生异常 导致step4失败,下单失败,直接影响到下单业务 step4发生异常,其他step成功 下单失败,消息投递成功,给用户增加了积分 方式二 我们将发送消息放到事务之后进行:step1:start transactionstep2:生成订单step3:commit transactionstep4:投递消息到mq 可能会出现的问题:step4发生异常,其他step成功 导致下单成功,投递消息失败,用户未增加积分 上面两种是比较常见的做法,也是最容易出错的。 方式三 step1:start transactionstep2:生成订单step3:本地库中...
相关文章
文章评论
共有0条评论来说两句吧...
文章二维码
点击排行
推荐阅读
最新文章
- CentOS8安装Docker,最新的服务器搭配容器使用
- Docker安装Oracle12C,快速搭建Oracle学习环境
- CentOS7设置SWAP分区,小内存服务器的救世主
- SpringBoot2全家桶,快速入门学习开发网站教程
- CentOS8编译安装MySQL8.0.19
- Docker使用Oracle官方镜像安装(12C,18C,19C)
- CentOS7编译安装Gcc9.2.0,解决mysql等软件编译问题
- CentOS关闭SELinux安全模块
- CentOS6,7,8上安装Nginx,支持https2.0的开启
- CentOS7编译安装Cmake3.16.3,解决mysql等软件编译问题