面试题：RabbitMQ 消息队列中间件

1. 确保消息不丢失

• 生产者确认机制
  确保生产者的消息能到达队列，如果报错可以先记录到日志中，再去修复数据
• 持久化功能
  确保消息未消费前在队列中不会丢失，其中的交换机、队列、和消息都要做持久化
• 消费者确认机制
  由spring确认消息处理成功后完成ack，当然也需要设置一定的重试次数，我们当时设置了3次，如果重试3次还没有收到消息，就将失败后的消息投递到异常交换机，交由人工处理

2. 消息重复消费问题

出现背景：消费者设置了自动确认机制，在消费者消费完消息后的 ACK 确认消息因为网络波动或者宕机的原因没有发送到 MQ，MQ中的消息并没有删除，这就将会导致消息的重复消费

解决方案：

• 消息唯一ID
  给每一条消息的设置一个唯一标识ID，我们在处理消息时，先到数据库查询一下，这个消息是否已经处理过，如果没有处理过，这个时候就可以正常处理这个消息了，处理前就可以把当前的 消息ID 标记为 处理中，处理完成后 再把此 消息ID 标记为 处理完。如果已经处理过这个消息了，就说明消息重复消费了，我们就不需要再消费了。
• 幂等问题：数据库的唯一约束和锁、分布式锁？

3. 延迟队列

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/菜鸟追梦旅行/article/detail/360695