做推广的网站,阿里云网站建设和部署框架,WordPress更改自定义侧边栏宽度,手机兼职群RabbitMQ如何保证消息不丢失#xff1f;
消息丢失的情况
生产者发送消息未到达交换机生产者发送消息未到达队列MQ宕机#xff0c;消息丢失消费者服务宕机#xff0c;消息丢失
生产者确认机制
解决的问题#xff1a;publisher confirm机制来避免消息发送到MQ过程中消失。…RabbitMQ如何保证消息不丢失
消息丢失的情况
生产者发送消息未到达交换机生产者发送消息未到达队列MQ宕机消息丢失消费者服务宕机消息丢失
生产者确认机制
解决的问题publisher confirm机制来避免消息发送到MQ过程中消失。
当消息成功发送到MQ会返回一个publish-confirm ack(acknowledge)
消息发送到交换机失败 publish-confirm nack
消息路由到队列失败publish-return ack
消息失败后如何处理 回调方法即时重发再发一次记录日志如果重发后还是失败可以记录到日志中保存到数据库然后定时重发成功发送后即可删除表中的数据再失败的话人工解决
持久化
保证保存在MQ中的消息不丢失。
MQ默认是内存存储消息开启持久化功能可以确保缓存在MQ中的消息不丢失。
交换机持久化队列持久化消息持久化
消费者确认
处理问题消费者导致的消息丢失问题。
消费者确认机制消费者处理消息后可以向MQ发送ack回执MQ收到ack回执后才会删除该消息。
SpringAMQP可以配置的三种确认模式
manual: 手动ack
auto:自动ack。Spring检测listener代码是否异常。
none: 关闭ackMQ假定消费者获取消息后会成功处理因此消息投递后立即被删除。
