知识要点:
什么是消息中间件
消息中间件的作用
消息中间件历史
JMS规范
AMQP协议
消息队列中间件(Message Queue Middleware,简称为MQ)是指利用高效可靠的消息传递机制进行与平台无关的数据交流,并基于数据通信来进行分布式系统的集成。通过提供消息传递和消息排队模型,它可以在分布式环境下扩展进程间的通信。
目前开源的消息中间件有很多,比较主流的有RabbitMQ、Kafka、 ActiveMQ、 RocketMQ等。 面向消息的中间件(简称为MOM, Message Oriented Middleware)提供了以松散藕合的灵活方式集成应用程序的一种机制。它们提供了基于存储和转发的应用程序之间的异步数据发送,即应用程序彼此不直接通信,而是与作为中介的消息中间件通信。消息中间件提供了有保证的消息发送,应用程序开发人员无须了解
远程过程调用( RPC)和网络通信协议的细节。
消息中间件的作用
步, (解决不必要的阻塞) : 消息中间件提供了异步处理机制,允许应用把一些消息放入消息中间件中,但并不立即处理它,在之后需要的时候再慢慢处理。
解耦(降低模块间的耦合关系) :
消息中间件在处理过程中间插入了一个隐含的、基于数据的接口层。
削峰(峰值任务的平滑处理) :
在访问量剧增的情况下,应用仍然需要继续发挥作用。
冗余(存储、补偿机制) :
有些情况下,处理数据的过程会失败。消息中间件可以把数据进行持久化直到
它们已经被完全处理,通过这- -方式规避了数据丢失风险。
注意:
分布式消息传递:中间件可用性(高可用)、可靠性 (消息在传递过程中不会丢失)、持久化 (消息在存储过程中不丢失)、吞吐量、 响应时间、跨平台。
消息中间件的历史
最早的消息中间件概念诞生是非常早的,在1983年, -个印度人提出了一个设想,设计-种软件总线,提供其他程序接入,以发布订阅的模式。后来成了TIB。
IBM——> WebSphere MQ
微软一一> MSMQ
JMS (Java Message Service)规范,由sun公司于2001年发布, 封装了各大厂商的消息中间件服务,提供了Java的APl。那么Java程序员就只需要面向API编程,不需要关注到底用了什么消息中间件AMQP (Advanced Message Queuing Protocol)协议,2004年诞生。
JMS规范(Message Serice)
JMS (Java Message Service)规范本质上是一套API,只适用于Java平台的消息中间件规范,支持Java应用程序之间进行消息交换。并且通过提供标准的生产、发送、接收消息的接口简化企业应用的开发。
JMS对象模型包含的元素:
1、连接工厂:用于创建一 个JMS连接
2、JMS连接:客户端和服务器之间的一个连接
3、JMS会话:客户端和服务器端会话的状态,建立在连接之上的
4、JMS目的:消息队列,就是消息的目的地
5、JMS生产者:生成消息
6、JMS消费者:接收消息
7、Broker: 消息中间件实例
JMS消息模型
1、 Point-to-Point (点对点)
特点:一个消息只有一个消费者拿到,该消息就从消息队列中删除。成功拿到消息后会向队列应答成功,确认接收。
2、publis/sbscribe(发布/订阅)
订阅者消费特点:
发布到Topic的消息会被当前主题所有的订阅者消息
AMQP协议
AMQP (Advanced Message Queuing Protocol)协议是一开放标准,支持不同语言的不同产品。
AMQP组件
生产者:
消息的创建者,将消息发送到消息中间件
消费者:
连接到消息中间件上,订阅在队列上,进行消息的消费。
消息:
包括有效载荷与标签。有效载荷:要传输的数据;标签:描述有效载荷的属性: RabbitMQ通过标签决定谁获得该消息,消费者只能得到有效载荷。
信道:
可理解为一个虚拟的连接,建立在真实的TCP/IP连接之上。所有AMQP上的消启都通过信道传输,TCP/IP连接的建立和释放对服务器有很大的消耗、昂贵的资源。信道的创建没有数量限制,保护资源的利用。
交换器、队列、绑定、路由键:
队列通过路由键(routing key)绑定到交换器,生产者把消息发送到交换器,交换器根据绑定的路由键把消息路由到特定的队列中,再由订阅该队列的消费者进行消息的消费。
注意:
一个连接有多个信道?可以信道是连接在Broker (MQ服务器)上交换器和信道无关