概述:
1)、大多应用中,可通过消息服务中间件来提升系统异步通信、扩展解耦能力
2)、消息服务中两个重要概念:
消息代理(message broker)和目的地(destination)
当消息发送者发送消息以后,将由消息代理接管,消息代理保证消息传递到指定目的地。
3)、消息队列主要有两种形式的目的地:
1.队列(queue):点对点消息通信(point-to-point)
2.主题(topic):发布(publish)/订阅(subscribe)消息通信
4)、异步处理消息的变迁
原始:
改进:
现在:
5)、应用解耦
过去:
现在:
6)、流量削峰
7)、点对点式
–消息发送者发送消息,消息代理将其放入一个队列中,消息接收者从队列中获取消息内容,消息读取后被移出队列
–消息只有唯一的发送者和接受者,但并不是说只能有一个接收者
8)、发布订阅式
–发送者(发布者)发送消息到主题,多个接收者(订阅者)监听(订阅)这个主题,那么就会在消息到达时同时收到消息
9)、JMS(Java Message Service)JAVA消息服务
–基于JVM消息代理的规范。ActiveMQ、HornetMQ是JMS实现
10)、AMQP(Advanced Message Queuing Protocol)
–高级消息队列协议,也是一个消息代理的规范,兼容JMS
–RabbitMQ是AMQP的实现
11)、JMS和AMQP对比
|
JMS |
AMQP |
定义 |
Java api |
网络线级协议 |
跨语言 |
否 |
是 |
跨平台 |
否 |
是 |
Model |
提供两种消息模型: (1)、Peer-2-Peer (2)、Pub/sub |
提供了五种消息模型: (1)、direct exchange (2)、fanout exchange (3)、topic change (4)、headers exchange (5)、system exchange 本质来讲,后四种和JMS的pub/sub模型没有太大差别,仅是在路由机制上做了更详细的划分; |
支持消息类型 |
多种消息类型: TextMessage MapMessage BytesMessage StreamMessage ObjectMessage Message (只有消息头和属性) |
byte[] 当实际应用时,有复杂的消息,可以将消息序列化后发送。 |
综合评价 |
JMS 定义了JAVA API层面的标准;在java体系中,多个client均可以通过JMS进行交互,不需要应用修改代码,但是其对跨平台的支持较差; |
AMQP定义了wire-level层的协议标准;天然具有跨平台、跨语言特性。 |
13)、Spring支持
–spring-jms提供了对JMS的支持
–spring-rabbit提供了对AMQP的支持
–需要ConnectionFactory的实现来连接消息代理
–提供JmsTemplate、RabbitTemplate来发送消息
–@JmsListener(JMS)、@RabbitListener(AMQP)注解在方法上监听消息代理发布的消息
–@EnableJms、@EnableRabbit开启支持
14)、Spring Boot自动配置
–JmsAutoConfiguration
–RabbitAutoConfiguration