快捷導(dǎo)航

當Transactional遇上synchronized的解決方法分享

更新時間：2023年05月07日 14:08:17 作者：思想領(lǐng)袖

前些時間剛好刷到了有關(guān)于“# 【事務(wù)與鎖】當Transactional遇上synchronized”這一類的文章，感覺這也是工作中經(jīng)常會遇到的一類問題了。所以就針對這個話題進行了分析并整理了常用的解決方法，希望對大家有所幫助

問題情形

假設(shè)代碼如下：

//controller層：
@GetMapping("/t1")
@Transactional(rollbackFor = Exception.class)
public void getTest1() {
    String n = countNumService.getCount();
    System.out.println(" t1 : " + n);
    try {
        Thread.sleep(60000);
    } catch (InterruptedException e) {
        throw new RuntimeException(e);
    }
}

@GetMapping("/t2")
@Transactional(rollbackFor = Exception.class)
public void getTest2() {
    String n = countNumService.getCount();
    System.out.println(" t2 : " + n);
    // 忽略其他的增刪操作
}

//service層：
@Override
@Transactional(rollbackFor = Exception.class)
public synchronized String getCount() {
    // 獲取
    CountNum countNum = countNumMapper.selectById(1);

    countNum.setNumber(countNum.getNumber() + 1);
    // 修改
    countNumMapper.updateById(countNum);

    return countNum.getNumber().toString();
}

問題分析

首先，在 getTest1() 和 getTest2() 這兩個方法中都加了 @Transactional 注解，因此它們會分別開啟自己的事務(wù)。假設(shè)在某一刻，兩個線程同時調(diào)用了 /t1 和 /t2 接口，并且 /t1 接口中執(zhí)行了較長的睡眠操作，于是 /t2 的業(yè)務(wù)邏輯率先完成，并且更新了數(shù)據(jù)庫中的Number字段。

隨后 /t1 的業(yè)務(wù)邏輯也完成了，但是由于之前被阻塞了 60 秒鐘，此時讀取到的計數(shù)器值已經(jīng)過期了，不能反映最新的狀態(tài)。因此 /t1 返回的結(jié)果將是過期的數(shù)據(jù)，與 /t2 返回的結(jié)果不一致。所以這段代碼存在一個并發(fā)問題，可能導(dǎo)致數(shù)據(jù)的不一致性。

解決方法

這里我給出常用的解決方法：

把 getCount() 方法上的 synchronized 去掉，使用樂觀鎖的方式來控制并發(fā)訪問。
將 /t1 和 /t2 兩個接口的事務(wù)設(shè)置為同一個事務(wù)，即兩個接口共享同一個事務(wù)上下文?？梢酝ㄟ^ Spring 的聲明式事務(wù)管理機制來實現(xiàn)。(在 Spring 框架中，我們可以使用 @Transactional 注解來聲明式地管理事務(wù)。使用 PROPAGATION_REQUIRED 屬性可以表示當前方法需要加入到一個存在的事務(wù)中，如果不存在，則開啟新的事務(wù)。)
在 getCount() 方法中，進行增量更新，而不是直接把Number字段加 1，例如使用 update count_num set number = number + 1 where id = ? 等 SQL 語句來實現(xiàn)。
保留synchronized關(guān)鍵字的情況下，添加事務(wù)管理器進行手動事務(wù)管理。

代碼參考

1.樂觀鎖方案

@Override
@Transactional(rollbackFor = Exception.class)
public String getCount() {
    CountNum countNum = countNumMapper.selectById(1);
    // 使用版本號作為樂觀鎖
    int version = countNum.getVersion();
    countNum.setNumber(countNum.getNumber() + 1);
    countNum.setVersion(version + 1);
    // 更新操作必須要包含版本號字段
    int rows = countNumMapper.updateById(countNum);
    if (rows == 0) {
        throw new OptimisticLockException("事務(wù)中更新失敗");
    }
    return countNum.getNumber().toString();
}

2.將 /t1 和 /t2 兩個接口的事務(wù)設(shè)置為同一個事務(wù)。在 CountNumService 類的事務(wù)注解上添加了 propagation = Propagation.REQUIRED 屬性，表示當前方法需要加入到一個已存在的事務(wù)中。此時，如果 /t1 和 /t2 調(diào)用的是同一個 CountNumService 實例，則它們將共享同一個事務(wù)上下文。

@Service
public class CountNumService {
    @Autowired
    private CountNumMapper countNumMapper;
    @Transactional(rollbackFor = Exception.class, propagation = Propagation.REQUIRED)
    public String getCount() {
         // 與之前代碼相同
    }
}
@RestController
public class CountNumController {
    @Autowired
    private CountNumService countNumService;
    @GetMapping("/t1")
    public void getTest1() {
        String n = countNumService.getCount();
        System.out.println(" t1 : " + n);
        try {
            Thread.sleep(60000);
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        }
    }
    @GetMapping("/t2")
    public void getTest2() {
        String n = countNumService.getCount();
        System.out.println(" t2 : " + n);
        // 忽略其他的增刪操作
    }
}

3.SQL中增量更新方案

@Mapper
public interface CountNumMapper {
    @Update("UPDATE count_num SET number = number + 1 WHERE id = 1")
    int updateNumber();
}
@Override
@Transactional(rollbackFor = Exception.class)
public String getCount() {
    // 直接執(zhí)行 SQL 語句進行增量更新操作
    countNumMapper.updateNumber();
    // 再查詢一次獲取最新值
    CountNum countNum = countNumMapper.selectById(1);
    return countNum.getNumber().toString();
}

4.手動事務(wù)管理方案

@Service
public class CountNumService {
    @Autowired
    private CountNumMapper countNumMapper;

    // 使用spring事務(wù)管理器
    @Autowired
    private PlatformTransactionManager transactionManager;

    public synchronized String getCount() {
        TransactionStatus status = null;
        try {
            DefaultTransactionDefinition definition = new DefaultTransactionDefinition();
            //將傳播行為設(shè)置為 PROPAGATION_REQUIRED，以確保當前方法在事務(wù)內(nèi)執(zhí)行：
            definition.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED);
            //獲取當前事務(wù)的狀態(tài)信息：
            status = transactionManager.getTransaction(definition);
            
            CountNum countNum = countNumMapper.selectById(1);
            countNum.setNumber(countNum.getNumber() + 1);

            int rows = countNumMapper.updateById(countNum);
            if (rows == 0) {
                throw new RuntimeException("事務(wù)中更新失敗");
            }
            //提交事務(wù)：
            transactionManager.commit(status);
            return countNum.getNumber().toString();
        } catch (Exception e) {
            if (status != null) {
                //回滾事務(wù)：
                transactionManager.rollback(status);
            }
            throw e;
        }
    }
}

到此這篇關(guān)于當Transactional遇上synchronized的解決方法分享的文章就介紹到這了,更多相關(guān)Transactional synchronized內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: