RabbitMQ如何避免消息丢失

系统管理员 2024-03-24 12:19 51阅读 0赞

#### 目录 ####

*   *  1.生产者没有成功把消息发送到MQ
     *  2.RabbitMQ接收到消息之后丢失了消息
     *  3.消费者弄丢了消息

> 前言

首先明确一点一条消息的传送流程：生产者->MQ->消费者  
![在这里插入图片描述][ffce5895aa6844ab9229fd6079a30974.png]  
我们根据这三个依次讨论

### 1.生产者没有成功把消息发送到MQ ###

丢失的原因：因为网络传输的不稳定性，当生产者在向MQ发送消息的过程中，MQ没有成功接收到消息，但是生产者却以为MQ成功接收到了消息，不会再次重复发送该消息，从而导致消息的丢失。  
解决办法 ：有两个解决办法：事务机制和confirm机制，最常用的是confirm机制。  
事务机制和cnofirm机制最大的不同在于，事务机制是同步的，你提交一个事务之后会阻塞在那儿，但是confirm机制是异步的，你发送个消息之后就可以发送下一个消息，然后那个消息rabbitmq接收了之后会异步回调你一个接口通知你这个消息接收到了。  
我们就谈谈confirm return(扩展一下)

> rabbitmq 整个消息投递的路径为：  
> producer—>rabbitmq broker—>exchange—>queue—>consumer

消息从 producer 到 exchange 则会返回一个 confirmCallback 。  
消息从 exchange–>queue 投递失败则会返回一个 returnCallback 。

confirm:使用 rabbitTemplate.setConfirmCallback 设置回调函数。当消息发送到 exchange 后回调 confirm 方法。在方法中判断 ack，如果为true，则发送成功，如果为false，则发送失败，需要处理。

return:使用 rabbitTemplate.setReturnCallback 设置退回函数，当消息从exchange 路由到 queue 失败后，如果设置了 rabbitTemplate.setMandatory(true) 参数，则会将消息退回给 producer并执行回调函数returnedMessage

### 2.RabbitMQ接收到消息之后丢失了消息 ###

丢失的原因：RabbitMQ接收到生产者发送过来的消息，是存在内存中的，如果没有被消费完，此时RabbitMQ宕机了，那么再次启动的时候，原来内存中的那些消息都丢失了。  
解决方案：开启RabbitMQ的持久化。当生产者把消息成功写入RabbitMQ之后，RabbitMQ就把消息持久化到磁盘。(持久化要起作用必须同时设置这两个持久化才行)

*  持久化可以跟生产者那边的confirm机制配合起来，只有消息被持久化到磁盘之后，才会通知生产者ack了，所以哪怕是在持久化到磁盘之前，rabbitmq挂了，数据丢了，生产者收不到ack，你也是可以自己重发的。
 *  若生产者那边的confirm机制未开启的情况下，哪怕是你给rabbitmq开启了持久化机制，也有一种可能，就是这个消息写到了rabbitmq中，但是还没来得及持久化到磁盘上，结果不巧，此时rabbitmq挂了，就会导致内存里的一点点数据会丢失。

### 3.消费者弄丢了消息 ###

丢失的原因：如果RabbitMQ成功的把消息发送给了消费者，那么RabbitMQ的ack机制会自动的返回成功，表明发送消息成功，下次就不会发送这个消息。但如果就在此时，消费者还没处理完该消息，然后宕机了，那么这个消息就丢失了。  
解决的办法：简单来说，就是必须关闭 RabbitMQ 的自动 ack  
none：自动确认，manual：手动确认  
如果在消费端没有出现异常，则调用channel.basicAck(deliveryTag，true);方法确认签收消息  
如果出现异常，则在catch中调用 basicNack，拒绝消息，让MQ重新发送消息。

[ffce5895aa6844ab9229fd6079a30974.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/24/591ca1371ca543afaf9f41466c05a395.png