RabbitMQ如何通過持久化保證消息99.99%不丟失？

1. 本篇概要

要解決該問題，就要用到RabbitMQ中持久化的概念，所謂持久化，就是RabbitMQ會將內存中的數據(Exchange 交換器，Queue 隊列，Message 消息)固化到磁碟，以防異常情況發生時，數據丟失。

其中，RabblitMQ的持久化分為三個部分：

交換器(Exchange)的持久化
隊列(Queue)的持久化
消息(Message)的持久化

2. 交換器(Exchange)的持久化

在上篇博客中，我們聲明Exchange的代碼是這樣的：

private final static String EXCHANGE_NAME = "normal-confirm-exchange";

// 創建一個Exchange
channel.exchangeDeclare(EXCHANGE_NAME, "direct");

這種情況下聲明的Exchange是非持久化的，在RabbitMQ出現異常情況（重啟，宕機）時，該Exchange會丟失，會影響後續的消息寫入該Exchange，那麼如何設置Exchange為持久化的呢？答案是設置durable參數。

durable：設置是否持久化。durable設置為true表示持久化，反之是非持久化。

持久化可以將交換器存檔，在伺服器重啟的時候不會丟失相關信息。

設置Exchange持久化：

channel.exchangeDeclare(EXCHANGE_NAME, "direct", true);

此時調用的重載方法為：

public DeclareOk exchangeDeclare(String exchange, String type, boolean durable) throws IOException { return this.exchangeDeclare(exchange, (String)type, durable, false, (Map)null); }

為了能更好的理解，我們新建個生產類如下：

package com.zwwhnly.springbootaction.rabbitmq.durable;

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;

import java.io.IOException;
import java.util.concurrent.TimeoutException;

public class DurableProducer {
private final static String EXCHANGE_NAME = "durable-exchange";
private final static String QUEUE_NAME = "durable-queue";

public static void main(String[] args) throws IOException, TimeoutException {
// 創建連接
ConnectionFactory factory = new ConnectionFactory();
// 設置 RabbitMQ 的主機名
factory.setHost("localhost");
// 創建一個連接
Connection connection = factory.newConnection();
// 創建一個通道
Channel channel = connection.createChannel();
// 創建一個Exchange
channel.exchangeDeclare(EXCHANGE_NAME, "direct");
channel.queueDeclare(QUEUE_NAME, false, false, false, null);
channel.queueBind(QUEUE_NAME, EXCHANGE_NAME, "");

// 發送消息
String message = "durable exchange test";
channel.basicPublish(EXCHANGE_NAME, "", null, message.getBytes());

// 關閉頻道和連接
channel.close();
connection.close();
}
}

示例代碼中，我們新建了1個非持久化的Exchange，1個非持久化的Queue，並將它們做了綁定，此時運行代碼，Exchange和Queue新建成功，消息『durable exchange test』也被正確地投遞到了隊列中：