1、什么情况会导致消息丢失?
a.发送时丢失:
生产者发送的消息未送达exchange
消息到达exchange后未到达queue
b.MQ宕机,queue将消息丢失
c.consumer接收到消息后未消费就宕机
2、如何保证息不丢失,就是分别避免每一个环节丢失
a.保证生产者不丢消息
b.保证rabbitmq不丢消息
c.保证消费端不丢消息
3、RabbitMQ生产者如何避免消息丢失?
a.保证生产者不丢消息,要确保说写rabbitmq的消息别丢,可以开启。
b.每次写的消息都会分配一个唯一的id,如果写入了rabbitmq中,rabbitmq会给你回传一个ack消息,告诉你说这个消息ok了。
c.如果rabbitmq没能处理这个消息,会回调你一个nack接口,告诉你这个消息接收失败,我们可以重试。
(publisher-confirm,发送者确认消息成功投递到交换机,返回ack;消息未投递到交换机,返回nack。publisher-return,发送者回执,消息投递到交换机,但是没有路由到队列。返回ACK,及路由失败原因。)
4、如何实现消息持久化?(注意:SpringAMQP默认已经进行持久化)
a.保证rabbitmq不丢消息,开启rabbitmq的持久化(持久化queue和message、exhange),设置不能自动删除
b.交换机持久化 :
c.持久化queue,在创建queue的时候将其设置为持久化的,这样就可以保证rabbitmq持久化queue的元数据,但是不会持久化queue里的数据。
d.持久化Message,在发送消息的时候将消息的deliveryMode设置为2,就是将消息设置为持久化的,此时rabbitmq就会将消息持久化到磁盘上去。
4、消费者有几种确认机制?
RabbitMQ支持消费者确认机制:消费者处理消息后可以向MQ发送ack回执,MQ收到ack回执后才会删除该消息。SpringAMQP允许配置三种确认模式:
none:关闭ack,MQ假定消费者获取消息后会成功处理,因此消息投递后立即被删除。
manual:手动ack,需要在业务代码结束后,调用api发送ack。
auto:自动ack,由spring监测listener代码是否出现异常,没有异常返回ack;有异常返回nack(默认)。(注意:auto默认方式,消费者消息处理异常后消息会重新入队,如果消费者一直异常则会一直死循环。)
方式是修改application.yml文件,添加下面配置:
5、消费者消费失败后如何解决死循环导致MQ压力大?(注意:重试次数达到后,消息被丢弃。)
当消费者出现异常后,消息会不断requeue(重新入队)到队列,再重新发送给消费者,然后再次异常,再次requeue,无限循环,导致mq的消息处理飙升,带来不必要的压力:
我们可以利用Spring的retry机制,在消费者出现异常时利用本地重试,而不是无限制的requeue到mq队列。
开启Spring本地重试模式后,重试次数耗尽,如果消息依然失败,则需要有MessageRecoverer接口来处理,它包含三种不同的实现:
a.RejectAndDontRequeueRecoverer:重试耗尽后,直接reject,丢弃消息。默认就是这种方式。
b.ImmediateRequeueMessageRecoverer:重试耗尽后,返回nack,消息重新入队。
c.RepublishMessageRecoverer:重试耗尽后,将失败消息投递到指定的交换机(推荐使用)。
测试下RepublishMessageRecoverer处理模式:
创建配置类ErrorMessageConfig,定义接收失败消息的交换机、队列及其绑定关系: 然后,定义RepublishMessageRecoverer:
6、如何确保RabbitMQ消息的可靠性(面试)?
1.开启生产者确认机制,确保生产者的消息能到达队列
2.开启持久化功能,确保消息未消费前在队列中不会丢失
3.开启消费者确认机制为auto,由spring确认消息处理成功后完成ack
4.开启消费者失败重试机制,配置重试次数、重试时间文章来源:https://www.toymoban.com/news/detail-784769.html
5.改变默认失败重试策略,多次重试失败后将消息投递到异常交换机,交由人工处理文章来源地址https://www.toymoban.com/news/detail-784769.html
到了这里,关于RabbitMQ如何保证消息不丢失?的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!