spring事务和加可重入锁解决库存超卖遇到的问题

想法：使用可重入锁实现预锁库存，防止超卖现象，数据库中存入100件商品，测试时每次购买一件，预锁定一件。理想状态是无超卖现象。

@PostMapping("/buyLock")@Transactional(rollbackFor = Exception.class,isolation = SERIALIZABLE)public String buyLock(Integer quantity,Long skuId){lock.lock();try {PmsSkuStock skuStock = skuStockMapper.selectByPrimaryKey(skuId);int left = skuStock.getStock() - skuStock.getLockStock();if (left < quantity){return "库存不足";}int s = skuStockMapper.updateLockStock(skuId,quantity);if (s == 1){return "购买成功";}}catch (Exception e){e.printStackTrace();}finally {lock.unlock();}return "购买失败";}

结果发生了超卖，实际锁定了101件。

解决方法一：去掉@Transactional注解，再试，没有超卖了

@PostMapping("/buyLock")public String buyLock(Integer quantity,Long skuId){lock.lock();try {PmsSkuStock skuStock = skuStockMapper.selectByPrimaryKey(skuId);int left = skuStock.getStock() - skuStock.getLockStock();if (left < quantity){return "库存不足";}int s = skuStockMapper.updateLockStock(skuId,quantity);if (s == 1){return "购买成功";}}catch (Exception e){e.printStackTrace();}finally {lock.unlock();}return "购买失败";}

解决方法二：加上@Transactional注解，将锁提到事务外面，没有超卖

@PostMapping("/buyLock")public String buyLock(Integer quantity,Long skuId){lock.lock();try {return buyLock1(quantity,skuId);}catch (Exception e){e.printStackTrace();}finally {lock.unlock();}return "购买失败";}@Transactional(rollbackFor = Exception.class)public String buyLock1(Integer quantity,Long skuId){PmsSkuStock skuStock = skuStockMapper.selectByPrimaryKey(skuId);int left = skuStock.getStock() - skuStock.getLockStock();if (left < quantity){return "库存不足";}int s = skuStockMapper.updateLockStock(skuId,quantity);if (s == 1){return "购买成功";}return "购买失败";}

解决方法三：spring事务默认使用mysql默认的事务隔离级别，是可重复读，将spring事务级别设置成序列化，没有超卖

@PostMapping("/buyLock")@Transactional(rollbackFor = Exception.class,isolation = SERIALIZABLE)public String buyLock(Integer quantity,Long skuId){lock.lock();try {PmsSkuStock skuStock = skuStockMapper.selectByPrimaryKey(skuId);int left = skuStock.getStock() - skuStock.getLockStock();if (left < quantity){return "库存不足";}int s = skuStockMapper.updateLockStock(skuId,quantity);if (s == 1){return "购买成功";}}catch (Exception e){e.printStackTrace();}finally {lock.unlock();}return "购买失败";}

结论：

发生上述现象的原因是，事物未提交之前，锁已经释放(事物提交是在整个方法执行完)，导致另一个事物读取到了这个事物未提交的数据

spring事务和加可重入锁解决库存超卖遇到的问题相关推荐

mysql乐观锁处理超卖_通过乐观锁解决库存超卖的问题
前言在通过多线程来解决高并发的问题上,线程安全往往是最先需要考虑的问题,其次才是性能.库存超卖问题是有很多种技术解决方案的,比如悲观锁,分布式锁,乐观锁,队列串行化,Redis原子操作等.本篇通过M ...
面试官让我设计一个基于分布式锁的库存超卖方案，并发量很高的那种
今天给大家聊一个有意思的话题:每秒上千订单场景下,如何对分布式锁的并发能力进行优化? 背景引入首先,我们一起来看看这个问题的背景? 前段时间有个朋友在外面面试,然后有一天找我聊说:有一个国内不错的电 ...
阿里面试官：高并发大流量秒杀系统如何正确的解决库存超卖问题？（建议收藏）
大家好,我是冰河~~ 在[精通高并发系列]的<实践出真知:全网最强秒杀系统架构解密!!>一文中,冰河详细的阐述了高并发秒杀系统的架构设计,也简单提到了如何扣减商品的库存. 也许不少小伙伴会 ...
Redis解决库存超卖问题，大厂直通车
查询商品信息 (调用商品服务) 计算总价(生成订单详情) 商品服务扣库存(调用商品服务) 订单入库( 生成订单) // 原始的MySQL同步流程 // 判断此代金券是否加入抢购 SeckillVouc ...
python threading lock_python threading之死锁和可重入锁
一.死锁简单来说,死锁是一个资源被多次调用,而多次调用方都未能释放该资源就会造成死锁,这里结合例子说明下两种常见的死锁情况. 1.迭代死锁该情况是一个线程"迭代"请求同一个资源 ...
java可重入锁是什么意思_Java中的可重入(Reentrant)锁
## 什么是可重入锁? 可重入锁是一种特殊的互斥锁,它可以被同一个线程多次获取,而不会产生死锁. 1. 首先它是互斥锁:任意时刻,只有一个线程锁.即假设A线程已经获取了锁,在A线程释放这个锁之前,B线 ...
用分布式锁来防止库存超卖，但是是每秒上千订单的高并发场景，如何对分布式锁进行高并发优化来应对这个场景？
用分布式锁来防止库存超卖,但是是每秒上千订单的高并发场景,如何对分布式锁进行高并发优化来应对这个场景? 转载 codeing_doc 最后发布于2018-11-23 09:44:41 阅读数 1073 ...
基于 MySQL 排它锁实现分布式可重入锁解决方案
一.MySQL 排它锁和共享锁在进行实验前,先来了解下MySQL 的排它锁和共享锁,在 MySQL 中的锁分为表锁和行锁,在行锁中锁又分成了排它锁和共享锁两种类型. 1. 排它锁排他锁又称为写锁, ...
年轻人，看看Redisson分布式锁—可重入锁吧！太重要了
1.引言作为后端开发,对于所谓的线程安全.高并发等一系列名词肯定都不会陌生,相关的一些概念及技术框架是面试中的宠儿,也是工作中解决一些特定场景下的技术问题的银弹.今天我们就来聊聊这些银弹中的其中一枚 ...
年轻人，看看 Redisson 分布式锁—可重入锁吧！太重要了
作者 | 李祥责编 | 张文来源 | 企鹅杏仁技术站(ID:xingren-tech) 引言作为后端开发,对于所谓的线程安全.高并发等一系列名词肯定都不会陌生,相关的一些概念及技术框架是面 ...

spring事务和加可重入锁解决库存超卖遇到的问题

spring事务和加可重入锁解决库存超卖遇到的问题相关推荐

最新文章

热门文章