RabbitMQ 高可用之如何确保消息成功消费

1. 两种消费思路

在RabbitMQ中，消息消费有两种思路，推模式和拉模式。推模式通过缓冲区缓存消息，效率较高；拉模式消费者主动拉取消息，适合批量拉取但效率不高。

2. 确保消费成功两种思路

消息消费成功可通过autoAck参数设置自动确认或手动确认。autoAck为false时，消费者需手动确认消息；为true时，消息自动确认并移除。

3. 消息拒绝

消费者可拒绝消息，通过basicReject方法，指定是否重新入队。

4. 消息确认

4.1 自动确认

默认情况下，Spring Boot中的消息消费是自动确认的，如果消费方法抛出异常，则消息重新入队。

4.2 手动确认

手动确认分为推模式和拉模式两种。推模式下，配置acknowledge-mode为manual，消息处理成功后调用basicAck方法确认；失败时调用basicNack方法。拉模式手动确认较为复杂，需使用原生方法确认。

5. 幂等性问题

由于可能发生的消息重复消费，处理幂等性问题十分重要。一般通过业务逻辑，如使用Redis标记消息状态，确保消息只被成功消费一次。

6. 小结

本文概述了RabbitMQ中消息消费的相关知识点，包括消费方式、确认机制、拒绝处理和幂等性问题的解决，供读者参考和实践。