解决RabbitMQ数据丢失

1）生产者弄丢了数据

生产者将数据发送到rabbitmq的时候，可能数据就在半路给搞丢了，因为网络啥的问题，都有可能。

解决：

RabbitMQ提供transaction和confirm模式来确保生产者不丢消息。transaction机制就是说，发送消息前
开启事物(channel.txSelect())，然后发送消息，如果发送过程中出现什么异常，
事物就会回滚(channel.txRollback())，如果发送成功则提交事物(channel.txCommit())。然而缺点就是吞吐量下降了。
因此，生产上用confirm模式的居多。一旦channel进入confirm模式，所有在该信道上面发布的消息都将会被指派一个唯一的ID(从1开始)，
一旦消息被投递到所有匹配的队列之后，rabbitMQ就会发送一个Ack给生产者(包含消息的唯一ID)，
这就使得生产者知道消息已经正确到达目的队列了.如果rabiitMQ没能处理该消息，则会发送一个Nack消息给你，你可以进行重试操作。

2）rabbitmq弄丢了数据

就是rabbitmq自己弄丢了数据，这个你必须开启rabbitmq的持久化，就是消息写入之后会持久化到磁盘，
哪怕是rabbitmq自己挂了，恢复之后会自动读取之前存储的数据，一般数据不会丢
。除非极其罕见的是，rabbitmq还没持久化，自己就挂了，可能导致少量数据会丢失的，但是这个概率较小。

设置持久化：

MQ丢失数据：
交找机持久化、channel.exchangeDeclare(exchange_name,”topic”,true);
声明交换机、指定类型为topic、设为true
队列持久化、channel.queueDeclare(QUEUE_NAME,true,false,false,null);
声明队列、第二个为true
消自持久化、channel.basicPublish(exchange_name,”item.update”,MessageProperties.PERSISTENT_TEXT_PLAIN,MESSAGE.GETbYTES());
MESSAGEPROPER...为持久化

解决：

处理消息队列丢数据的情况，一般是开启持久化磁盘的配置。这个持久化配置可以和confirm机制配合使用，
你可以在消息持久化磁盘后，再给生产者发送一个Ack信号。
这样，如果消息持久化磁盘之前，rabbitMQ阵亡了，那么生产者收不到Ack信号，生产者会自动重发。

3）消费端弄丢了数据

rabbitmq如果丢失了数据，主要是因为你消费的时候，刚消费到，还没处理，
结果进程挂了，比如重启了，那么就尴尬了，rabbitmq认为你都消费了，这数据就丢了。

解决：

启用手动确认模式可以解决这个问题（重试机制）
手动确认模式，如果消费者来不及处理就死掉时，没有响应ack时会重复发送一条信息给其他消费者；
如果监听程序处理异常了，且未对异常进行捕获，会一直重复接收消息，然后一直抛异常；
如果对异常进行了捕获，但是没有在finally里ack，也会一直重复发送消息(重试机制)。

解决RabbitMQ数据丢失相关推荐

解决RabbitMQ消息丢失与重复消费问题
解决RabbitMQ消息丢失与重复消费问题参考文章: (1)解决RabbitMQ消息丢失与重复消费问题 (2)https://www.cnblogs.com/sessionbest/articles ...
解决RabbitMQ保错 Error: unable to connect to node rabbit@localhost: nodedown
解决RabbitMQ保错 Error: unable to connect to node rabbit@localhost: nodedown 查询mq的进程 ps -ef | grep rabbi ...
rabbitmq可靠性投递_解决RabbitMQ消息丢失问题和保证消息可靠性（一）
工作中经常用到消息中间件来解决系统间的解耦问题或者高并发消峰问题,但是消息的可靠性如何保证一直是个很大的问题,什么情况下消息就不见了?如何防止消息丢失?下面通过这篇文章,我们就聊聊RabbitMQ 消 ...
解决RabbitMQ service is already present - only up...
2019独角兽企业重金招聘Python工程师标准>>> C:\Users\Administrator>rabbitmq-service install RabbitMQ ser ...
解决rabbitmq收到消息打印告警消息
现象:收到消息会打印告警消息::Could not convert incoming message with content-type [null] 解决: RabbitMQ已经实现了Jackson ...
（转）解决RabbitMQ service is already present - only updating service parameters
C:\Users\Administrator>rabbitmq-service install RabbitMQ service is already present - only updati ...
RabbitMQ:Plugin configuration unchanged；解决RabbitMQ启动问题,Win10用户中文问题解决
首先MQ是什么? MQ是Message Queue消息队列的缩写.消息队列是一种应用程序对应用程序的通信方法.应用程序通过写和检索入列队的针对应用程序的数据(消息)来进行通信,而不需要专用连接来链接它 ...
离线解决Rabbitmq启动报“line 80: erl: command not found”
问题描述: 部署一套新环境,因为该环境的机器规定不能连外网,rabbitmq采用离线部署的方式. 将本地yum下载的rabbitmq所需rpm包手动上传到该环境的机器离线部署.所有的rpm包都和本地在 ...
解决rabbitmq add_user 报错
rabbitmq 安装完成之后会有个可执行文件 rabbitmqctl 通过这个可执行文件去添加用户,报错报错情况如下: $ rabbitmqctl add_user seabed seabed ...

解决RabbitMQ数据丢失

解决RabbitMQ数据丢失相关推荐

最新文章

热门文章