Springboot在有锁的情况下正确使用事务的实现代码

1. 概述

老话说的好：想要赚钱，就去看看有钱人有什么需求，因为有钱人钱多，所以赚的多。

言归正传，在Java项目的研发中，“锁”这个词并不陌生，最经典的使用场景是商品的超卖问题。

很多Java小白，通常会认为，给代码加上一把“锁”，就能解决多扣库存问题，却忽略了数据库事务的问题，今天我们就来做一个实验，分析一下商品超卖问题。

2. 场景介绍

有一款商品，库存只剩1件。

购买商品时，做三个动作，一是检查库存，二是扣库存，三是生成订单，三个动作在一个事务中执行。

模拟并发场景，使用10个线程同时执行用户购买商品的操作。

3. 代码实现

3.1 不加锁的代码实现

@Transactional(rollbackFor = Exception.class)
    public void buy() {

        // 查看是商品否有库存
        Integer count = getProductCount();
        if(count <= 0) {
            throw new RuntimeException("库存为 0");
        }

        // 减库存
        productRepository.reductCount();

        // 生成订单
        createOrder();
    }

首先我们正常编写业务逻辑，用 @Transactional 注解控制事务。

经并发实验，产生了超卖的现象。

3.2 加锁的代码实现

@Transactional(rollbackFor = Exception.class)
    public synchronized void buy() {

        // 查看是商品否有库存
        Integer count = getProductCount();
        if(count <= 0) {
            throw new RuntimeException("库存为 0");
        }

        // 减库存
        productRepository.reductCount();

        // 生成订单
        createOrder();
    }

这次我们使用 synchronized 关键字给方法加了把“锁”，理论上应该不会产生超卖现象了吧。

经实验，仍然产生了超卖现象。

因为虽然方法被锁住了，可是@Transactional 注解并没有及时的提交事务，导致库存没有及时扣减为0，因此还是超卖了。

3.3 正确使用事务的代码实现

@Autowired
    private PlatformTransactionManager platformTransactionManager;
    @Autowired
    private TransactionDefinition transactionDefinition;

    // @Transactional(rollbackFor = Exception.class)
    public synchronized void buy() {

        // 开启事务
        TransactionStatus transactionStatus = platformTransactionManager.getTransaction(transactionDefinition);

        try {
            // 查看是商品否有库存
            Integer count = getProductCount();
            if(count <= 0) {
                throw new RuntimeException("库存为 0");
            }

            // 减库存
            productRepository.reductCount();

            // 生成订单
            createOrder();

            // 事务提交
            platformTransactionManager.commit(transactionStatus);
        } catch (Exception ex) {
            log.error(ex.getMessage(), ex);
            // 事务回滚
            platformTransactionManager.rollback(transactionStatus);
        }

    }

这次我们不使用@Transactional 注解管理事务了，改为手动管理事务。

经实验，解决了超卖现象。

4. 综述

今天聊了一下 Springboot在有锁的情况下如何正确使用事务，希望可以对大家的工作有所帮助。

到此这篇关于Springboot在有锁的情况下如何正确使用事务的文章就介绍到这了,更多相关Springboot使用事务内容请搜索我们以前的文章或继续浏览下面的相关文章希望大家以后多多支持我们！

赞 (0)

