【入门简介篇】
一、 RabbitMQ特点
开发语言：Erlang
消息协议：AMQP
缺点：多实例消费场景，无法保证消费有序性
最初起源于金融系统，用于在分布式系统中存储转发消息，具体特点包括：
1 可靠性保证：使用持久化、传输确认、发布确认等。
2 具有灵活的路由功能：在消息进入队列之前，是通过Exchange（交换器）来路由消息的。
3 支持消息集群：多台RabbitMQ服务器可以组成一个集群，形成一个逻辑Broker。
4 具有高可用性：队列可以在集群中的机器上进行镜像，使得在部分节点出现问题的情况下队列仍然可用。
5 支持多种协议：除了支持AMQP之外，还通过插件的方式支持其他消息队列的协议，比如STOMP、MQTT等。
二、 基本概念
RabbitMQ整体架构图
Publisher 生产者：一个向交换器发布消息的客户端应用程序，采用push模式。
Exchange 交换器：用来接收生产者发送的消息，并将这些消息路由给服务器中的队列。
Binding 绑定：用于消息队列和交换器之间的关联。一个绑定就是基于路由键将交换器和消息队列连接起来的路由规则，所以可以将交换器理解为一个由绑定构成的路由表。
Queue 消息队列：用来保存消息，直到发送给消费者。它是消息的容器，也是消息的终点。一条消息可被投入一个或多个队列中。消息一直在队列里面，等待消费者连接到这个队列将其取走。
Message 消息：由消息头和消息体组成，消息头由一系列可选属性组成，这些属性包括routing-key（路由键）、priority（优先级）、delivery-mode（持久化模式）等。
Connection 网络连接：比如一个TCP连接。
Channel 信道：多路复用连接中的一条独立的双向数据流通道。信道是建立在真实的TCP连接内的虚拟连接，AMQP命令都是通过信道发送出去，包括发消息、订阅队列、接收消息；这里的重点在于，复用了一个TCP连接，因为从操作系统层面来讲，建立和销毁TCP连接相对于信道的方式，开销非常大。
Consumer 消费者：表示一个从消息队列中取得消息的客户端应用程序，采用pull模式。
Virtual Host 虚拟主机：默认的vhsot是“/”，本质上是一台缩小版的RabbitMQ服务器。
Broker：代表消息服务器的实体。
三、 AMQP中的消息路由
AMQP中的消息路由过程：
生产者发送消息到Exchange上，根据不同的Binding决定交换器上的消息应该被发送到哪个队列中，消息最终到达队列并被消费者接收，如图：
AMQP消息路由过程
四、 Exchange类型
交换器类型有四种：Header、Direct、Fanout和Topic，其中Header已被业界淘汰，所以在这里介绍其它三种交换器：
1 Direct 交换器
Direct 交换器
单播模式，只有消息的routing-key需要和Binding的routing-key完全一致，交换器就会将消息发送到对应的队列中；该模式的最大问题在于只能点对点。
2 Fanout 交换器
Fanout 交换器
广播模式，该模式下交换器会忽略routing-key，直接将队列绑定到交换器，发送到交换器的消息会被转发到所有绑定的队列中；该模式的最大问题在于多实例下重复消费。
3 Topic 交换器
Topic 交换器
主题模式，通过模式匹配来分配消息的路由键属性，routing-key可以通过模式进行匹配，其中routing-keyi可用多个单词+点"."分隔的方式进行定义，而且会识别“#”和“*”两个通配符，来进行单词匹配；最终效果相当于多个Direct交换器的灵活组合。
参考文献
倪炜 《分布式消息中间件实践》
网友评论