上一篇講消息中間件的文章：??《如果公司線上系統突然宕機了，怎么才能確保MQ消息不丟失？》??，初步給大家介紹了一個在生產環境中可能遇到的問題，就是你的消費者服務可能會宕機，一旦宕機，你就需要考慮是否會導致沒處理完的消息丟失。

這篇文章，給不太熟悉MQ技術的同學，介紹一個生產環境中可能會遇到的問題。

目前為止，你的RabbitMQ部署在線上服務器了，對吧？然后訂單服務和倉儲服務都可以基于RabbitMQ來收發消息，同時倉儲服務宕機，不會導致消息丟失。

好，我們來看下目前為止的架構圖。

那如果此時出現一個問題，就是說訂單服務投遞了訂單消息到RabbitMQ里去，RabbitMQ暫時放在了自己的內存中，還沒來得及投遞給下游的倉儲服務呢，此時RabbitMQ突然宕機了，會怎么樣？

答案其實很簡單，默認情況下，按照我們目前的代碼和配置，這個數據就會丟失了。

所以在這里而言，就牽扯到了RabbitMQ的一個較為重要的概念：消息的持久化，用英文來說就是durable機制。

然后這里又有一個引申的概念，如果按照我們之前的代碼和配置，默認情況下，RabbitMQ一旦宕機就再次重啟，就會丟失我們之前創建的queue。所以首先得先讓queue是持久化的。

使用下面的代碼，就可以把我們的“
warehouse_schedule_delivery”這個queue，也就是倉儲調度發貨的queue，設置為持久化的。

這樣，即使RabbitMQ宕機后重啟，也會恢復之前創建好的這個queue。

channel.queueDeclare(
"warehouse_schedule_delivery",
true,
false,
false,
null);

大家看到上面那行定義和創建queue的代碼么？核心在于第二個參數，第二個參數是true。

他的意思就是說，這個創建的queue是durable的，也就是支持持久化的。

RabbitMQ會把這queue的相關信息持久化的存儲到磁盤上去，這樣RabbitMQ重啟后，就可以恢復持久化的queue。

OK，現在你的queue的信息可以持久化了，RabbitMQ宕機重啟后會自動恢復queue。但是，你的queue里的message數據呢？ queue里都是訂單服務發送過去的訂單消息數據，如果RabbitMQ還沒來得及投遞queue里的訂單消息到倉儲服務，結果RabbitMQ就宕機了。

那此時RabbitMQ重啟之后，他可以恢復queue的信息，但是queue的message數據是沒法恢復了。 所以此時還有一個重要的點，就是在你的訂單服務發送消息到RabbitMQ的時候，需要定義這條消息也是durable，即持久化的。

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

通過上面的方式來發送消息，就可以讓發送出去的消息是持久化的。

一旦標記了消息是持久化之后，就會讓RabbitMQ把消息持久化寫入到磁盤上去，此時如果RabbitMQ還沒投遞數據到倉儲服務，結果就突然宕機了。那么再次重啟的時候，就會把磁盤上持久化的消息給加載出來。

整個過程，如下圖所示：

但是這里要注意一點，RabbitMQ的消息持久化，是不承諾100%的消息不丟失的。

因為有可能RabbitMQ接收到了消息，但是還沒來得及持久化到磁盤，他自己就宕機了，這個時候消息還是會丟失的。

如果要完全100%保證寫入RabbitMQ的數據必須落地磁盤，不會丟失，需要依靠其他的機制。