当前位置：首页 - 正文

rabbitmq保证消息不丢失？

发布网友发布时间：2022-03-26 08:21

我来回答

共2个回答

热心网友时间：2022-03-26 09:51

我是在网上粘贴复制的。

mq原则

数据不能多，也不能少，不能多是说消息不能重复消费，这个我们上一节已解决；不能少，就是说不能丢失数据。如果mq传递的是非常核心的消息，支撑核心的业务，那么这种场景是一定不能丢失数据的。

2.丢失数据场景

丢数据一般分为两种，一种是mq把消息丢了，一种就是消费时将消息丢了。下面从rabbitmq和kafka分别说一下，丢失数据的场景，
（1）rabbitmq
A:生产者弄丢了数据生产者将数据发送到rabbitmq的时候，可能在传输过程中因为网络等问题而将数据弄丢了。
B:rabbitmq自己丢了数据如果没有开启rabbitmq的持久化，那么rabbitmq一旦重启，那么数据就丢了。所依必须开启持久化将消息持久化到磁盘，这样就算rabbitmq挂了，恢复之后会自动读取之前存储的数据，一般数据不会丢失。除非极其罕见的情况，rabbitmq还没来得及持久化自己就挂了，这样可能导致一部分数据丢失。
C：消费端弄丢了数据主要是因为消费者消费时，刚消费到，还没有处理，结果消费者就挂了，这样你重启之后，rabbitmq就认为你已经消费过了，然后就丢了数据。

3.如何防止消息丢失

（1）rabbitmq

A:生产者丢失消息

①：可以选择使用rabbitmq提供是事物功能，就是生产者在发送数据之前开启事物，然后发送消息，如果消息没有成功被rabbitmq接收到，那么生产者会受到异常报错，这时就可以回滚事物，然后尝试重新发送；如果收到了消息，那么就可以提交事物

channel.txSelect();//开启事物try{//发送消息}catch(Exection e){channel.txRollback()；//回滚事物//重新提交}复制代码

缺点： rabbitmq事物已开启，就会变为同步阻塞操作，生产者会阻塞等待是否发送成功，太耗性能会造成吞吐量的下降。

②：可以开启confirm模式。在生产者哪里设置开启了confirm模式之后，每次写的消息都会分配一个唯一的id，然后如何写入了rabbitmq之中，rabbitmq会给你回传一个ack消息，告诉你这个消息发送OK了；如果rabbitmq没能处理这个消息，会回调你一个nack接口，告诉你这个消息失败了，你可以进行重试。而且你可以结合这个机制知道自己在内存里维护每个消息的id，如果超过一定时间还没接收到这个消息的回调，那么你可以进行重发。

//开启confirmchannel.confirm();//发送成功回调public void ack(String messageId){}// 发送失败回调public void nack(String messageId){//重发该消息}复制代码

二者不同事务机制是同步的，你提交了一个事物之后会阻塞住，但是confirm机制是异步的，发送消息之后可以接着发送下一个消息，然后rabbitmq会回调告知成功与否。一般在生产者这块避免丢失，都是用confirm机制。
B:rabbitmq自己弄丢了数据设置消息持久化到磁盘。设置持久化有两个步骤：
①创建queue的时候将其设置为持久化的，这样就可以保证rabbitmq持久化queue的元数据，但是不会持久化queue里面的数据。
②发送消息的时候讲消息的deliveryMode设置为2，这样消息就会被设为持久化方式，此时rabbitmq就会将消息持久化到磁盘上。必须要同时开启这两个才可以。

而且持久化可以跟生产的confirm机制配合起来，只有消息持久化到了磁盘之后，才会通知生产者ack，这样就算是在持久化之前rabbitmq挂了，数据丢了，生产者收不到ack回调也会进行消息重发。
C:消费者弄丢了数据使用rabbitmq提供的ack机制，首先关闭rabbitmq的自动ack，然后每次在确保处理完这个消息之后，在代码里手动调用ack。这样就可以避免消息还没有处理完就ack。

热心网友时间：2022-03-26 11:09

流量削峰：通过消息队列设置请求最大值,超过阀值的抛弃或者转到错误界面

所有的MQ都不能做到永不丢失吧

详细讲解!RabbitMQ如何防止数据丢失,看这篇就够了

消息持久化可以防止消息在RabbitMQ Server中不会因为宕机重启而丢失。三、消息确认机制 3.1 confirm机制在生产者发送到RabbitMQ Server时有可能因为网络问题导致投递失败，从而丢失数据。我们可以使用confirm模式防止数据丢失。工作流程是怎么样的呢，看以下图解：从上图中可以看到是通过两个回调函数confirm()...

RabbitMQ消息丢失的场景,如何保证消息不丢失?(详细讲解,一文看懂)_百...

RabbitMQ作为主流的消息中间件，消息丢失可能源自生产者、RabbitMQ本身或消费端。为确保消息不丢失，我们需要采取一系列措施：生产者端：可启用事务或confirm机制。事务模式下，消息发送失败会回滚，confirm机制异步监控消息确认，超时或失败后重试。但需注意事务模式可能影响性能。 RabbitMQ层面：启用持久化，...

《RabbitMQ》 | 消息丢失也就这么回事

首先，了解消息丢失的原因。消息可能在发送、路由到队列或消费者消费时丢失。为防范于未然，我们需要关注工程结构，使用Spring Boot项目构建消费者和生产者模块。生产者发送丢失RabbitMQ的publisher confirm机制能避免发送过程中的丢失。通过设置全局唯一ID，确保消息确认成功。配置文件中需开启publisher confirm和p...

《RabbitMQ》 | 消息丢失也就这么回事

消息存储丢失消息存储丢失指的是当消息已经成功发送到队列，但消费者未能及时消费，此时MQ重启，可能导致消息丢失。为了解决这一问题，我们需要启用持久化功能，确保消息在MQ中的存储不丢失。在RabbitMQ的GUI创建交换机或队列时，可以发现有持久化的选项。将durability设为durable后，重启MQ，交换机和队列依然...

RabbitMQ 是如何避免消息丢失的?

RabbitMQ 提供了多种机制来避免消息丢失，例如：- 持久化消息：可以将消息存储在磁盘上，以便在服务器重启或崩溃后重新加载。- 消息确认：消费者在收到消息后向 RabbitMQ 发送确认信号，以便 RabbitMQ 知道该消息已被成功处理。- 死信队列：可以将无法处理的消息放入死信队列中，以便稍后再次尝试处理。- ...

RabbitMQ面试题:如何确保消息不丢失? --- 2022-04-03

下面从多个方面确保消息不丢：RabbitMQ 的消息默认存放在内存上面，如果不特别声明，消息不会持久化保存到硬盘上面，如果节点重启或者意外crash掉，消息就会丢失。要想做到消息持久化，必须满足以下三个条件：默认情况消费者收到消息，MQ就会从队列中删除消息，如果消费者没处理成功，消息就丢了，可以使用手动...

RabbitMQ消息丢失问题解析与解决方案

RabbitMQ，作为常用的消息队列中间件，有时会遭遇消息丢失问题，这对于保证应用间可靠通信至关重要。本文将深入剖析消息丢失的几个原因，并提供相应的解决策略。首先，生产者与消费者速度不匹配可能导致消息堆积，进而丢失。其次，队列满载时，新消息无法加入，造成消息丢失。确认机制处理不当，如未正确确认...