异步调用方式其实就是基于消息通知的方式,一般包含三个角色:
● 消息发送者:投递消息的人,就是原来的调用方
● 消息Broker(消息代理/消息中间件):管理、暂存、转发消息,你可以把它理解成微信服务器
● 消息接收者:接收和处理消息的人,就是原来的服务提供方
在异步调用中,发送者不再直接同步调用接收者的业务接口,而是发送一条消息投递给消息Broker。然后接收者根据自己的需求从消息Broker那里订阅消息。每当发送方发送消息后,接收者都能获取消息并处理。
这样,发送消息的人和接收消息的人就完全解耦了。
消息Broker,目前常见的实现方案就是消息队列(MessageQueue),简称为MQ.
AI:消息队列的应用场景
- 异步处理:
a. 场景: 当应用程序需要执行耗时的操作(如发送电子邮件、文件上传或下载等)时,可以将这些任务发送到消息队列中,由专门的任务处理程序异步执行。
b. 好处: 减少了用户的等待时间,提高了用户体验。 - 解耦:
a. 场景: 当一个系统由多个组件组成时,这些组件之间可以使用消息队列进行通信。
b. 好处: 单个组件的变化不会直接影响到其他组件,提高了系统的可扩展性。 - 流量削峰
a. 场景:在许多互联网应用和服务中,尤其是那些具有明显周期性流量特征的应用(如电商平台、社交网络等),常常会遇到流量突增的情况。例如,在电商促销期间,大量的用户会在短时间内访问网站并提交订单,这种短时间内产生的巨大流量可能会导致服务器过载,影响用户体验甚至导致服务不可用。
b. 好处:当流量激增时接收到请求会被暂时存储在消息队列中,而不是直接发送到后端服务进行处理。这样做可以避免后端服务因为短时间内处理大量请求而过载。后端服务可以从消息队列中按需拉取消息进行处理。这种异步处理机制可以有效地分散流量峰值,确保后端服务的稳定运行。如下图:
目比较常见的MQ实现:
● ActiveMQ:https://activemq.apache.org/
● RabbitMQ:https://www.rabbitmq.com/
● RocketMQ:https://rocketmq.apache.org/
● Kafka:https://kafka.apache.org/
几种常见MQ的对比:
● 追求可靠性:RabbitMQ、RocketMQ
● 追求吞吐(高并发)能力:RocketMQ、Kafka
● 追求消息低延迟:RabbitMQ、Kafka
这四种的MQ在市场都是非常流行,本课程讲解RabbitMQ。
Spring Boot默认支持AMQP协议,RabbitMQ支持AMQP协议 。