男生为女生做网站,免费的网站入口在哪,wordpress数据在哪个文件夹,重庆app下载注册一、生产者确认机制 RabbitMQ提供了publisher confirm机制来避免消息发送到MQ过程中丢失。消息发送到MQ以后#xff0c;会返回一个结果给发送者#xff0c;表示消息是否处理成功。 当消息没有到交换机就失败了#xff0c;就会返回publish-confirm。当消息没有到达MQ时…一、生产者确认机制 RabbitMQ提供了publisher confirm机制来避免消息发送到MQ过程中丢失。消息发送到MQ以后会返回一个结果给发送者表示消息是否处理成功。 当消息没有到交换机就失败了就会返回publish-confirm。当消息没有到达MQ时就会返回publish-return。 消息失败之后如何处理呢 1. 回调方法即时重发。 2. 记录日志。 3. 保存到数据库然后定时重发成功发送后即刻删除表中的数据。
二、 消息持久化 当消息发送到MQ但是MQ如果宕机消息也发送失败。
MQ默认是内存存储消息开启持久化功能可以确保缓存在MQ中的消息不丢失 1. 交换机持久化。 2. 队列持久化。 3. 消息持久化SpringAMQP中的的消息默认是持久的可以通过MessageProperties中的DeliveryMode来指定的。 三、 消费者确认 当消息发送到消费者时但是消费者如果宕机消息也发送失败。 RabbitMQ支持消费者确认机制即消费者处理消息后可以向MQ发送ack回执MQ收到ack回执后才会删除该消息。而SpringAMQP则允许配置三种确认模式 1. manual手动ack需要在业务代码结束后调用api发送ack。 2. auto自动ack由spring监测listener代码是否出现异常没有异常则返回ack抛出异常则返回nack。 3. none关闭ackMQ假定消费者获取消息后会成功处理因此消息投递后立即被删除。
那发送消息失败应该怎么做我们可以利用Spring的retry机制在消费者出现异常时利用本地重试设置重试次数当次数达到了以后如果消息依然失败将消息投递到异常交换机交由人工处理。 四、面试题
面试官RabbitMQ-如何保证消息不丢失
候选人我们当时MYSQL和Redis的数据双写一致性就是采用RabbitMQ实现同步的这里面就要求了消息的高可用性我们要保证消息的不丢失。主要从三个层面考虑
第一个是开启生产者确认机制确保生产者的消息能到达队列如果报错可以先记录到日志中再去修复数据。
第二个是开启持久化功能确保消息未消费前在队列中不会丢失其中的交换机、队列、和消息都要做持久化。
第三个是开启消费者确认机制为auto由spring确认消息处理成功后完成ack当然也需要设置一定的重试次数我们当时设置了3次如果重试3次还没有收到消息就将失败后的消息投递到异常交换机交由人工处理。
