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

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

        // 減庫存
        productRepository.reductCount();

        // 生成訂單
        createOrder();
    }

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

經并發(fā)實驗，產生了超賣的現象。

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 注解管理事務了，改為手動管理事務。

經實驗，解決了超賣現象。