Springboot在有鎖的情況下正確使用事務(wù)的實(shí)現(xiàn)代碼

更新時(shí)間：2021年12月17日 14:33:35 作者：追風(fēng)人聊Java

這篇文章主要介紹了Springboot在有鎖的情況下如何正確使用事務(wù)，今天通過一個(gè)實(shí)驗(yàn)給大家分析一下商品超賣問題，模擬場(chǎng)景分析通過實(shí)例代碼給大家介紹的非常詳細(xì),需要的朋友可以參考下

1. 概述

老話說的好：想要賺錢，就去看看有錢人有什么需求，因?yàn)橛绣X人錢多，所以賺的多。

言歸正傳，在Java項(xiàng)目的研發(fā)中，“鎖”這個(gè)詞并不陌生，最經(jīng)典的使用場(chǎng)景是商品的超賣問題。

很多Java小白，通常會(huì)認(rèn)為，給代碼加上一把“鎖”，就能解決多扣庫(kù)存問題，卻忽略了數(shù)據(jù)庫(kù)事務(wù)的問題，今天我們就來做一個(gè)實(shí)驗(yàn)，分析一下商品超賣問題。

2. 場(chǎng)景介紹

有一款商品，庫(kù)存只剩1件。

購(gòu)買商品時(shí)，做三個(gè)動(dòng)作，一是檢查庫(kù)存，二是扣庫(kù)存，三是生成訂單，三個(gè)動(dòng)作在一個(gè)事務(wù)中執(zhí)行。

模擬并發(fā)場(chǎng)景，使用10個(gè)線程同時(shí)執(zhí)行用戶購(gòu)買商品的操作。

3. 代碼實(shí)現(xiàn)

3.1 不加鎖的代碼實(shí)現(xiàn)

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

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

        // 減庫(kù)存
        productRepository.reductCount();

        // 生成訂單
        createOrder();
    }

首先我們正常編寫業(yè)務(wù)邏輯，用 @Transactional 注解控制事務(wù)。

經(jīng)并發(fā)實(shí)驗(yàn)，產(chǎn)生了超賣的現(xiàn)象。

3.2 加鎖的代碼實(shí)現(xiàn)

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

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

        // 減庫(kù)存
        productRepository.reductCount();

        // 生成訂單
        createOrder();
    }

這次我們使用 synchronized 關(guān)鍵字給方法加了把“鎖”，理論上應(yīng)該不會(huì)產(chǎn)生超賣現(xiàn)象了吧。

經(jīng)實(shí)驗(yàn)，仍然產(chǎn)生了超賣現(xiàn)象。

因?yàn)殡m然方法被鎖住了，可是@Transactional 注解并沒有及時(shí)的提交事務(wù)，導(dǎo)致庫(kù)存沒有及時(shí)扣減為0，因此還是超賣了。

3.3 正確使用事務(wù)的代碼實(shí)現(xiàn)

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

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

        // 開啟事務(wù)
        TransactionStatus transactionStatus = platformTransactionManager.getTransaction(transactionDefinition);

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

            // 減庫(kù)存
            productRepository.reductCount();

            // 生成訂單
            createOrder();

            // 事務(wù)提交
            platformTransactionManager.commit(transactionStatus);
        } catch (Exception ex) {
            log.error(ex.getMessage(), ex);
            // 事務(wù)回滾
            platformTransactionManager.rollback(transactionStatus);
        }

    }

這次我們不使用@Transactional 注解管理事務(wù)了，改為手動(dòng)管理事務(wù)。

經(jīng)實(shí)驗(yàn)，解決了超賣現(xiàn)象。