RabbitMQ消息队列持久化实现指南
RabbitMQ的消息持久化需通过交换机持久化、队列持久化、消息持久化三者结合实现，确保服务器重启或故障后消息不丢失。以下是具体实现步骤及关键注意事项：
交换机是消息的路由枢纽，持久化其元数据可避免RabbitMQ重启后需重新创建。声明交换机时，需将durable参数设置为true（默认为false）。
@Bean
public DirectExchange myExchange() {
return new DirectExchange("my_exchange", true, false); // durable=true表示持久化
}
channel.exchange_declare(
exchange="my_exchange",
exchange_type="direct",
durable=True # 持久化交换机
)
交换机持久化仅保存其名称、类型等元数据，不包含绑定的队列或消息。
队列是消息的存储容器，持久化队列可确保其元数据（如名称、最大长度）及已存储的消息在重启后保留。声明队列时，需将durable参数设置为true（默认为false）。
@Bean
public Queue myQueue() {
return new Queue("my_queue", true); // durable=true表示持久化
}
channel.queue_declare(
queue="my_queue",
durable=True # 持久化队列
)
关键说明：若队列未设置为持久化，即使消息标记为持久化，重启后队列会丢失，消息也随之消失。
消息持久化是将消息内容从内存写入磁盘的核心步骤。发布消息时，需通过BasicProperties设置delivery_mode=2（PERSISTENT，默认为1，表示非持久化）。
MessageProperties props = new MessageProperties();
props.setDeliveryMode(MessageDeliveryMode.PERSISTENT); // 设置为持久化
Message message = new Message("Hello World".getBytes(), props);
rabbitTemplate.send("my_exchange", "my_routing_key", message);
properties = pika.BasicProperties(
delivery_mode=2 # 持久化消息（值为2表示PERSISTENT）
)
channel.basic_publish(
exchange="my_exchange",
routing_key="my_queue",
body="Hello World!",
properties=properties
)
注意：消息持久化的前提是队列已持久化，否则消息无法保存到磁盘。
RabbitMQ默认采用定期批量刷盘（默认间隔250ms），可通过修改rabbitmq.conf文件调整刷盘频率（如flush_interval = 100，单位毫秒），减少数据丢失风险，但会略微降低性能。
结合集群使用镜像队列，将队列冗余到多个节点，避免单点故障。通过rabbitmqctl命令设置镜像策略：
rabbitmqctl set_policy ha-all "^ha\." '{"ha-mode":"all"}' # 所有节点同步队列
镜像队列需配合持久化使用，确保镜像节点上的队列和消息均为持久化状态。
channel.confirm_delivery()）确保消息成功写入磁盘。basic_ack（手动确认），避免消息因消费失败或未确认而被RabbitMQ删除。
