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

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

相关文章

MybatisGenerator文件生成不出对应文件的问题

《MybatisGenerator文件生成不出对应文件的问题》本文介绍了使用MybatisGenerator生成文件时遇到的问题及解决方法,主要步骤包括检查目标表是否存在、是否能连接到数据库、配置生成... 目录MyBATisGenerator 文件生成不出对应文件先在项目结构里引入“targetProje

C#使用HttpClient进行Post请求出现超时问题的解决及优化

《C#使用HttpClient进行Post请求出现超时问题的解决及优化》最近我的控制台程序发现有时候总是出现请求超时等问题,通常好几分钟最多只有3-4个请求,在使用apipost发现并发10个5分钟也... 目录优化结论单例HttpClient连接池耗尽和并发并发异步最终优化后优化结论我直接上优化结论吧,

Java内存泄漏问题的排查、优化与最佳实践

《Java内存泄漏问题的排查、优化与最佳实践》在Java开发中,内存泄漏是一个常见且令人头疼的问题,内存泄漏指的是程序在运行过程中,已经不再使用的对象没有被及时释放,从而导致内存占用不断增加,最终... 目录引言1. 什么是内存泄漏?常见的内存泄漏情况2. 如何排查 Java 中的内存泄漏?2.1 使用 J

numpy求解线性代数相关问题

《numpy求解线性代数相关问题》本文主要介绍了numpy求解线性代数相关问题,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧... 在numpy中有numpy.array类型和numpy.mat类型,前者是数组类型,后者是矩阵类型。数组

解决systemctl reload nginx重启Nginx服务报错:Job for nginx.service invalid问题

《解决systemctlreloadnginx重启Nginx服务报错:Jobfornginx.serviceinvalid问题》文章描述了通过`systemctlstatusnginx.se... 目录systemctl reload nginx重启Nginx服务报错:Job for nginx.javas

深入理解C语言的void*

《深入理解C语言的void*》本文主要介绍了C语言的void*,包括它的任意性、编译器对void*的类型检查以及需要显式类型转换的规则,具有一定的参考价值,感兴趣的可以了解一下... 目录一、void* 的类型任意性二、编译器对 void* 的类型检查三、需要显式类型转换占用的字节四、总结一、void* 的

Redis缓存问题与缓存更新机制详解

《Redis缓存问题与缓存更新机制详解》本文主要介绍了缓存问题及其解决方案,包括缓存穿透、缓存击穿、缓存雪崩等问题的成因以及相应的预防和解决方法,同时,还详细探讨了缓存更新机制,包括不同情况下的缓存更... 目录一、缓存问题1.1 缓存穿透1.1.1 问题来源1.1.2 解决方案1.2 缓存击穿1.2.1

深入理解Redis大key的危害及解决方案

《深入理解Redis大key的危害及解决方案》本文主要介绍了深入理解Redis大key的危害及解决方案,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着... 目录一、背景二、什么是大key三、大key评价标准四、大key 产生的原因与场景五、大key影响与危

vue解决子组件样式覆盖问题scoped deep

《vue解决子组件样式覆盖问题scopeddeep》文章主要介绍了在Vue项目中处理全局样式和局部样式的方法,包括使用scoped属性和深度选择器(/deep/)来覆盖子组件的样式,作者建议所有组件... 目录前言scoped分析deep分析使用总结所有组件必须加scoped父组件覆盖子组件使用deep前言

解决Cron定时任务中Pytest脚本无法发送邮件的问题

《解决Cron定时任务中Pytest脚本无法发送邮件的问题》文章探讨解决在Cron定时任务中运行Pytest脚本时邮件发送失败的问题,先优化环境变量,再检查Pytest邮件配置,接着配置文件确保SMT... 目录引言1. 环境变量优化:确保Cron任务可以正确执行解决方案:1.1. 创建一个脚本1.2. 修