如何保证消息的可靠性，避免消息丢失

悠悠 2023-10-14 11:56 68阅读 0赞

**出现消息丢失的情况有三种：**

（1）生产者把消息发送到RabbitMQ Server的过程中丢失

（2）RabbitMQ Server 收到消息后再持久化之前宕机导致消息 丢失

（3）消费端收到消息还没来得及处理，此时宕机，导致RabbitMQ Server认为这个消息已签收，无法重复投递导致消息丢失

所以我认为保证消息可靠性从  **生产者、   MQ   、消费者中**  这三个方面着手就可以了

**解决方案：**

**从生产者发送消息到Server端的角度：**  RabbitMQ提供了事务（transaction）和确认（confirm）两种模式来确保生产者不丢消息。

（1）开启事务channel.txSelect()，然后发送消息，如果发送过程中出现什么异常，事务就会回滚channel.txRollback()，如果发送成功则提交事务channel.txCommit()，但是这种方式是同步的，会导致吞吐量下降；

（2）confirm确认模式：RabbitMQ提供了一个Confirm消息确认机制，消息从生产者发送到Server端以后，如果消息处理成功，Server端会返回一个ack的消息，那么客户端可以根据消息的处理结果，来决定是否要对消息进行重新发送，从而确保消息发送到Server端上。

**从RabbitMQ Server端的角度：**  可以开启消息的持久化机制，也就是收到消息之后持久化到磁盘里面。设置持久化的方式有两个步骤：

（1）创建Queue的时候设置为持久化

（2）发送消息的时候，把消息投递模式设置为持久化投递。

不过虽然设置了持久化消息，但是有可能也会出现问题，比如消息刷新到磁盘之前，RabbitMQ的Server 端宕机，导致消息丢失的一个问题。所以为了确保万无一失，我们需要结合Confirm消息确认机制来一起使用。

**从消费端的角度：**  我们可以把消息的自动确认机制修改为手动确认，也就是消费端只有手动调用消息确认方法，才表示这个消息已经被签收。

这种方式可能会造成消息的重复消费的问题，这里需要考虑到幂等性的一个设计。

以上就是我对保证消息的可靠性的全部理解。

![up-49aef71276ad81c179e3d34a8b48d011153.png][]

*  生产者提交给消息服务器时，使用确认机制
 *  消息服务器对应的队列、交换机等都持久化，保证数据的不丢失
 *  消费者关闭RabbitMQ自动ACK，采用消息确认机制，保证数据的不丢失

[up-49aef71276ad81c179e3d34a8b48d011153.png]: https://oscimg.oschina.net/oscnet/up-49aef71276ad81c179e3d34a8b48d011153.png

发表评论取消回复

表情：

评论列表（有 0 条评论，68人围观）

还没有评论，来说两句吧...

相关阅读

相关如何保证消息的可靠性，避免消息丢失

出现消息丢失的情况有三种：（1）生产者把消息发送到RabbitMQ Server的过程中丢失（2）RabbitMQ Server 收到消息后再持久化之前宕机导致消息

悠悠/ 2023年10月14日 11:56/ 0 赞/ 69 阅读

相关解决RabbitMQ消息丢失问题和保证消息可靠性

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E3NzIz

小鱼儿/ 2023年10月07日 11:43/ 0 赞/ 55 阅读

相关如何保证消息的可靠性传输（如何处理消息丢失的问题）？

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ub

悠悠/ 2023年10月05日 15:09/ 0 赞/ 9 阅读

相关如何保证 RabbitMQ 的消息可靠性

前言项目开发中经常会使用消息队列来完成异步处理、应用解耦、流量控制等功能。虽然消息队列的出现解决了一些场景下的问题，但是同时也引出了一些问题，其中使用消息队列时如何保证

不念不忘少年蓝@/ 2023年09月27日 18:27/ 0 赞/ 127 阅读

相关如何保证消息的可靠性传输？（如何处理消息丢失的问题）

面试题如何保证消息的可靠性传输？或者说，如何处理消息丢失的问题？面试官心理分析这个是肯定的，用 MQ 有个基本原则，就是数据不能多一条，也不能少一条，不能多

Myth丶恋晨/ 2023年06月04日 14:58/ 0 赞/ 12 阅读

相关如何保证消息可靠性？

文章目录一、消息可靠性方案二、消息丢失三、消息重复四、消息积压一、消息可靠性方案 ① 持久化 `exchange`要持久

蔚落/ 2023年01月19日 04:59/ 0 赞/ 24 阅读

相关 rabbitmq如何保证消息可靠性不丢失

> 之前我们简单介绍了rabbitmq的功能。他的作用就是方便我们的消息解耦。紧接着问题就会暴露出来。解耦就设计到双方系统不稳定问题。在mq中有生产者、mq、消费者三个角色。其

小咪咪/ 2022年11月05日 04:29/ 0 赞/ 17 阅读

相关如何保证消息的可靠性传输？或者说，如何处理消息丢失的问题？

RabbitMQ ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ib

落日映苍穹つ/ 2022年01月21日 08:04/ 0 赞/ 251 阅读

相关如何保证消息的可靠性传输

如何保证消息的可靠性传输面试题引入面试题剖析 RabbitMQ Kafka 面试题引入如何保证消息的可靠性传输？其实就

朴灿烈づ我的快乐病毒、/ 2021年10月19日 16:46/ 0 赞/ 359 阅读

相关《RabbitMQ》如何保证消息的可靠性

一条消费成功被消费经历了生产者->MQ->消费者，因此在这三个步骤中都有可能造成消息丢失。一消息生产者没有把消息成功发送到MQ 1.1 事务机制 `AMQP`

短命女/ 2021年09月18日 05:40/ 0 赞/ 446 阅读