解决MQ下单消息重复消费幂等机制详解

简介: 【11月更文挑战第20天】在分布式系统中,消息队列(Message Queue, MQ)作为一种常用的中间件,用于在不同系统或服务之间异步传输消息。MQ的应用场景广泛,如订单处理、日志收集、系统解耦等。然而,MQ的使用也伴随着一些挑战,其中消息重复消费是一个常见问题。特别是在下单场景中,如果消息被重复消费,可能会导致订单被重复创建或处理,从而引发一系列业务问题。

一、历史与背景

在分布式系统中,消息队列(Message Queue, MQ)作为一种常用的中间件,用于在不同系统或服务之间异步传输消息。MQ的应用场景广泛,如订单处理、日志收集、系统解耦等。然而,MQ的使用也伴随着一些挑战,其中消息重复消费是一个常见问题。特别是在下单场景中,如果消息被重复消费,可能会导致订单被重复创建或处理,从而引发一系列业务问题。

消息重复消费的问题并非MQ系统本身的设计缺陷,而是由于网络不稳定、消费者故障、负载均衡调整等多种因素导致的。为了解决这一问题,引入了幂等性机制。幂等性(Idempotence)是一个数学和计算机科学概念,指的是一个操作无论执行多少次,其结果都相同。在消息消费场景中,幂等性要求即使消息被重复消费,也不会对业务逻辑产生副作用。

二、功能点

幂等性机制的核心功能点包括:

  1. 唯一标识:每条消息在发送时都会携带一个唯一标识(如订单号、消息ID等),用于在消费时判断消息是否已被处理过。
  2. 去重逻辑:消费者在接收到消息后,首先检查该消息的唯一标识是否已存在,如果存在则直接跳过处理,否则执行相应的业务逻辑。
  3. 业务逻辑幂等:业务逻辑本身需要设计成幂等的,即多次执行相同操作不会产生不同的结果。

三、业务场景

以电商平台的下单场景为例,当用户点击“提交订单”按钮后,系统会生成一条下单消息并发送到MQ中。订单服务作为消费者从MQ中拉取消息并进行处理,包括创建订单、扣减库存、生成支付单等。在这个过程中,如果由于网络问题或消费者故障导致消息被重复消费,可能会出现以下问题:

  • 订单重复创建:同一条下单消息被消费多次,导致生成了多个相同的订单。
  • 库存超扣:如果库存扣减逻辑没有幂等性设计,多次扣减可能会导致库存变为负数。
  • 支付单重复生成:支付单与订单一一对应,订单重复会导致支付单也重复生成。

为了避免上述问题,需要在下单消息的消费过程中引入幂等性机制。

四、底层原理

幂等性机制的实现依赖于消息的唯一标识和业务逻辑的幂等设计。以下是幂等性机制的主要实现原理:

1. 唯一标识的生成与传递

在消息发送时,生产者会为每条消息生成一个唯一标识,并将其作为消息的一部分进行传递。这个唯一标识可以是订单号、UUID、时间戳+序列号等。唯一标识的生成需要保证全局唯一性,以避免不同消息之间发生冲突。

2. 去重逻辑的实现

消费者在接收到消息后,首先会检查该消息的唯一标识是否已存在。检查的方式有多种,包括:

  • 数据库去重表:消费者维护一个去重表,表中包含已处理消息的唯一标识。在消费消息前,先查询去重表,如果唯一标识已存在则跳过处理。
  • Redis缓存:利用Redis的setnx命令实现分布式锁或去重逻辑。消费者在消费消息前,尝试将唯一标识设置到Redis中,如果设置成功则进行处理,否则跳过。
  • 消息体本身:如果消息体中包含业务唯一标识(如订单号),消费者可以直接从消息体中提取该标识进行判断。

3. 业务逻辑的幂等设计

业务逻辑本身需要设计成幂等的,即多次执行相同操作不会产生不同的结果。以库存扣减为例,可以设计如下幂等逻辑:

  • 检查库存状态:在扣减库存前,先检查当前库存是否足够。
  • 使用数据库事务:将库存检查和扣减操作放在一个数据库事务中执行,确保原子性。
  • 记录操作日志:在扣减库存时,记录操作日志(包括操作类型、操作时间、操作结果等),以便后续审计和回滚。

五、使用Java模拟示例

以下是一个使用Java模拟下单消息幂等性处理的示例代码:

