# 持久化

持久化在前面多次提到,持久化可以提高 RabbitMQ 的可靠性,防止在异常情况(重启、关闭、宕机等)下的数据丢失。

本节针对这个概念做一个总结。RabbitMQ 的持久化分为三个部分:

  • 交换器的持久化

    在声明交换器是将 durable 参数设置为 true 实现,如果不持久化,RabbitMQ 服务重启之后,相关的交换器元数据会丢失(没有这个交换器了),但是 队列和消息不会丢失(分情况是否设置持久化),只是 不能将消息发送到这个交换器了。

  • 队列的持久化

    在声明队列时将 durable 参数设置为 true 实现,如果不持久化,RabbitMQ 服务重启之后,相关的 元数据会丢失消息也会丢失

  • 消息的持久化

    但是队列的持久化,并 不能保证消息数据不丢失,要保证消息不丢失,需要将消息的投递模式设置为 2 (BasicProperties 中的 deliveryMode 属性)

注意要点

不是所有的消息都设置持久化,在一些对可靠性要求不是那么高的消息,可以不采用持久化。这样可以提高整体的吞吐量。

交换器、队列、消息都设置为持久化,也有可能丢失,有以下一个方面:

  • autoAck :自动确认

    在业务系统中,自动确认是最容易丢失的,如果处理过程中发生异常,消息可能就丢了。

    解决方案:改成手动 ack

  • 数据刷盘:RabbitMQ 依赖内核的 fsync 函数存盘

    关于 fsync 函数,自己百度;大概就是数据先写缓存,等待缓存写满,或则内核需要重用缓存时,会将该缓存排入输出队列,进而同步到设备上。

    服务器突然断电,就有可能导致丢失一部分数据;

    解决方案:可以使用 RabbitMQ 的镜像队列机制(后面章节会讲解),相当于配置了副本,master 挂掉,会自动切换到 slave 节点,保证了高可用性。

还可以在发送端引 入事物机制发送方确认机制 来保证消息已经正确发送并存储至 RabbitMQ 中。下一章节讲解