在初识消息中间件中，我们了解到了消息中间件的编年史，如下

然后我们在介绍ActiveMQ就先简单的介绍了JMS的规则，所以这里我们在介绍RabbitMQ的时候，那么肯定也是先来了解一下AMQP

AMQP，即Advanced Message Queuing Protocol,一个提供统一消息服务的应用层标准高级消息队列协议。是应用层协议的一个开放标准,为面向消息的中间件设计。基于此协议的客户端与消息中间件可传递消息，并不受客户端/中间件不同产品，不同的开发语言等条件的限制。目标是实现一种在全行业广泛使用的标准消息中间件技术，以便降低企业和系统集成的开销，并且向大众提供工业级的集成服务。主要实现有RabbitMQ。

要素

其包括的要素：生产者、消费者、消息、信道、交换器、队列、绑定、路由键。

生产者、消费者、消息

• 生产者： 消息的创建者，发送到RabbitMQ
• 消费者： 连接到RabbitMQ，订阅到队列上，消费消息，持续订阅(basicConsumer)和单条订阅(basicGet)
• 消息： 包含有效载荷和标签，有效载荷指要传输的数据，标签描述了有效载荷，并且RabbitMQ用它来决定谁获得消息，消费者只能拿到有效载荷，并不知道生产者是谁。

这里生产者和消费者的概念其实和ActiveMQ中的类似，只有消息的概念不同，这里生产者发送给RabbitMQ的消息是有两部分组成——有效载荷、标签，其中标签并不会被消费者拿到，只用于RabbitMQ来进行判断的。

信道

信道是生产者消费者与RabbitMQ通信的渠道，生产者publish或是消费者subscribe一个队列都是通过信道来通信的。信道是建立在TCP连接上的虚拟连接，什么意思呢？

就是说RabbitMQ在一条TCP上建立成百上千个信道来达到多个线程处理，这个TCP被多个线程共享，每个线程对应一个信道，信道在RabbitMQ都有唯一的ID ,保证了信道私有性，对应上唯一的线程使用。

那么为什么RabbitMQ不直接多个TCP连接呢，因为RabbitMQ为了保证性能，系统为每个线程开辟一个TCP是非常消耗性能，每秒成百上千的建立销毁TCP会严重消耗系统。所以RabbitMQ选择建立多个信道（建立在tcp的虚拟连接）连接到RabbitMQ上。

交换器、队列、绑定、路由键

队列通过路由键（routing key，某种确定的规则）绑定到交换器，生产者将消息发布到交换器，交换器根据绑定的路由键将消息路由到特定队列，然后由订阅这个队列的消费者进行接收。

如果消息达到无人订阅的队列会怎么办？ 消息会一直在队列中等待，RabbitMq默认队列是无限长度的。

多个消费者订阅到同一队列怎么办？ 消息以循环的方式发送给消费者，每个消息只会发送给一个消费者。

消息路由到了不存在的队列怎么办？ 一般情况下RabbitMQ会直接忽略，当这个消息不存在，也就是消息丢了。

---

消息的确认

消费者收到的每一条消息都必须进行确认（自动确认和自行确认）。

消费者在声明队列时，可以指定autoAck参数，当autoAck=false时，RabbitMQ会等待消费者显式发回ack信号后才从内存(和磁盘，如果是持久化消息的话)中移去消息。否则，RabbitMQ会在队列中消息被消费后立即删除它。

采用消息确认机制后，只要令autoAck=false，消费者就有足够的时间处理消息(任务)，不用担心处理消息过程中消费者进程挂掉后消息丢失的问题，因为RabbitMQ会一直持有消息直到消费者显式调用basicAck为止。

当autoAck=false时，对于RabbitMQ服务器端而言，队列中的消息分成了两部分：一部分是等待投递给消费者的消息；一部分是已经投递给消费者，但是还没有收到消费者ack信号的消息。如果服务器端一直没有收到消费者的ack信号，并且消费此消息的消费者已经断开连接，则服务器端会安排该消息重新进入队列，等待投递给下一个消费者（也可能还是原来的那个消费者）。

RabbitMQ不会为未ack的消息设置超时时间，它判断此消息是否需要重新投递给消费者的唯一依据是消费该消息的消费者连接是否已经断开。这么设计的原因是RabbitMQ允许消费者消费一条消息的时间可以很久很久。

---

交换器类型

交换器的作用是什么呢？我们可以看到上述的流程图，其中消费者是从队列中获取消息的，可以多个不同的队列，和ActiveMQ不同的是生产者发送消息并不是直接发送到队列之中供消费者消息的，而是发送到交换器中，然后由根据绑定的路由键将消息路由到不同队列，然后消费者才可以进行消费。

交换器类型共有四种Direct、Fanout、Topic、Headers，其中Headers几乎和direct一样。

Direct Exchange

路由键完全匹配，消息被投递到对应的队列，和ActiveMQ的Queue模式类似。每个amqp的实现都必须有一个Direct交换器，包含一个空白字符串名称的默认交换器。声明一个队列时，会自动绑定到默认交换器，并且以队列名称作为路由键。

Fanout Exchange

消息广播到绑定的队列，这个和ActiveMQ的Topic模式就很比较类似的。

Topic Exchange

这个和我们在ActiveMQ通配符式订阅比较类似

而AMQP中通过使用 * 和 # ，使来自不同源头的消息到达同一个队列，. 将路由键分为了几个标识符， * 匹配1个，# 匹配一个或多个。

从上述我们就可以发现 # 和在ActiveMQ通配符式订阅介绍的 > 类似，然后 * 和ActiveMQ中也是类似的，只能匹配一个，不能多个。

---

虚拟主机

虚拟主机（vhost），其本质上就是一个mini版的MQ服务器，有自己的队列、交换器和绑定，最重要的，自己的权限机制。

虚拟主机提供了逻辑上的分离，可以将众多客户端进行区分，又可以避免队列和交换器的命名冲突。虚拟主机必须在连接时指定，RabbitMQ包含缺省vhost："/"，通过缺省用户和口令guest进行访问。

RabbitMQ里创建用户，必须要被指派给至少一个虚拟主机，并且只能访问被指派内的队列、交换器和绑定。虚拟主机必须通过RabbitMQ的管理控制工具创建。