当前位置：首页 > news >正文

rabbitMQ如何确保消息不会丢失

news 来源：原创 2025/5/6 14:56:31

在这里插入图片描述
rabbitmq消息丢失的三种情况

生产者将消息发送到RabbitMQ的过程中时，消息丢失。
消息发送到RabbitMQ，还未被持久化就丢失了数据。
消费者接收到消息，还未处理，比如服务宕机导致消息丢失。

解决方案

生产者发送过程中，消息丢失

方案1 - 开启RabbitMQ事务

生产者发送消息之前，开启RabbitMQ事务channel.txSelect，如果消息没有成功被RabbitMQ接收到，那么生产者会收到异常报错，此时可以回滚事务channel.txRollback，然后重试发送消息，如果收到了消息，那么可以正常提交事务。channel.txCommit。（不建议，同步阻塞）

方案2 - 使用confirm机制

事务机制和Confirm机制最大的不同在于，事务机制是同步的，提交一个事务之后会阻塞在那儿，但是Confirm机制是异步的。
在生产者开启confirm机制后，每次写消息都会分配一个唯一id，然后RabbitMQ正常处理了这个消息，RabbitMQ会回传给你一个ack消息，告诉你这个消息发送ok了，如果没能正常处理，会回调一个nack接口，告诉你这个消息失败了，此时，你可以对这个消息发起重试。
并且你可以基于这个机制，维护每个消息的id，如果超过一定的时候还没接收到这个消息的回调，你可以进行重发。（消费者需要做好幂等）

RabbitMQ 服务端消息丢失

丢失场景：

未持久化消息
磁盘损坏或集群故障

方案 - 消息持久化

RabbitMQ的消息默认存放在内存上的，如果不特别声明设置，消息不会持久化保存到硬盘上，如果节点重启或者意外crash掉，消息就会丢失。

Exchange 设置持久化
Queue 设置持久化
Message 设置持久化

方案 - 设置集群镜像模式

RabbitMQ有以下三种部署模式

单节点部署
最简单的模式，非集群模式，节点挂了，业务瘫痪
普通模式（默认集群模式）
消息只会存在主节点上，不会同步到其他节点，当前节点宕机，有影响的业务会瘫痪，只能等待节点重启后恢复可用，
镜像模式（镜像队列模式）
消息会同步到其他节点上，可以设置同步的节点个数，但吞吐量会下降，属于RabbitMQ的HA方案

以下是三种HA策略模式

同步所有的
同步最多N个机器的
只同步至服务执行名称的节点

消费者丢失消息

方案 - ACK确认机制

关闭自动应答（自动ack），业务服务端在确保正确处理完消息后，手动ack，避免消息还未被处理完就ack，这样就避免了，当一个消费者出了问题，也会有其他的消费者去消费，保证了消息不丢失的场景。