參考連結：

https://www.cnblogs.com/Keep-Ambition/p/8044752.html

 假如訊息佇列test裡面還有訊息等待消費者(consumers)去接收，但是這個時候伺服器端宕機了，這個時候訊息是否還在？

 1、佇列訊息非持久化

服務端（producer）：

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17

import pika # 宣告一個socket 例項 connect = pika.BlockingConnection(pika.ConnectionParameters("localhost")) # 宣告一個管道 channel = connect.channel() # 宣告queue名稱為test channel.queue_declare(queue="test") #RabbitMQ的訊息永遠不會被直接傳送到佇列中，它總是需要經過一次交換 channel.basic_publish(exchange='', routing_key="test", body="hello word" ) print("Sent 'hello world'") connect.close()

客戶端（consumers）:

上面的服務端和客戶端宣告queue的方式都是非持久的

channel.queue_declare(queue="test")

①服務端先發送往test佇列裡傳送兩條訊息

②通過執行--services.msc進入服務重新啟動RabbitMQ

 

③再次檢視訊息佇列queue中的訊息數量

 

通過小實驗可以看出，非持久宣告的queue，在服務端宕機後，訊息佇列queue和訊息都不復存在了

2、佇列訊息持久化：

①佇列持久化很簡單，只需要在服務端(produce)宣告queue的時候新增一個引數：

channel.queue_declare(queue='shuaigaogao', durable=True)  # durable=True 持久化

相關推薦