相关推荐

  • springboot cloud使用eureka整合分布式事务组件Seata 的方法

    springboot cloud使用eureka整合分布式事务组件Seata 的方法

    前言 近期一直在忙项目,我也是打工仔.不多说,我们开始玩一玩seata. 正文 什么都不说,我们按照惯例,先上一个图(图里不规范的使用请忽略): 简单一眼就看出来, 比我们平时用的东西,多了 Seata Server 微服务 . 同样这个 Seata Server 微服务 ,也是需要注册到eureka上面去的. 那么我们首先就搞一搞这个 seata server ,那么剩下的就是一些原本的业务服务整合配置了. 该篇用的 seata server 版本,用的是1.4.1 , 可以去git下载下.当

  • SpringBoot事务使用及回滚实现代码详解

    Springboot中事务的使用: 1.启动类加上@EnableTransactionManagement注解,开启事务支持(其实默认是开启的). 2.在使用事务的public(只有public支持事务)方法(或者类-相当于该类的所有public方法都使用)加上@Transactional注解. 在实际使用中一般是在service中使用@Transactional,那么对于controller->service流程中: 如果controller未开启事务,service中开始了事务,servic

  • 使用SpringBoot注解方式处理事务回滚实现

    我们在SpringBoot和MyBatis整合的时候,需要在SpringBoot中通过注解方式配置事务回滚 1 Pojo类 package com.zxf.domain; import java.util.Date; public class User { private Integer id; private String name; private String pwd; private String head_img; private String phone; private Date

  • Springboot在有锁的情况下正确使用事务的实现代码

    1. 概述 老话说的好:想要赚钱,就去看看有钱人有什么需求,因为有钱人钱多,所以赚的多. 言归正传,在Java项目的研发中,"锁"这个词并不陌生,最经典的使用场景是商品的超卖问题. 很多Java小白,通常会认为,给代码加上一把"锁",就能解决多扣库存问题,却忽略了数据库事务的问题,今天我们就来做一个实验,分析一下商品超卖问题. 2. 场景介绍 有一款商品,库存只剩1件. 购买商品时,做三个动作,一是检查库存,二是扣库存,三是生成订单,三个动作在一个事务中执行. 模拟

  • Yii+MYSQL锁表防止并发情况下重复数据的方法

    本文实例讲述了Yii+MYSQL锁表防止并发情况下重复数据的方法.分享给大家供大家参考,具体如下: lock table 读锁定 如果一个线程获得在一个表上的read锁,那么该线程和所有其他线程只能从表中读数据,不能进行任何写操作. lock tables user read;//读锁定表 unlock tables;//解锁 lock tables user read local;//本地读锁定表,其他线程的insert未被阻塞,update操作被阻塞 lock table 写锁定 如果一个线

  • SpringBoot RedisTemplate分布式锁的项目实战

    SpringBoot RedisTemplate分布式锁的项目实战

    目录 1.使用场景 2.加锁解决 3.分布式锁 4.增加失效时间 5.增加线程唯一值 6.Lua脚本 7.Lua是如何实现原子性的 8.代码演示 9. 总结 1.使用场景 想直接获取加锁和解锁代码,请直接到代码处 在下单场景减库存时我们一般会将库存查询出来,进行库存的扣除 @GetMapping(value = "order") public R order() { int stock = RedisUtil.getObject("stock", Integer.c

  • PHP通过加锁实现并发情况下抢码功能

    需求:抢码功能 要求: 1.特定时间段才开放抢码: 2.每个时间段放开的码是有限的: 3.每个码不允许重复: 实现: 1.在不考虑并发的情况下实现: function get_code($len){ $CHAR_ARR = array('1','2','3','4','5','6','7','8','9','A','B','C','D','E','F','G','H','I','J','K','L','M','N','O','P','Q','X','Y','Z','W','S','R','T')

  • Android屏幕锁屏弹窗的正确姿势DEMO详解

    在上篇文章给大家介绍了Android程序开发仿新版QQ锁屏下弹窗功能.今天通过本文给大家分享android锁屏弹窗的正确姿势. 最近在做一个关于屏幕锁屏悬浮窗的功能,于是在网上搜索了很多安卓屏幕锁屏的相关资料,鉴于网上的资料比较零碎,所以我在这里进行整理总结.本文将从以下两点对屏幕锁屏进行解析: 1. 如何监听系统屏幕锁屏 2. 如何在锁屏界面弹出悬浮窗 如何监听系统屏幕锁屏 经过总结,监听系统的锁屏可以通过以下两种方式: 1) 代码直接判定 2) 接收广播 1) 代码直接判定 代码判断方式,也

  • springboot redis分布式锁代码实例

    这篇文章主要介绍了springboot redis分布式锁代码实例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下 随着微服务等分布式架构的快速发展及应用,在很多情况下,我们都会遇到在并发情况下多个线程竞争资源的情况,比如我们耳熟能详的秒杀活动,多平台多用户对同一个资源进行操作等场景等.分布式锁的实现方式有很多种,比如基于数据库.Zookeeper.Redis等,本文我们主要介绍Spring Boot整合Redis实现分布式锁. 工具类如下: i

  • Django如何在不停机的情况下创建索引

    该框架在管理数据库更改方面非常强大和有用,但是该框架提供的灵活性受到了一定的限制.为了理解Django迁移的局限性,你将处理一个众所周知的问题:在不停机的情况下,在Django中创建一个索引. 在本教程中,你将学习: Django如何以及何时生成新的迁移: 如何检查Django生成的执行迁移的命令: 如何安全地修改迁移以满足你的需求. 本中级教程是为已经熟悉Django迁移(Migration)的读者设计的. 在Django迁移中创建索引的问题 当应用程序存储的数据增长时,通常需要进行的一个常见

  • 完美解决android M上锁屏情况下,禁止pc通过MTP访问手机存储单元

    1.问题解决主要文件:/m8976/packages/providers/MediaProvider/src/com/android/providers/media/MtpService.java 需要在MtpService.java中updateDisabledStateLocked 方法添加锁屏情况限制: final KeyguardManager keyguardManager = (KeyguardManager) getSystemService( Context.KEYGUARD_S

  • Android如何实现锁屏状态下弹窗

    前言 想在锁屏上面实现弹窗,第一个想法就是利用 WindowManager 设置 Window 的 Flag,通过设置 Flag 的显示优先级来让窗口显示在锁屏的上面. 接下来就是试验可能相关的 Window Type 属性,验证该方案是否可行. 在尝试各个 Window Type 属性之前需要明确各个 Type 所需要的权限,下面是 com.android.internal.policy.impl.PhoneWindowManager.checkAddPermission 的源码: publi

  • 分析在Python中何种情况下需要使用断言

    这个问题是如何在一些场景下使用断言表达式,通常会有人误用它,所以我决定写一篇文章来说明何时使用断言,什么时候不用. 为那些还不清楚它的人,Python的assert是用来检查一个条件,如果它为真,就不做任何事.如果它为假,则会抛出AssertError并且包含错误信息.例如: py> x = 23 py> assert x > 0, "x is not zero or negative" py> assert x%2 == 0, "x is not a

随机推荐