1. 简介

RabbitMQ 是 AMQP 协议的 Erlang 的实现（RabbitMQ 还支持 STOMP、MQTT 等协议）。

AMQP 的模型架构和 RabbitMQ 的模型架构是一样的：

1. 生产者发送消息给交换器
2. 交换器和队列绑定
3. 当 RoutingKey 和 BindingKey 相匹配时，消息被存入相应的队列中
4. 消费者可以订阅相应的队列来获取消息。

RabbitMQ 中的交换器、交换器类型、队列、绑定、路由键等都遵循 AMQP 协议中相应的概念。本书讲解的 RabbitMQ 版本对应的是 AMQP 0-9-1 版本协议。如无特指，则以该协议为基准介绍。

1. 背景

生产者将消息发送出去之后，消息到底有没有正确到达服务器？如果不进行特殊配置，默认情况下发送消息的操作是不会返回任何信息给生产者的。也就是说默认情况下，生产者不知道消息是否正确到达服务器。

RabbitMQ 针对这个问题，提供了两种解决方式：

• 事物机制
• 发送方确认（publisher confirm）机制

2. 事物机制

RabbitMQ 客户端中与事物机制相关的方法有三个：

• channel.txSelect：将当前的信道设置为 事物模式
• channel.txCommit：提交事物
• channel.txRollback：回滚事物

1. 简介

消费者客户端可以通过 推模式 和 拉模式 来获取并消费消息，RabbitMQ 把消息推送后（或客户端主动 ACK）后，RabbitMQ 把当前消息从队列中标记清除。如果由于某些原因无法处理当前接受到的信息，可以通过 channel.basicNack 或则 channel.basicReject 来拒绝掉。

对于消费者来说，还有几点需要注意：

• 消息分发
• 消息顺序性
• 弃用 QueueingConsumer

1. 分析数据丢失的原因

分析RabbitMQ消息丢失的情况，不妨先看看一条消息从生产者发送到消费者消费的过程：

1. 简介

Dead Letter Exchange 简称 DLX，可称为死信交换器，当消息在一个 队列中变成死信（dead message）之后，它能被重新发送到另一个交换器中，这个交换器就是 DLX，绑定在 DLX 上的队列就称为 死信队列。

消息变成死信一般有以下几种情况：

• 消息被拒绝，并设置 requeue 参数为 false

  Basic.Reject 或 Basic.Nack

• 消息过期

• 队列达到最大长度

1. 简介

持久化在前面多次提到，持久化可以提高 RabbitMQ 的可靠性，防止在异常情况（重启、关闭、宕机等）下的数据丢失。

本节针对这个概念做一个总结。RabbitMQ 的持久化分为三个部分：

• 交换器的持久化

  在声明交换器是将 durable 参数设置为 true 实现，如果不持久化，RabbitMQ 服务重启之后，相关的交换器元数据会丢失（没有这个交换器了），但是 队列和消息不会丢失（分情况是否设置持久化），只是 不能将消息发送到这个交换器了。

• 队列的持久化

  在声明队列时将 durable 参数设置为 true 实现，如果不持久化，RabbitMQ 服务重启之后，相关的 元数据会丢失，消息也会丢失；

• 消息的持久化

  但是队列的持久化，并 不能保证消息数据不丢失，要保证消息不丢失，需要将消息的投递模式设置为 2 （BasicProperties 中的 deliveryMode 属性）

1. 什么是消息队列

消息指的是两个应用间传递的数据。数据的类型有很多种形式，可能只包含文本字符串，也可能包含嵌入对象。

“消息队列(Message Queue)”是在消息的传输过程中保存消息的容器。在消息队列中，通常有生产者和消费者两个角色。生产者只负责发送数据到消息队列，谁从消息队列中取出数据处理，他不管。消费者只负责从消息队列中取出数据处理，他不管这是谁发送的数据。

1. 简介

优先级高的消息具备 优先被消费 的特权。

2. 代码实现

在定义队列时，可通过参数 x-max-priority 来指声明此队列的最大优先级别。在发送消息时，给消息设置的最大级别不能超过这个值

// 定义队列支持的最大级别
final HashMap<String, Object> arguments = new HashMap<>();
arguments.put("x-max-priority", 10);
channel.queueDeclare("queue.priority", true, false, false, arguments);

// 发送消息时设置消息的优先级
final AMQP.BasicProperties.Builder builder = new AMQP.BasicProperties().builder();
builder.deliveryMode(2); // 持久化消息
builder.priority(5);  //设置消息的优先级别
channel.basicPublish(EXCHANGE_NAME,
                     "",
                     builder.build(),
                     "test".getBytes()
                    );

1. 简介

Remote Procedure Call 简称 RPC，即远程调用。这个请自行百度。

这里 RPC 实现和传统的 RPC 还不太一样。

1. 消息可靠传输

消息可靠传输 一般是业务系统接入消息中间件首要考虑的问题，一般消息中间件的消息传输保障分为三个层级：

• At most once：最多一次。消息可能会丢失，但绝不会重复传输
• At least once：最少一次。消息绝不会丢失，但可能重复传输
• Exactly once：恰好一次。每条消息肯定会被传输一次且仅传输一次。

RabbitMQ 支持 「最多一次」和「最少一次」，不支持恰好一次