消息服务中间件之概述

客官°小女子只卖身不卖艺 2022-05-17 07:50 197阅读 0赞

# 1、应用场景 #

大多应用中，可通过消息服务中间件来提升系统异步通信、扩展解耦能力。

## 异步处理： ##

a、传统的流程如上，同步执行流程。  
![这里写图片描述][70]  
b、使用多线程改进。  
![这里写图片描述][70 1]  
c、使用消息队列，只需要将消息发布到队列中，相关的消息订阅方即可从队列中取出消息，执行相应操作。  
![这里写图片描述][70 2]

## 应用解耦： ##

![这里写图片描述][70 3]  
![这里写图片描述][70 4]

## 流量削峰： ##

比如秒杀活动，同时有10万个并发访问，我们可以设置消息队列为1万，那么当请求发起时，只需将请求写入消息队列，当消息队列已满时，其余的请求直接回应秒杀不成功的消息，然后队列中的消息再由秒杀业务异步处理即可。  
![这里写图片描述][70 5]

# 2、消息服务中两个重要概念： #

*  `消息代理（message broker）`
 *  `目的地（destination）`

当消息发送者发送消息以后，将由消息代理接管，消息代理保证消息传递到指定目的地。

# 3、消息队列主要有两种形式的目的地 #

*  `队列（queue）`：点对点消息通信（point-to-point）
 *  `主题（topic）`：发布（publish）/订阅（subscribe）消息通信

# 4、点对点式： #

*  消息发送者发送消息，消息代理将其放入一个队列中，消息接收者从队列中获取消息内容，消息读取后被移出队列  
    消息只有唯一的发送者和接受者，但并不是说只能有一个接收者

# 5、发布订阅式： #

*  发送者（发布者）发送消息到主题，多个接收者（订阅者）监听（订阅）这个主题，那么就会在消息到达时同时收到消息

# 6、JMS（Java Message Service）JAVA消息服务： #

*  基于JVM消息代理的规范。ActiveMQ、HornetMQ是JMS实现

# 7、AMQP（Advanced Message Queuing Protocol） #

*  高级消息队列协议，也是一个消息代理的规范，兼容JMS
 *  RabbitMQ是AMQP的实现

# 8、Spring支持 #

*  spring-jms提供了对JMS的支持
 *  spring-rabbit提供了对AMQP的支持
 *  需要ConnectionFactory的实现来连接消息代理
 *  提供JmsTemplate、RabbitTemplate来发送消息
 *  @JmsListener（JMS）、@RabbitListener（AMQP）注解在方法上监听消息代理发布的消息
 *  @EnableJms、@EnableRabbit开启支持

# 9、Spring Boot自动配置 #

*  JmsAutoConfiguration
 *  RabbitAutoConfiguration

[70]: /images/20220517/b759eb603d204f1aa656a3d3d2cdf230.png
[70 1]: /images/20220517/1ef837843f3c4be5bbe514c6a4806684.png
[70 2]: /images/20220517/6cc9f3522c4c40b2b921c0bc69f2607c.png
[70 3]: /images/20220517/d5706fcff14b48e98daeba56c78abcb2.png
[70 4]: /images/20220517/4f7deb0a03294e10b340e8b086843044.png
[70 5]: /images/20220517/7161bf7dbbcc4b95a3d9fdf4ccdcac97.png