RabbitMQ消息持久化Ubuntu实践

以下是在Ubuntu上实践RabbitMQ消息持久化的步骤：

1. 安装RabbitMQ

   sudo apt update  
   sudo apt install rabbitmq-server  
   sudo systemctl start rabbitmq-server  
   sudo systemctl enable rabbitmq-server  
   

2. 启用管理插件

   sudo rabbitmq-plugins enable rabbitmq_management  
   sudo ufw allow 15672  # 开放管理界面端口  
   

   访问 http://localhost:15672，使用默认用户名/密码（guest/guest）登录。

3. 配置队列持久化

   • 命令行方式：

     sudo rabbitmqadmin declare queue name=my_queue durable=true  
     

   • 代码方式（Python示例）：

     channel.queue_declare(queue='my_queue', durable=True)  
     

4. 发送持久化消息

   properties = pika.BasicProperties(delivery_mode=2)  # 设置消息持久化  
   channel.basic_publish(exchange='', routing_key='my_queue', body='Hello', properties=properties)  
   

5. 验证持久化

   • 重启RabbitMQ服务：

     sudo systemctl restart rabbitmq-server  
     

   • 检查管理界面中队列和消息是否保留。

关键说明：

• 需同时设置队列持久化（durable=true）和消息持久化（delivery_mode=2），否则重启后消息会丢失。
• 生产环境中建议结合生产者确认模式（channel.confirmSelect()）确保消息成功写入磁盘。