RabbitMQ怎样包管消息不丢失

RabbitMQ怎样包管消息不丢失

消息未到达交换机

消息未到达队列

队列中消息丢失

斲丧者未吸收到消息

生产者确认机制

克制消息发送到MQ过程中丢失
当消息发送到MQ后会返回一个结果给返回者
在差别环节中,返回的ACK差别
消息失败后怎样处置惩罚

在回调方法中举行重试
纪录日记
落库重发,发送后删除表中数据
MQ消息长期化

克制消息在mq中时mq宕机
交换机长期化

队列长期化

消息长期化(默认)

斲丧者确认机制

手动ACK

须要手动调用API举行发送
自动ACK(常用)

Spring检测代码是否出现非常,根据结果判断是否返回ack
关闭ACK(不常用)

Spring重试机制

斲丧者出现非常时,举行本地重试并设置重试次数
假如重试次数斲丧完时仍旧失败
将消息投递到非常交换机,投递到非常队列中处置惩罚