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