rabbitMq

rabbitMq如何保证消息不丢失？

❒ 消息从生产者到消费者流程
✔ publisher -> exchange -> queue -> consumer

❒ 消息丢失的几种可能
✔ 发送阶段丢失。
✔ 在中间件内存中丢失。
✔ 消费阶段丢失。

❒ rabbitMQ提供了publisher confirm机制来避免消息丢失。
✔ 消息未到交换机，返回nack publish-confirm。
✔ 消息未到消息队列，返回nack publish-return。
✔ 消息发送到队列成功，返回ack publish-confirm。

❒ 消息失败之后如何处理呢?
✔ 1. 生产者回调方法中及时重发。
✔ 2. 记录日志。
✔ 3. 保存到数据库然后定时重发，成功发送后即刻删除表中的数据。

❒ MQ默认是内存存储消息，开启持久化功能可以确保缓存在MQ中的消息不丢失。
✔ 持久化交换机。
✔ 持久化队列。
✔ 持久化消息。

❒ rabbitMQ支持消费者确认机制，即:消费者处理消息后可以向MQ发送ack回执，MQ收到ack回执后才会删除该消息而SpringAMQP则允许配置三种确认模式:
✔ manual：手动ack，需要在业务代码结束后，调用api发送ack。
✔ auto：自动ack，由spring监测listener代码是否出现异常，没有异常则返回ack;抛出常则返回nack。
✔ none：关闭ack，MQ假定消费者获取消息后会成功处理，因此消息投递后立即被删除。

我们可以利用spring的retry机制，在消费者出现异常时利用本地重试，设置重试次数，当次数达到了以后，如果消息依然失败，将消息投递到异常交换机，交由人工处理。

❒ 配套回答
✔ 开启生产者确认机制，确保生产者的消息能到达队列。
✔ 开启持久化功能，确保消息未消费前在队列中不会丢失。
✔ 开启消费者确认机制为auto，由spring确认消息处理成功后完成ack。
✔ 开启消费者失败重试机制，多次重试失败后将消息投递到异常交换机，交由人工处理。

❒ 补充回答
✔ 生产端：开启发布确认 + 返回机制、有限重试、消息持久化。
✔ broker端：交换机/队列持久化、消息体 deliveryMode=2、镜像队列（集群）。
✔ 消费端：手动 ACK、死信队列兜底、异常分类处理。
✔ 兜底：消息落地数据库、定时补偿、监控告警。