RabbitMQ保证消息不丢失
消息丢失的情况
(1)生产者方面:生产者发送消息至MQ的数据丢失 (2)RabbitMQ方面:MQ收到消息,暂存内存中,还没消费,自己挂掉,数据会都丢失 (3)消费者方面:消费者刚拿到消息,还没处理,挂掉了,MQ又以为消费者处理完
解决方法
1.配置文件中添加
#消息已发送到交换机(Exchange)时返回
spring.rabbitmq.publisher-confirm-type=correlated
# 消息在未被队列收到的情况下返回
spring.rabbitmq.template.mandatory=true
spring.rabbitmq.publisher-returns=true
# 开启消息手动确认机制
spring.rabbitmq.listener.simple.acknowledge-mode=manual
2.config类配置
package com.example.
共有 0 条评论