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,喜欢的关注一下。
另外有需要云服务器可以了解下创新互联scvps.cn,海内外云服务器15元起步,三天无理由+7*72小时售后在线,公司持有idc许可证,提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案,具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势,专为企业上云打造定制,能够满足用户丰富、多元化的应用场景需求。
网站栏目:聊聊mq的使用场景-创新互联
网页URL:
http://cdkjz.cn/article/djcepo.html