一、概述

    在生產過程中，難免會發生伺服器宕機的事情，RabbitMQ也不例外，可能由於某種特殊情況下的異常而導致RabbitMQ宕機從而重啟，那麼這個時候對於訊息佇列裡的資料，包括交換機、佇列以及佇列中存在訊息恢復就顯得尤為重要了。RabbitMQ本身帶有持久化機制，包括交換機、佇列以及訊息的持久化。持久化的主要機制就是將資訊寫入磁碟，當RabbtiMQ服務宕機重啟後，從磁碟中讀取存入的持久化資訊，恢復資料。(當然凡是都不是100%的，只能盡最大程度的保證訊息不會丟失吧)

二、交換機的持久化

    在前面的示例中，我們使用常規的宣告交換機的方法

		 channel.exchangeDeclare(EXCHANGE_NAME,"fanout");
 

使用這種方法宣告的交換機，預設不是持久化的，在伺服器重啟之後，交換機會消失。我們在管理臺的Exchange頁簽下檢視交換機，可以看到使用上述方法宣告的交換機，Features一列是空的，即沒有任何附加屬性。

    

    我們換用另一種方法宣告交換機

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

    檢視一下方法的說明

    /**
     * Actively declare a non-autodelete exchange with no extra arguments
     * @see com.rabbitmq.client.AMQP.Exchange.Declare
     * @see com.rabbitmq.client.AMQP.Exchange.DeclareOk
     * @param exchange the name of the exchange
     * @param type the exchange type
     * @param durable true if we are declaring a durable exchange (the exchange will survive a server restart)
     * @throws java.io.IOException if an error is encountered
     * @return a declaration-confirm method to indicate the exchange was successfully declared
     */
    Exchange.DeclareOk exchangeDeclare(String exchange, String type, boolean durable) throws IOException;
 

    我們可以看到第三個引數durable，如果為true時則表示要做持久化，當服務重啟時，交換機依然存在，所以使用該方法宣告的交換機是下面這個樣子的（做測試的時候，需要先在管理臺刪掉原來的同名交換機）D表示durable，滑鼠放在上邊會顯示為true

    

    現在重啟RabbitMQ服務之後，可以看到我們宣告的交換機仍然存在。

三、佇列的持久化

    與交換機的持久化相同，佇列的持久化也是通過durable引數實現的，預設生成的隨機佇列不是持久化的。前面示例中宣告的帶有我們自定義名字的佇列都是持久化的。

		 channel.queueDeclare(QUEUE_NAME, true, false, false, null);
 

    看一下方法的定義 

    /**
     * Declare a queue
     * @see com.rabbitmq.client.AMQP.Queue.Declare
     * @see com.rabbitmq.client.AMQP.Queue.DeclareOk
     * @param queue the name of the queue
     * @param durable true if we are declaring a durable queue (the queue will survive a server restart)
     * @param exclusive true if we are declaring an exclusive queue (restricted to this connection)
     * @param autoDelete true if we are declaring an autodelete queue (server will delete it when no longer in use)
     * @param arguments other properties (construction arguments) for the queue
     * @return a declaration-confirm method to indicate the queue was successfully declared
     * @throws java.io.IOException if an error is encountered
     */
    Queue.DeclareOk queueDeclare(String queue, boolean durable, boolean exclusive, boolean autoDelete,
                                 Map<String, Object> arguments) throws IOException;

    第二個引數跟交換機方法的引數一樣，true表示做持久化，當RabbitMQ服務重啟時，佇列依然存在。這裡說一下後邊的三個引數，exclusive是排他佇列，如果一個佇列被宣告為排他佇列，那麼這個佇列只能被第一次宣告他的連線所見，並在連線斷開的時候自動刪除。這裡有三點需要說明，1、同一個連線的不同channel，是可以訪問同一連線下建立的排他佇列的。2、排他佇列只能被宣告一次，其他連線不允許宣告同名的排他佇列。3、及時排他佇列是持久化的，當連線斷開或者客戶端退出時，排他佇列依然會被刪除。autoDelete是自動刪除，為true時，當沒有任何消費者訂閱該佇列時，佇列會被自動刪除。arguments：其它引數

四、訊息的持久化

    訊息的持久化是指當訊息從交換機發送到佇列之後，被消費者消費之前，伺服器突然宕機重啟，訊息仍然存在。訊息持久化的前提是佇列持久化，假如佇列不是持久化，那麼訊息的持久化毫無意義。

    通過如下程式碼設定訊息的持久化

channel.basicPublish(EXCHANGE_NAME,"",MessageProperties.PERSISTENT_TEXT_PLAIN,message.getBytes());

    其中MessageProperties.PERSISTENT_TEXT_PLAIN是設定持久化的引數

    我們檢視basicPublish方法的定義

    /**
     * Publish a message
     * @see com.rabbitmq.client.AMQP.Basic.Publish
     * @param exchange the exchange to publish the message to
     * @param routingKey the routing key
     * @param props other properties for the message - routing headers etc
     * @param body the message body
     * @throws java.io.IOException if an error is encountered
     */
    void basicPublish(String exchange, String routingKey, BasicProperties props, byte[] body) throws IOException;

    在看下BasicProperties的型別

        public BasicProperties(
            String contentType,
            String contentEncoding,
            Map<String,Object> headers,
            Integer deliveryMode,
            Integer priority,
            String correlationId,
            String replyTo,
            String expiration,
            String messageId,
            Date timestamp,
            String type,
            String userId,
            String appId,
            String clusterId)

     其中deliveryMode是設定訊息持久化的引數，等於1不設定持久化，等於2設定持久化。PERSISTENT_TEXT_PLAIN是例項化的一個deliveryMode=2的物件，便於程式設計。

public static final BasicProperties PERSISTENT_TEXT_PLAIN =
    new BasicProperties("text/plain",
                        null,
                        null,
                        2,
                        0, null, null, null,
                        null, null, null, null,
                        null, null);

    設定了佇列的持久化和訊息的持久化之後，當伺服器宕機重啟，存在佇列中未傳送的訊息會依然存在。

    以上就是關於RabbitMQ中持久化的一些內容，但是並不會嚴格的100%保證資訊不會丟失，相關內容後續再說明。

五、總結

    RabbitMQ的持久化有交換機、佇列、訊息的持久化。用於防止伺服器宕機重啟之後資料的丟失，其中交換機和佇列的持久化都是設定durable引數為true，訊息的持久化是設定Properties為MessageProperties.PERSITANT_TEXT_PLAIN,訊息的持久化基於佇列的持久化。持久化不是100%完全保證訊息的可靠性。