RabbmitMQ基础
1.1 什么是MQ
MQ(Message Queue),从字面意思看,本质是个队列,FIFO先入先出,队列中存放的是message。是一种跨进程的通信机制,用于上下游传递消息。在互联网架构中,MQ是一种非常常见的上下游“逻辑解耦+物理解耦”的消息通信服务。使用MQ之后,消息发送的上游只需要依赖MQ,不再依赖其它服务。
1.2 MQ的应用场景
1.流量消峰
订单系统一秒最多处理1万次请求,当高峰期请求达到2万次每秒的时候,如果不使用消息队列,就需要采取拒绝策略,限制用户下单。如果使用消息队列做缓冲,可以把多出的无法处理的请求缓存在消息队列中,这样就可以把一秒内下单的订单分散成一段时间来处理,这时有些用户可能在下单十几秒后才能收到下单成功的操作,但是比不能下单的体验要好。
2.应用解耦
以电商应用为例,应用中有订单系统、库存系统、物流系统、支付系统。用户创建订单后,如果耦合调用库存系统、物流系统、支付系统,如何一个子系统出现故障,都会造成下单操作异常。当转变成基于消息队列的方式后,系统间调用的问题会减少很多,比如物流系统发生故障,需要几分钟来修复,在这几分钟中,物流系统需要处理的内容被缓存在消息队列中,用户的下单操作可以正常完成。当物流系统恢复后,继续处理订单信息即可,中间用户感受不到物流系统的故障,提升系统的可用性。
3.异步处理
有些服务间调用是异步的,例如A调用B,B需要花费很长时间执行,但是A需要知道B什么时候可以执行完,以前一般有两种方式,A过一段时间去调用B的查询api获取执行结果,或者A提供一个回调api,B执行完之后调用回调api同A。这两种方式都增加了A和B的额外接口开发,使用消息队列后,可以优雅的解决这个问题,A调用B服务后,只需要监听B处理完成的消息,当B处理完成后,会发送一条消息到MQ,MQ会将此消息转发给A,A就可以及时地得到异步处理成功的消息。