zoukankan      html  css  js  c++  java
  • [转] 聊聊mq的使用场景

    MQ的作用

    • 通过异步方式对系统解耦
    • 增加系统的并发处理能力

    通过异步方式对系统解耦

    以用户注册为例,一般情况下:

    分下一下,上面过程存在的一些问题:

    注册过程会调用4个服务(注册服务、邮件服务、短信服务、积分服务),服务之间依赖性太强,任何一个服务不可用,直接影响整个注册业务
    接口耗时太长,每个服务耗时100ms,注册流程耗时400ms
    对用户来说,用户信息入库是主要的业务流程,其他并不是响应用户过程中直接关注的逻辑,可以异步进行处理

    采用MQ的方式实现:

    过程:

    • 调用注册服务,注册信息入库,耗时100ms
    • 投递注册消息到MQ
    • 返回注册成功
    • 对于用户来说耗时200ms
    • 其他3个操作(发邮件、发短信、增加积分)从消息队列中拉取消息进行处理,对于主流程来说是异步操作

    将依赖于3个服务转换为只依赖于MQ服务,只需要保证注册服务、MQ服务高可用,即可以保证注册服务的高可用,相比保证其他3个服务高可用上容易了许多。

    增加系统的并发处理能力

    以电商中的秒杀场景为例,采用同步处理:

    • 用户点击秒杀
    • 调用订单服务,验证库存、锁定库存
    • 跳转到支付页面进行支付

    分析一下,存在的问题:

    • 验证库存、锁定库存会访问数据库
    • 秒杀场景,商品数量有限,请求量非常大,每个请求来了都做以上处理,直接会把数据库压垮,导致数据库无法对外提供服务,数据库的不可用直接导致整个业务的不可用,秒杀活动打水漂。
    • 大量请求会同时到达,同时去访问数据库,数据库连接有限,导致很多请求会处于等待状态,导致并发性能急剧下降
    • 大量用户同时操作库存,存在争抢数据库锁的情况,容易导致死锁
    • 秒杀中数量一般是有限,大量用户抢购,其实最终只有很少的用户能够抢购到
      大家都有在银行办理业务的经验,银行处理业务的流程:领号、排队、等待叫号办理业务

    秒杀中我们也可以参考银行办理业务的流程:

    • 用户点击描述
    • 系统接受到用户请求后,生成一个唯一的编号,然后投递一条消息(秒杀下单)到MQ
    • 响应用户:秒杀正在处理中
    • 秒杀系统从MQ中拉取消息进行处理,处理完成之后告知用户,这步操作对于用户来说是异步处理的过程

    从上面可以看出,从接受用户请求到响应用户请求,未访问数据库,只有生成编号和发送消息的操作,这部分处理速度是非常快的,不存在性能的问题,数据库也不存在压力的问题了,所有用户的请求都被作为一条消息投递到MQ进行异步处理;从而解决了秒杀中同步处理遇到的各种问题。

    其他一些使用场景

    • 系统日志的处理
      系统手机日志,异步发送到MQ,日志服务队从MQ中拉取消息进行各种处理,关于这个以后我们会专门讨论。
    • 通过事件驱动的一些业务,也可以使用MQ实现
    • 分布式事务中,使用异步消息,达到最终一致性,这个后面会专门介绍

    总结

    • MQ是采用异步的方式来解决系统耦合性的问题,并发处理的问题;重点是在于异步,那么什么情况下使用异步呢?当调用方不强依赖于被调用方的结果的时候,可以采用异步的方式进行处理,此时可以使用MQ。
    • 当调用方强依赖于被调用方的结果的时候,需要使用同步的方式,不能使用MQ

    MQ系列整个内容,我们将讨论:

    【转载自:原文地址

  • 相关阅读:
    课程一(Neural Networks and Deep Learning),第一周(Introduction to Deep Learning)—— 1、经常提及的问题
    递归、字节流、文件复制_DAY20
    IO概述、异常、File文件类_DAY19
    某书2018笔试题之薯券
    某书2018笔试题之翻转数字
    某书2018笔试题之字符串中最大子数字串
    批量发货的启示
    为什么易燥易怒以及柔润相处的练习
    编程漫谈(十五):编程与软件开发
    使用函数式编程消除重复无聊的foreach代码(Scala示例)
  • 原文地址:https://www.cnblogs.com/eedc/p/12851222.html
Copyright © 2011-2022 走看看