@Transactional 與線程鎖：為何聯(lián)用會失效？
作者：一安
很多小伙伴使用Spring事務時，為了省事都喜歡使用@Transactional。但是@Transactional配合鎖，會導致一些預期之外的問題！
很多小伙伴使用Spring事務時，為了省事都喜歡使用@Transactional。但是@Transactional配合鎖，會導致一些預期之外的問題！
在此舉例說明。
數(shù)據(jù)準備
我們將在該表中，實現(xiàn)level數(shù)據(jù)遞減的并發(fā)操作。
圖片
Controller中，簡單模擬10個線程各自執(zhí)行10次：
圖片
@Transactional是如何導致鎖失效的
1、不加鎖
// service代碼
public void test() {
// 簡單的select + update 模擬業(yè)務場景
Model model = mapper.choseOne("99");
// 實現(xiàn) level -- 操作
Model updater = new Model();
updater.setId("99");
updater.setLevel(model.getLevel() - 1);
mapper.updateOne(updater);
}執(zhí)行結果：我們發(fā)現(xiàn)，level只扣減了26，說明存在并發(fā)問題！
圖片
2、使用鎖
// service代碼
private Lock lock = new ReentrantLock();
public void test() {
try {
//加鎖
lock.lock();
// 簡單的select + update 模擬業(yè)務場景
Model model = mapper.choseOne("99");
// 實現(xiàn) level -- 操作
Model updater = new Model();
updater.setId("99");
updater.setLevel(model.getLevel() - 1);
mapper.updateOne(updater);
} finally {
lock.unlock(); // 解鎖
}
}執(zhí)行結果：我們發(fā)現(xiàn)，使用鎖是可以控制并發(fā)問題。
圖片
3、使用鎖+@Transactional
// service代碼
private Lock lock = new ReentrantLock();
@Transactional
public void test() {
try {
//加鎖
lock.lock();
// 簡單的select + update 模擬業(yè)務場景
Model model = mapper.choseOne("99");
// 實現(xiàn) level -- 操作
Model updater = new Model();
updater.setId("99");
updater.setLevel(model.getLevel() - 1);
mapper.updateOne(updater);
} finally {
lock.unlock(); // 解鎖
}
}執(zhí)行結果：我們發(fā)現(xiàn)，level只扣減了86！用了@Transactional之后，鎖怎么就失效了呢！
圖片
4、問題分析
我們都知道，@Transactional是通過使用AOP，在目標方法執(zhí)行前后進行事務的開啟和提交。所以，Lock鎖住的代碼，其實并沒有包含住一整個事務！
通過下面的圖理解一下：
圖片
當線程A將level設置為99時，此時鎖已經(jīng)釋放了，但是事務還沒提交??！線程B此時可以獲取到鎖并進行查詢，查詢出來的level還是線程A修改之前的100，所以出現(xiàn)了并發(fā)問題。
解決方案
1、@Transactional單獨一個方法
private Lock lock = new ReentrantLock();
@Transactional
public void test1() {
// 簡單的select + update 模擬業(yè)務場景
Model model = mapper.choseOne("99");
// 實現(xiàn) level -- 操作
Model updater = new Model();
updater.setId("99");
updater.setLevel(model.getLevel() - 1);
mapper.updateOne(updater);
}
@Autowired
@Lazy
private CommonService commonService;
public void test() {
try {
// 加鎖
lock.lock();
// 自己注入自己，以使用到其代理類
commonService.test1();
} finally {
lock.unlock(); // 解鎖
}
}執(zhí)行結果：沒有并發(fā)問題出現(xiàn)！
圖片
或者直接在controller層加鎖，也是一樣的道理。
2、使用編程式事務
// service代碼
private Lock lock = new ReentrantLock();
@Autowired
private PlatformTransactionManager transactionManager;
public void test() {
try {
//加鎖
lock.lock();
// 編程式事務
TransactionStatus status = transactionManager.getTransaction(new DefaultTransactionDefinition());
// 簡單的select + update 模擬業(yè)務場景
Model model = mapper.choseOne("99");
// 實現(xiàn) level -- 操作
Model updater = new Model();
updater.setId("99");
updater.setLevel(model.getLevel() - 1);
mapper.updateOne(updater);
// 在鎖中提交
transactionManager.commit(status);
} finally {
lock.unlock(); // 解鎖
}
}執(zhí)行結果：我們發(fā)現(xiàn)，將整個事務都鎖住，就沒問題了！
圖片
責任編輯：武曉燕
來源：
一安未來
