RabbitMQ在CentOS上的消息持久化

在CentOS上配置RabbitMQ的消息持久化，可以確保即使在RabbitMQ服務器重啟后，消息也不會丟失。以下是詳細的步驟和說明：

1. 安裝RabbitMQ

首先，確保你已經在CentOS上安裝了RabbitMQ。如果還沒有安裝，可以使用以下命令進行安裝：

sudo yum install rabbitmq-server

2. 啟動RabbitMQ服務

安裝完成后，啟動RabbitMQ服務：

sudo systemctl start rabbitmq-server

3. 啟用管理插件（可選）

為了方便管理RabbitMQ，可以啟用管理插件：

sudo rabbitmq-plugins enable rabbitmq_management

然后，你可以通過瀏覽器訪問 http://<your_server_ip>:15672 來管理RabbitMQ。

4. 創建持久化隊列

在RabbitMQ中，隊列和消息都可以設置為持久化。以下是如何創建一個持久化隊列的示例：

import pika

# 連接到RabbitMQ服務器
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

# 聲明一個持久化隊列
channel.queue_declare(queue='durable_queue', durable=True)

print("Queue declared with persistence enabled.")

# 關閉連接
connection.close()

5. 發送持久化消息

發送消息時，也需要將消息標記為持久化：

import pika

# 連接到RabbitMQ服務器
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

# 聲明一個持久化隊列
channel.queue_declare(queue='durable_queue', durable=True)

# 發送持久化消息
channel.basic_publish(exchange='',
                      routing_key='durable_queue',
                      body='Hello World!',
                      properties=pika.BasicProperties(
                         delivery_mode=2,  # 使消息持久化
                      ))

print("Message sent with persistence enabled.")

# 關閉連接
connection.close()

6. 消費持久化消息

消費者在消費消息時，不需要特別設置，只要隊列是持久化的，消息就會一直存在直到被消費：

import pika

# 連接到RabbitMQ服務器
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

# 聲明一個持久化隊列
channel.queue_declare(queue='durable_queue', durable=True)

def callback(ch, method, properties, body):
    print(f"Received {body}")

# 消費消息
channel.basic_consume(queue='durable_queue',
                      on_message_callback=callback,
                      auto_ack=True)

print('Waiting for messages. To exit press CTRL+C')

# 開始消費
channel.start_consuming()

7. 持久化交換機（可選）

如果你使用的是自定義交換機，也可以將其設置為持久化：

import pika

# 連接到RabbitMQ服務器
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

# 聲明一個持久化交換機
channel.exchange_declare(exchange='durable_exchange', exchange_type='direct', durable=True)

# 聲明一個持久化隊列
channel.queue_declare(queue='durable_queue', durable=True)

# 綁定隊列到交換機
channel.queue_bind(exchange='durable_exchange', queue='durable_queue', routing_key='routing_key')

print("Exchange and queue declared with persistence enabled.")

# 關閉連接
connection.close()

通過以上步驟，你可以在CentOS上配置RabbitMQ的消息持久化，確保消息在服務器重啟后不會丟失。