java复制代码
import java.util.*;
import java.util.concurrent.ConcurrentHashMap;
// 模拟消息类
class OrderMessage {
private String orderId; // 订单号,作为唯一标识
private int quantity; // 商品数量
public OrderMessage(String orderId, int quantity) {
this.orderId = orderId;
this.quantity = quantity;
    }
// Getter和Setter方法省略
}
// 模拟库存服务类
class InventoryService {
// 使用ConcurrentHashMap模拟库存数据
private Map<String, Integer> inventory = new ConcurrentHashMap<>();
public InventoryService() {
// 初始化库存数据
        inventory.put("product1", 100);
    }
// 扣减库存的幂等方法
public synchronized boolean deductInventory(String productId, int quantity) {
Integer currentInventory = inventory.get(productId);
if (currentInventory == null || currentInventory < quantity) {
return false; // 库存不足
        }
        inventory.put(productId, currentInventory - quantity);
return true; // 扣减成功
    }
}
// 模拟订单服务类
class OrderService {
private InventoryService inventoryService = new InventoryService();
// 使用Set模拟去重表
private Set<String> processedOrders = ConcurrentHashMap.newKeySet();
// 消费下单消息的方法
public void consumeOrderMessage(OrderMessage message) {
String orderId = message.getOrderId();
// 检查消息是否已处理过
if (processedOrders.contains(orderId)) {
            System.out.println("Order " + orderId + " has been processed, skipping...");
return;
        }
// 模拟处理订单逻辑
int quantity = message.getQuantity();
String productId = "product1"; // 假设所有订单都是购买同一种商品
// 扣减库存
boolean deductResult = inventoryService.deductInventory(productId, quantity);
if (deductResult) {
            System.out.println("Order " + orderId + " processed successfully, deducted " + quantity + " items from inventory.");
// 将订单号添加到已处理集合中
            processedOrders.add(orderId);
        } else {
            System.out.println("Failed to process order " + orderId + ", insufficient inventory.");
        }
    }
}
public class IdempotenceExample {
public static void main(String[] args) {
OrderService orderService = new OrderService();
// 模拟发送重复消息
OrderMessage message1 = new OrderMessage("order123", 5);
OrderMessage message2 = new OrderMessage("order123", 5); // 与message1重复
// 消费消息
        orderService.consumeOrderMessage(message1);
        orderService.consumeOrderMessage(message2);
    }
}

代码说明

  1. OrderMessage类:模拟下单消息,包含订单号(唯一标识)和商品数量。
  2. InventoryService类:模拟库存服务,使用ConcurrentHashMap存储库存数据,并提供扣减库存的幂等方法。
  3. OrderService类:模拟订单服务,使用Set存储已处理的订单号作为去重表。consumeOrderMessage方法用于消费下单消息,首先检查消息是否已处理过,然后执行相应的业务逻辑(如扣减库存)。
  4. IdempotenceExample类:包含main方法,用于模拟发送重复消息并消费它们。可以看到,即使发送了重复的消息,由于幂等性机制的存在,订单只会被处理一次。

运行结果

运行上述代码后,控制台将输出以下内容:

复制代码
Order order123 processed successfully, deducted 5 items from inventory.
Order order123 has been processed, skipping...

从输出结果可以看出,第一条消息被成功处理并扣减了库存,而第二条重复的消息被跳过,没有再次扣减库存,从而实现了幂等性。

六、总结

幂等性机制是解决MQ下单消息重复消费问题的有效手段。通过为每条消息生成唯一标识、在消费者端实现去重逻辑以及设计幂等的业务逻辑,可以确保即使消息被重复消费,也不会对业务系统产生负面影响。在实际应用中,可以根据具体业务场景选择合适的去重方式和实现细节,以满足系统对幂等性的要求。

