我们在工作中,经常用到各自各样的mq消息队列中间件,今天我们来学习一下为什么需要用消息队列,用了对我们的好处是什么?
现在的系统都是拆分成多个模块,模块直接需要相互调用来完成协作。比如商城系统,用户下单时,需要跟订单系统,库存系统,物流系统等多个系统打交道。而且后续还需要添加更多的系统。
这样会导致两个问题
引入mq消息中间件后 用户下订单后,订单系统发送下单成功消息到mq就返回响应给用户了,其他系统通过订阅消息topic来消费消息,执行各自的业务逻辑。
这样引入了消息队列中间件之后,就和其他系统解耦了。
系统由多个模块组成时,用户一个请求,往往需要调用多个模块才能返回响应。这样会导致用户响应变慢。如下图,调用方式如果是同步的,用户需要等待16s才能得到响应结果。
引入了mq中间件后 请求A系统+投递消息到消息队列约1s,B系统和C系统异步消费mq消息,这样可以大大缩短响应时间,提高系统的吞吐量,性能可以大大的提高。
我们在搞秒杀活动时,往往会影响大量的用户同时请求下单,这样如果超过了订单系统的可承受访问,就会把系统压垮,导致用户无法下单。
引入了mq中间件后 用户请求先生产消息,发送到mq,由订单系统消费mq消息,来处理用户下单请求,下单请求完成时,通过短信方式通知用户。
引入mq中间件后
后面我们再来学习消息队列是怎么实现这些功能的。