MQ的作用
- 消息通信
MQ的基础功能即为消息通信。使用MQ的客户端可以将消息发送到MQ中，也可以从MQ中消费消息。 - 异步处理
MQ作为一个数据传输的通道，可以将消息传输异步化。生产者将消息生产放入MQ中，可以继续生产其他消息，不要求获得消费者的消费信号之后再生产。
MQ也可以将RPC异步化。传统的RPC直接调用，可以转化为调用方生产消息，将原本RPC请求的内容放在消息体中，然后由RPC的被调用方去消费消息并进行处理。如果有返回结果，可以将结果再通过另外一个队列发送给调用方。 - 应用解耦
以订单系统和库存系统为例，用户下单后，订单系统需要通知库存系统。
传统模式中，假如库存系统无法访问，则订单减库存将失败，从而导致订单失败。 订单系统与库存系统耦合。
引入MQ，用户下单后，订单系统：完成持久化处理，将消息写入消息队列，返回用户订单下单成功；库存系统：订阅下单的消息，采用拉/推的方式，获取下单信息，库存系统根据下单信息，进行库存操作。他们直接交互的只有MQ服务，从而实现应用解耦。 - 削峰控流
在一些应用场景中，经常出现某种消息流量激增的情况，比如秒杀活动中的用户请求。这种情况下，下游业务可能来不及处理导致整个服务崩溃。引入MQ后，流量激增的消息可以缓存入队列中，下游业务缓慢消费，尽管有一定的延迟，但能保证整体服务稳定运行。
网友评论