深入解析秒杀业务中的核心问题 —— 从并发控制到事务管理

2024-09-08 15:28

本文主要是介绍深入解析秒杀业务中的核心问题 —— 从并发控制到事务管理,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

深入解析秒杀业务中的核心问题 —— 从并发控制到事务管理

秒杀系统是应对高并发、高压力下的典型业务场景,涉及到并发控制、库存管理、事务管理等多个关键技术点。本文将深入剖析秒杀商品业务中常见的几个核心问题,包括 AOP 事务管理、同步锁机制、乐观锁、CAS 操作,以及用户限购策略。通过这些技术的结合,确保秒杀系统在高并发场景下的稳定性和一致性。


1. AOP 代理对象与事务管理

在秒杀商品的业务中,事务管理是至关重要的环节,尤其是涉及到库存扣减和订单创建的场景。Spring 提供了 @Transactional 注解,通过 AOP(面向切面编程)实现事务管理。为了保证事务的正常执行,方法调用必须通过 Spring 的代理对象来进行

为什么需要代理对象?

Spring 的事务管理是通过 AOP 实现的,AOP 的本质是通过代理对象拦截方法调用,并在方法调用前后进行事务的开启、提交、回滚等操作。如果在同一个类中直接调用 this 方法,则不会经过代理,事务拦截器无法生效,导致事务管理失效。

解决方案

为了确保在类内部调用方法时依然通过代理对象,我们可以通过以下技术:

  1. AopContext.currentProxy():Spring 提供的 AopContext.currentProxy() 方法可以获取当前类的代理对象,确保事务正常生效。
  2. @EnableAspectJAutoProxy(exposeProxy = true):该注解的作用是暴露当前的代理对象,配合 AopContext.currentProxy() 来获取代理对象。

代码示例

synchronized (uid.toString().intern()) {// 获取当前代理对象,确保事务生效IVoucherOrderService proxy = (IVoucherOrderService) AopContext.currentProxy();return proxy.createOrder(productId, uid);
}

在这个场景中,我们确保通过代理对象调用 createOrder 方法,以保证事务的正确性。


2. 并发控制与锁机制

在秒杀商品业务中,确保单个用户不能在同一时刻多次请求是很重要的。为了实现这一点,我们可以使用 synchronized 锁机制,通过用户 ID 进行加锁,确保一个用户不能同时发起多次秒杀请求。

synchronized (uid.toString().intern()) 机制

  • uid.toString().intern() 方法保证相同的用户 ID 会共享同一个锁对象,intern() 会将字符串放入常量池,从而确保不同用户获得不同的锁对象,而相同用户始终使用相同的锁。
  • synchronized 锁粒度基于用户,防止同一用户并发访问,确保线程安全。

注意:这种锁机制是 JVM 层面的锁,适用于单机环境。如果是分布式部署,还需要使用 Redis 分布式锁 等手段来确保分布式环境下的并发控制。

代码示例

Long uid = UserHolder.getUser().getId();
synchronized (uid.toString().intern()) {// 秒杀业务逻辑
}

在分布式环境下,可以用 Redis 锁来代替 JVM 锁,确保分布式集群环境中的并发安全。


3. 锁包含事务,还是事务包含锁?

在秒杀业务中,锁和事务的执行顺序非常关键。通常情况下,我们希望在进入临界区(即加锁后)开启事务,确保多个操作的原子性。这意味着锁的作用是为了保证并发控制,而事务的作用是确保数据操作的原子性和一致性。

因此,锁先于事务启动,事务的所有操作都在加锁保护的代码块内执行。这样可以确保在并发情况下,事务中的操作不会出现线程安全问题。

代码示例

synchronized (uid.toString().intern()) {// 在锁内,调用带有事务的方法IVoucherOrderService proxy = (IVoucherOrderService) AopContext.currentProxy();return proxy.createOrder(productId, uid);
}

在这个流程中,锁保护了事务,确保同一时间只有一个用户可以创建订单,并且事务操作得到正确的执行。


4. 乐观锁、悲观锁、版本号、CAS

在秒杀场景中,库存扣减的正确性是关键问题之一。常见的解决方案包括乐观锁、悲观锁、CAS(Compare And Swap),它们各有优缺点。

  • 乐观锁:基于一种“乐观”的思想,假设不会发生冲突,因此不加锁。它通过 版本号 或其他条件进行判断。在库存扣减时,通过检查 stock > 0 或版本号的方式保证库存扣减的正确性。

    宽松的乐观锁

    UPDATE product_stock
    SET stock = stock - 1
    WHERE product_id = #{productId} AND stock > 0;
    

    严格的乐观锁

    UPDATE product_stock
    SET stock = stock - 1
    WHERE product_id = #{productId} AND stock = #{currentStock};
    

    宽松的乐观锁只要库存大于 0 就能扣减,而严格的乐观锁要求库存值完全匹配,避免高并发下的超卖情况。

  • CAS(Compare And Swap):CAS 是一种无锁的操作,通过比较内存中的值是否是预期的值,如果是就更新,否则重试。它在并发高的场景中非常有效,避免了加锁带来的性能开销。


5. 限购策略:一人一单

在秒杀商品业务中,通常会限制每个用户只能购买一件商品。这可以通过在订单表中查询用户是否已经下单来实现。

