我们在工作中,经常用到各自各样的mq消息队列中间件,今天我们来学习一下为什么需要用消息队列,用了对我们的好处是什么?
一. 解耦
现在的系统都是拆分成多个模块,模块直接需要相互调用来完成协作。比如商城系统,用户下单时,需要跟订单系统,库存系统,物流系统等多个系统打交道。而且后续还需要添加更多的系统。
这样会导致两个问题
- 调用系统太多,订单系统成功了,但是调用物流系统失败,需要多次重试调用该系统直到成功,或者回滚订单系统,返回用户重试,这样导致响应时间长,且系统设计复杂
- 如果后续需要添加更多的系统,需要改造订单系统,不符合系统设计的开闭原则
引入mq消息中间件后
用户下订单后,订单系统发送下单成功消息到mq就返回响应给用户了,其他系统通过订阅消息topic来消费消息,执行各自的业务逻辑。
- 依赖mq消息不丢失,可确保其他系统一定会调用成功,解决了第一个问题;
- 如果需要添加更多系统交互,只需要订阅消息的topic,就能消费下单成功的消息,不需要改动到订单系统,解决了第二个问题。
这样引入了消息队列中间件之后,就和其他系统解耦了。
二.异步
系统由多个模块组成时,用户一个请求,往往需要调用多个模块才能返回响应。这样会导致用户响应变慢。如下图,调用方式如果是同步的,用户需要等待16s才能得到响应结果。
引入了mq中间件后
请求A系统+投递消息到消息队列约1s,B系统和C系统异步消费mq消息,这样可以大大缩短响应时间,提高系统的吞吐量,性能可以大大的提高。
三.削峰填谷
我们在搞秒杀活动时,往往会影响大量的用户同时请求下单,这样如果超过了订单系统的可承受访问,就会把系统压垮,导致用户无法下单。
引入了mq中间件后
用户请求先生产消息,发送到mq,由订单系统消费mq消息,来处理用户下单请求,下单请求完成时,通过短信方式通知用户。
四.小结
引入mq中间件后
- 解耦,这样可以很轻松的接入多个系统,这需要mq消息队列支持,多个系统订阅同一个消息的功能;
- 异步,这样可以大大提高系统的性能,这需要mq消息队列高性能
- 削峰填谷,这样大大提高了系统的高可用,这需要mq消息队列高可用
后面我们再来学习消息队列是怎么实现这些功能的。