RabbitMQ如何保证消息不丢失？

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.开启消费者失败重试机制，配置重试次数、重试时间

        5.改变默认失败重试策略，多次重试失败后将消息投递到异常交换机，交由人工处理