相关文章
|
8天前
|
存储 人工智能 弹性计算
阿里云弹性计算_加速计算专场精华概览 | 2024云栖大会回顾
2024年9月19-21日,2024云栖大会在杭州云栖小镇举行,阿里云智能集团资深技术专家、异构计算产品技术负责人王超等多位产品、技术专家,共同带来了题为《AI Infra的前沿技术与应用实践》的专场session。本次专场重点介绍了阿里云AI Infra 产品架构与技术能力,及用户如何使用阿里云灵骏产品进行AI大模型开发、训练和应用。围绕当下大模型训练和推理的技术难点,专家们分享了如何在阿里云上实现稳定、高效、经济的大模型训练,并通过多个客户案例展示了云上大模型训练的显著优势。
|
12天前
|
存储 人工智能 调度
阿里云吴结生:高性能计算持续创新,响应数据+AI时代的多元化负载需求
在数字化转型的大潮中,每家公司都在积极探索如何利用数据驱动业务增长,而AI技术的快速发展更是加速了这一进程。
|
3天前
|
并行计算 前端开发 物联网
全网首发!真·从0到1!万字长文带你入门Qwen2.5-Coder——介绍、体验、本地部署及简单微调
2024年11月12日,阿里云通义大模型团队正式开源通义千问代码模型全系列,包括6款Qwen2.5-Coder模型,每个规模包含Base和Instruct两个版本。其中32B尺寸的旗舰代码模型在多项基准评测中取得开源最佳成绩,成为全球最强开源代码模型,多项关键能力超越GPT-4o。Qwen2.5-Coder具备强大、多样和实用等优点,通过持续训练,结合源代码、文本代码混合数据及合成数据,显著提升了代码生成、推理和修复等核心任务的性能。此外,该模型还支持多种编程语言,并在人类偏好对齐方面表现出色。本文为周周的奇妙编程原创,阿里云社区首发,未经同意不得转载。
|
9天前
|
人工智能 运维 双11
2024阿里云双十一云资源购买指南(纯客观,无广)
2024年双十一,阿里云推出多项重磅优惠,特别针对新迁入云的企业和初创公司提供丰厚补贴。其中,36元一年的轻量应用服务器、1.95元/小时的16核60GB A10卡以及1元购域名等产品尤为值得关注。这些产品不仅价格亲民,还提供了丰富的功能和服务,非常适合个人开发者、学生及中小企业快速上手和部署应用。
|
19天前
|
自然语言处理 数据可视化 前端开发
从数据提取到管理:合合信息的智能文档处理全方位解析【合合信息智能文档处理百宝箱】
合合信息的智能文档处理“百宝箱”涵盖文档解析、向量化模型、测评工具等,解决了复杂文档解析、大模型问答幻觉、文档解析效果评估、知识库搭建、多语言文档翻译等问题。通过可视化解析工具 TextIn ParseX、向量化模型 acge-embedding 和文档解析测评工具 markdown_tester,百宝箱提升了文档处理的效率和精确度,适用于多种文档格式和语言环境,助力企业实现高效的信息管理和业务支持。
3940 3
从数据提取到管理:合合信息的智能文档处理全方位解析【合合信息智能文档处理百宝箱】
|
8天前
|
算法 安全 网络安全
阿里云SSL证书双11精选,WoSign SSL国产证书优惠
2024阿里云11.11金秋云创季活动火热进行中,活动月期间(2024年11月01日至11月30日)通过折扣、叠加优惠券等多种方式,阿里云WoSign SSL证书实现优惠价格新低,DV SSL证书220元/年起,助力中小企业轻松实现HTTPS加密,保障数据传输安全。
522 3
阿里云SSL证书双11精选,WoSign SSL国产证书优惠
|
15天前
|
安全 数据建模 网络安全
2024阿里云双11,WoSign SSL证书优惠券使用攻略
2024阿里云“11.11金秋云创季”活动主会场,阿里云用户通过完成个人或企业实名认证,可以领取不同额度的满减优惠券,叠加折扣优惠。用户购买WoSign SSL证书,如何叠加才能更加优惠呢?
992 3
|
7天前
|
数据采集 人工智能 API
Qwen2.5-Coder深夜开源炸场,Prompt编程的时代来了!
通义千问团队开源「强大」、「多样」、「实用」的 Qwen2.5-Coder 全系列,致力于持续推动 Open Code LLMs 的发展。
|
12天前
|
机器学习/深度学习 存储 人工智能
白话文讲解大模型| Attention is all you need
本文档旨在详细阐述当前主流的大模型技术架构如Transformer架构。我们将从技术概述、架构介绍到具体模型实现等多个角度进行讲解。通过本文档,我们期望为读者提供一个全面的理解,帮助大家掌握大模型的工作原理,增强与客户沟通的技术基础。本文档适合对大模型感兴趣的人员阅读。
445 18
白话文讲解大模型| Attention is all you need
|
13天前
|
存储 分布式计算 流计算
实时计算 Flash – 兼容 Flink 的新一代向量化流计算引擎
本文介绍了阿里云开源大数据团队在实时计算领域的最新成果——向量化流计算引擎Flash。文章主要内容包括:Apache Flink 成为业界流计算标准、Flash 核心技术解读、性能测试数据以及在阿里巴巴集团的落地效果。Flash 是一款完全兼容 Apache Flink 的新一代流计算引擎,通过向量化技术和 C++ 实现,大幅提升了性能和成本效益。
663 10
实时计算 Flash – 兼容 Flink 的新一代向量化流计算引擎