【RabbitMQ】RabbitMQ消息的重复消耗标题怎样办理？

可以从消息队列和消耗者两方面入手，确保消息处置处罚的幂等性和可靠性。
1.消息重复消耗的缘故原由

1.1消息队列的机制

• 消息确认失败： 消耗者处置处罚完消息后，未精确发送确认(ACK)给RabbitMQ，导致消息被重新投递。
  
• 消息重试机制：RabbitMQ在消耗者处置处罚失败时，会自动重试投递消息。
  
• 网络标题： 网络抖动或超时大概导致消息重复投递。
  

1.2消耗者端

• 幂等性未实现：消耗者未实现幂等性处置处罚逻辑，导致同一条消息被多次处置处罚。
  
• 并发消息标题： 多个消耗者同时消耗同一条消息，导致重复处置处罚。
  

2.办理方案

2.1确保消息处置处罚的幂等性

• 幂等性：无论同一条消息被消耗多少次，效果都是划一的。
  
• 实现方式：
  1.数据库唯一束缚：
  
  
  
  • 在数据库中为消息ID或业务唯一标识添加唯一束缚，克制重复插入。
    
  
  

1. CREATE TABLE orders (
2.     id BIGINT PRIMARY KEY,
3.     order_id VARCHAR(50) UNIQUE,
4.     -- 其他字段
5. );

复制代码

2.Redis去重：

• 利用Redis的SETNX下令判断消息是否已处置处罚。
  

1. String messageId = "msg_123";
2. if (redis.setnx(messageId, "processed") == 1) {
3.     // 处理消息
4. } else {
5.     // 消息已处理，直接返回
6. }

复制代码

3.状态机：

• 为消息处置处罚过程筹划状态机，确保每个消息只能从初始状态转移到完成状态一次。
  

1. if (message.getStatus() == Status.INIT) {
2.     // 处理消息
3.     message.setStatus(Status.PROCESSED);
4. }

复制代码

2.2优化消息确认机制

2.3消息去重

2.4控制消息重试

2.5并发控制

3.示例场景

4.总结

• 
  
  
  
  • 消息重复消耗的缘故原由包罗消息队列机制、消耗者端逻辑标题
    
  
  
• 办理方案：
  
  
  
  • 确保消息处置处罚的幂等性。
    
  • 优化消息确认机制，克制消息丢失。
    
  • 利用消息队列大概消耗者端的去重功能。
    
  • 控制消息的重试次数，克制无穷重试。
    
  • 通过并发控制克制多个消耗者同时处置处罚同一条消息。
    
  
  

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。