解决方案

  • 在秒杀开始前,查询当前用户是否已经下过订单。如果下单了,直接返回失败信息,防止重复下单。

SQL 示例

SELECT COUNT(1) 
FROM orders 
WHERE user_id = #{uid} 
AND product_id = #{productId};-- 如果用户没有下过单,则创建订单
INSERT INTO orders (order_id, user_id, product_id, quantity)
VALUES (#{orderId}, #{uid}, #{productId}, 1);

通过查询订单表来确保每个用户只能购买一次该商品,有效防止恶意抢购。


总结

秒杀业务的复杂性主要体现在 高并发场景下的事务管理和并发控制。在商品秒杀场景中,针对多个关键技术点进行了深度剖析:

  1. AOP 代理对象与事务管理:确保事务通过代理对象调用,避免事务失效。
  2. 并发控制与锁机制:通过 synchronized 实现单机并发控制,在分布式环境下可以使用分布式锁。
  3. 锁包含事务:锁先于事务执行,确保线程安全和数据一致性。
  4. 乐观锁与CAS:通过库存判断或版本号机制确保库存扣减的正确性,避免超卖。
  5. 限购策略:通过查询订单表限制用户的重复购买,防止一人多单。

通过合理运用这些技术,能够设计出一个稳定、高效的秒杀系统,在应对高并发时保持系统稳定性,同时确保数据的安全性和一致性。


希望这篇文章能帮助你深入理解秒杀商品业务中的关键技术点,构建更高效稳定的系统。

这篇关于深入解析秒杀业务中的核心问题 —— 从并发控制到事务管理的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1148480

相关文章

解决RocketMQ的幂等性问题

《解决RocketMQ的幂等性问题》重复消费因调用链路长、消息发送超时或消费者故障导致,通过生产者消息查询、Redis缓存及消费者唯一主键可以确保幂等性,避免重复处理,本文主要介绍了解决RocketM... 目录造成重复消费的原因解决方法生产者端消费者端代码实现造成重复消费的原因当系统的调用链路比较长的时

Mysql中设计数据表的过程解析

《Mysql中设计数据表的过程解析》数据库约束通过NOTNULL、UNIQUE、DEFAULT、主键和外键等规则保障数据完整性,自动校验数据,减少人工错误,提升数据一致性和业务逻辑严谨性,本文介绍My... 目录1.引言2.NOT NULL——制定某列不可以存储NULL值2.UNIQUE——保证某一列的每一

深度解析Nginx日志分析与499状态码问题解决

《深度解析Nginx日志分析与499状态码问题解决》在Web服务器运维和性能优化过程中,Nginx日志是排查问题的重要依据,本文将围绕Nginx日志分析、499状态码的成因、排查方法及解决方案展开讨论... 目录前言1. Nginx日志基础1.1 Nginx日志存放位置1.2 Nginx日志格式2. 499

kkFileView启动报错:报错2003端口占用的问题及解决

《kkFileView启动报错:报错2003端口占用的问题及解决》kkFileView启动报错因office组件2003端口未关闭,解决:查杀占用端口的进程,终止Java进程,使用shutdown.s... 目录原因解决总结kkFileViewjavascript启动报错启动office组件失败,请检查of

MySQL CTE (Common Table Expressions)示例全解析

《MySQLCTE(CommonTableExpressions)示例全解析》MySQL8.0引入CTE,支持递归查询,可创建临时命名结果集,提升复杂查询的可读性与维护性,适用于层次结构数据处... 目录基本语法CTE 主要特点非递归 CTE简单 CTE 示例多 CTE 示例递归 CTE基本递归 CTE 结

go动态限制并发数量的实现示例

《go动态限制并发数量的实现示例》本文主要介绍了Go并发控制方法,通过带缓冲通道和第三方库实现并发数量限制,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面... 目录带有缓冲大小的通道使用第三方库其他控制并发的方法因为go从语言层面支持并发,所以面试百分百会问到

Go语言并发之通知退出机制的实现

《Go语言并发之通知退出机制的实现》本文主要介绍了Go语言并发之通知退出机制的实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧... 目录1、通知退出机制1.1 进程/main函数退出1.2 通过channel退出1.3 通过cont

java如何实现高并发场景下三级缓存的数据一致性

《java如何实现高并发场景下三级缓存的数据一致性》这篇文章主要为大家详细介绍了java如何实现高并发场景下三级缓存的数据一致性,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 下面代码是一个使用Java和Redisson实现的三级缓存服务,主要功能包括:1.缓存结构:本地缓存:使

SpringBoot 异常处理/自定义格式校验的问题实例详解

《SpringBoot异常处理/自定义格式校验的问题实例详解》文章探讨SpringBoot中自定义注解校验问题,区分参数级与类级约束触发的异常类型,建议通过@RestControllerAdvice... 目录1. 问题简要描述2. 异常触发1) 参数级别约束2) 类级别约束3. 异常处理1) 字段级别约束

Spring Boot 3.x 中 WebClient 示例详解析

《SpringBoot3.x中WebClient示例详解析》SpringBoot3.x中WebClient是响应式HTTP客户端,替代RestTemplate,支持异步非阻塞请求,涵盖GET... 目录Spring Boot 3.x 中 WebClient 全面详解及示例1. WebClient 简介2.