在EC2上配置RabbitMQ，避免重启实例后丢失队列数据

一、用EBS卷实现存储持久化 #

EC2实例默认的临时存储（或未挂载独立卷的根卷）在实例重启/重建后会丢失数据，因此需要将RabbitMQ的数据目录挂载到EBS卷：

1. 停止当前EC2实例，在AWS控制台创建EBS卷并将其附加到实例
2. 启动实例，登录后执行以下操作：
   • 格式化EBS卷（替换/dev/xvdf为实际设备名）：

     mkfs -t ext4 /dev/xvdf
     

   • 备份原RabbitMQ数据目录（若存在）：

     mv /var/lib/rabbitmq /var/lib/rabbitmq_backup
     

   • 创建新的挂载目录并挂载EBS卷：

     mkdir /var/lib/rabbitmq
     mount /dev/xvdf /var/lib/rabbitmq
     

   • 设置开机自动挂载：编辑/etc/fstab，添加一行：

     /dev/xvdf /var/lib/rabbitmq ext4 defaults 0 0
     

   • 验证挂载：

     mount -a
     

二、配置RabbitMQ自身的持久化 #

仅靠外部存储不够，还需确保RabbitMQ的队列和消息本身支持持久化：

1. 创建持久化队列 #

创建队列时必须指定durable属性为true：

• 命令行方式：

  rabbitmqctl declare_queue --queue my_queue --durable
  

• 客户端代码示例（以Python Pika为例）：

  import pika
  
  connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
  channel = connection.channel()
  # 声明持久化队列
  channel.queue_declare(queue='my_queue', durable=True)
  

2. 发送持久化消息 #

发布消息时设置delivery_mode=2，确保消息写入磁盘：

channel.basic_publish(
    exchange='',
    routing_key='my_queue',
    body='persistent message',
    properties=pika.BasicProperties(
        delivery_mode=2,  # 标记为持久化消息
    )
)

3. 调整RabbitMQ配置 #

编辑RabbitMQ配置文件/etc/rabbitmq/rabbitmq.conf，确保以下配置：

# 启用消息持久化到磁盘
rabbitmq_server.persist_messages = true
# 指定数据存储目录为挂载的EBS目录
rabbitmq_mnesia.dir = /var/lib/rabbitmq/mnesia

重启RabbitMQ使配置生效：

systemctl restart rabbitmq-server

三、验证持久化效果 #

1. 启动RabbitMQ，创建持久化队列并发送几条持久化消息
2. 停止EC2实例，重新启动实例
3. 登录实例后，通过rabbitmqctl list_queues或RabbitMQ管理界面查看队列和消息是否保留

内容的提问来源于stack exchange，提问作者saurav kumar