RabbitMQ
1.RabbitMQ特点
RabbitMQ 是一个由Erlang 语言开发的基于AMQP 标准的开源实现。RabbitMQ 最初起源于金融系统,用于在分布式系统中存储转发消息,在易用性、扩展性、高可用性等方面表现不俗。其具体特点包括:
-
保证可靠性( Reliabil ity ) 。RabbitMQ 使用一些机制来保证可靠性,如持久化、传输确认、发布确认等。
-
具有灵活的路由( Flex ible Routing )功能。在消息进入队列之前,是通过Exchange (交换器)来路由消息的。对于典型的路由功能, RabbitMQ 已经提供了一些内置的Exchange来实现。针对更复杂的路由功能,可以将多个Exchange 绑定在一起,也可以通过插件
机制来实现自己的Exchange 。 -
支持消息集群( Clustering ) 。多台RabbitMQ 服务器可以组成一个集群,形成一个逻辅
Broker 。 -
具有高可用性( H ighly Available ) 。队列可以在集群中的机器上进行镜像,使得在部分节点出现问题的情况下队列仍然可用。
支持多种协议( Multi-protocol ) 。RabbitMQ 除支持AMQP 协议之外,还通过插件的方式支持其他消息队列协议,比如STOMP, MQTT 等。 -
支持多语言客户端( Many Client )。RabbitMQ 几乎支持所有常用的语言,比如Java 、.NET 、Ruby 等。
-
提供管理界面( Management UI ) 。RabbitMQ 提供了一个易用的用户界面,使得用户可以监控和管理消息Broker 的许多方面。
-
提供跟踪机制( Trac ing ) 。RabbitMQ 提供了消息跟踪机制,如果消息异常,使用者可以查出发生了什么情况。
-
提供插件机制( Plugin System ) 。RabbitMQ 提供了许多插件,从多方面进行扩展,也可以编写自己的插件。
RabbitMQ 基本概念
如图 所示是RabbitMQ 的整体架构图
- Message (消息) : 消息是不具名的,它由消息头和消息体组成。消息体是不透明的,而消息头则由一系列可选属性组成,这些属性包括routing-key (路由键)、priority (相对于其他消息的优先级〉、delivery-mode(指出该消息可能需要持久化存储)等。
- Publisher (消息生产者) : 一个向交换器发布消息的客户端应用程序。
- Exchange (交换器):用来接收生产者发送的消息,并将这些消息路由给服务器中的队列。
- Binding (绑定) : 用于消息队列和交换器之间的关联。一个绑定就是基于路由键将交换器和消息队列连接起来的路由规则,所以可以将交换器理解成一个由绑定构成的路由表。
- Queue (消息队列):用来保存消息直到发送给消费者。它是消息的容器,也是消息的终点。一条消息可被投入一个或多个队列中。消息一直在队列里面,等待消费者连接到这个队列将其取走。
- Connection (网络连接〉:比如一个TCP 连接。
- Channel ( 信道): 多路复用连接中的一条独立的双向数据流通道。信道是建立在真实的TCP 连接内的虚拟连接, AMQP 命令都是通过信道发送出去的,不管是发布消息、订阅队列还是接收消息,这些动作都是通过信道完成的。因为对于操作系统来说, 建立和销毁TCP 连接都是非常昂贵的开销,所以引入了信道的概念,以复用一个TCP连接。
- Consumer (消息消费者) : 表示一个从消息队列中取得消息的客户端应用程序。
-
Virtual Host (虚拟主机, 在RabbitMQ 中Qlj vhosD : 表示一批交换器、消息队列和相关对象。虚拟主机是共享相同的身份认证和加密环境的独立服务器域。本质上每个vhost就是一台缩小版的RabbitMQ 服务器,它拥有自己的队列、交换器、绑定和权限机制。
vhost 是AMQP 概念的基础,必须在连接时指定, RabbitMQ 默认的vhost 是“/”。 - Broker : 表示消息队列服务器实体。
(1)AMQP 中的消息路由
AMQP 中的消息路由过程和Java 开发者熟悉的JMS 存在一些差别,在AMQP 中增加了Exchan ge 和B inding 的角色。生产者需要把消息发布到Exchange 上,消息最终到达队列并被消费者接收,而Binding 决定交换器上的消息应该被发送到哪个队列中
(2)交换器类型
不同类型的交换器分发消息的策略也不同,目前交换器有4 种类型: Direct 、Fanout、Topic 、Headers 。其中Headers 交换器匹配AMQP 消息的Header 而不是路由键。此外, Headers 交换器
和Direct 交换器完全一致,但性能相差很多, 目前几乎不用了,所以下面我们看另外三种类型。
Direct 交换器
如果消息中的路由键( routing key )和Binding 中的绑定键( binding key ) 一致,交换器就将消息发送到对应的队列中。路由链’与队列名称要完全匹配,如果将一个队列绑定到交换机要求路由键为“ dog ”,则只转发routing key 标记为“ dog ” 的消息,不会转发“ dog.puppy ”消息,也不会转发“ dog.guard “消息等。Direct 交换器是完全匹配、单播的模式。
Fanout 交换器
Fanout 交换器不处理路由键,只是简单地将队列绑定到交换器,发送到交换器的每条消息都会被转发到与该交换器绑定的所有队列中。这很像子网广播,子网内的每个主机都获得了一份复制的消息。通过Fanout 交换器转发消息是最快的。
Topic 交换器
Topic 交换器通过模式匹配分配消息的路由键属性,将路由键和某种模式进行匹配, 此时队列需要绑定一种模式。Topic 交换器将路由键和l绑定键的字街串切分成单词,这些单词之间用点. ’隔开。该交换器会识别两个通配符: “#”和“*”,其中“#”匹配0 个或多个单
词,“*” 匹配不多不少一个单词。