RabbitMQ：消息一致性之持久化和消费者确认

「爱情、让人受尽委屈。」 2021-12-20 13:17 290阅读 0赞

![20190628163829731.png][]  
       在应用开发中，持久化也是经常被提起的，持久化就是存在在内存当中的数据，要写入到磁盘中，这样在内存中的数据由于各种原因丢失掉后，可以通过磁盘重新加载到内存中来，对于消息中间件，持久化也至关重要。在生产者发布消息到broker后，消费者消费消息之前，消息是存在于内存当中，倘若消息丢失，那么就会造成消息的不一致性，这时就要对生产之后消费之前的消息做一下持久化操作。  
![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0FwZW9wbA_size_16_color_FFFFFF_t_70][]  
         RabbitMQ的持久化分为三个部分:交换器的持久化、队列的持久化和消息的持久化，而我们要关注的就是消息的持久化。但是消息是依附于队列而存在的，所以也要关注队列的持久化，倘若队列没有做持久化而丢失了，那么消息还能依附到哪里呢？但是队列的持久化能保证其本身的元数据不会因异常情况而丢失，但是并不能保证内部所存储的 消息不会丢失。要确保消息不会丢失，需要将其设置为持久化。通过将消息的投递模式 (BasicProperties中的deliveryMode属性)设置为2，即可实现消息的持久化。代码中消息投递时设置的MessageProperties.PERSISTENT\_TEXT\_PLAIN实际上是封装了这个属性:  
![2019062816391553.png][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0FwZW9wbA_size_16_color_FFFFFF_t_70 1][]  
       设置了队列和消息的持久化，当RabbitMQ服务重启之后，消息依旧存在。单单只设置队 列持久化，重启之后消息会丢失;单单只设置消息的持久化，重启之后队列消失，继而消息也丢失。单单设置消息持久化而不设置队列的持久化显得毫无意义。这时要注意一个问题，如果将所有的消息都设为持久化，会严重影响RabbitMQ的性能。写入 磁盘的速度比写入内存的速度慢得不只一点点。所以对于可靠性不是那么高的消息可以不采用持久 化处理，以提高整体的吞吐量。在选择是否要将消息持久化时，需要在可靠性和吐吞量之间做一个权衡。  
![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0FwZW9wbA_size_16_color_FFFFFF_t_70 2][]  
        那么队列、消息都设置了持久化之后，就能百分百保证数据不丢失了吗？  
        在持久化的消息正确发送到RabbitMQ之后，还需要有一段时间(虽然很短〉才能存入磁盘之中。RabbitMQ并不会为每条消息都进行同步存盘的处理，可能仅仅保存到操作系统缓存之中而不是物理磁盘之中。如果在这段时间内RabbitMQ 服务节点发生了岩机、重启等异常情况，消息保存还没来得及落盘，那么这些消息将会丢失。所以针对上面那个问题，答案是否定的。  
对于这种问题的出现，需要保证RabbitMQ的高可用，来增加RabbitMQ的可靠性，也就是要引入RabbitMQ的镜像队列机制，进行主从配置，如果主节点master 在此特殊时间内挂掉，可以自动切换到从节点slave, 这样有效地保证了高可用性，除非整个集群都挂掉。虽然这样也不能完全保证RabbitMQ消息 不丢失，但是配置了镜像队列要比没有配置镜像队列的可靠性要高很多，在实际生产环境中的关键业务队列一般都会设置镜像队列。  
       还有一点就是消费者消费消息，如果在订阅消费队列时将autoAck参数设置为true，那么当消费者接 收到相关消息之后，还没来得及处理就看机了，这样也算数据丢失。这种情况很好解决，将autoAck参数设置为false，并进行手动确认，这点和生产者投递消息保证一致性的处理机制，有着异曲同工之妙，就不再赘述了！  
![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0FwZW9wbA_size_16_color_FFFFFF_t_70 3][]  
        这样的保证消息一致性的解决方案，完全是靠着RabbitMQ的自身机制来解决的，然而这样的机制并不能保证消息百分之一百的不丢失，只是对于RabbitMQ来说已经尽力了，因为此时这样的消息系统，已经接近保证消息的一致性了，要想再更一步的百分百的保证，还要借助于外力来解决，具体要借助于怎样的外力，那么就要靠大家集思广益了！原谅我的能力不足！

[20190628163829731.png]: /images/20211220/8e81bc00e92f4b2c97835da0b7eb4d95.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0FwZW9wbA_size_16_color_FFFFFF_t_70]: /images/20211220/4f8b8aa275a140d1a3c8c26417fdb14d.png
[2019062816391553.png]: /images/20211220/fc2726294511484694d3885d009624a9.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0FwZW9wbA_size_16_color_FFFFFF_t_70 1]: /images/20211220/4bc9a4643cab4d149bf5c40d3a9b45c0.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0FwZW9wbA_size_16_color_FFFFFF_t_70 2]: /images/20211220/c66eb3120db34578b8bd64dd37c1541c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0FwZW9wbA_size_16_color_FFFFFF_t_70 3]: /images/20211220/7dcc187b269643c58b79893b85b9df4a.png