SpringBoot異步與事務一起使用的問題解決

更新時間：2023年04月30日 09:22:57 作者：ghimi

本文主要介紹了SpringBoot異步與事務一起使用的問題解決，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧

最近遇到的一個場景,在一個被 @Transactional 注解的方法A中中調(diào)用了一個被 @Async 注解標記的方法B,由于方法B 在執(zhí)行時方法A 的事務沒有提交,但是方法B在執(zhí)行過程中獲取不到方法A中尚未提交的數(shù)據(jù),從而最終倒是方法B執(zhí)行異常。

@Transactional
public void create(User user){
? // 如果用戶已存在，則先刪除
? delete(user.id);
? // 創(chuàng)建用戶
? int userId = insert(user);
? // ?更新用戶信息
? update(userId);
}
@Async
public void update(Integer userId){
? Icon icon = getUserIcon(userId);
? // 更新用戶圖片
? updateUserPohot(userId,icon);
}

像上面的代碼，我為創(chuàng)建用戶的方法上標記了@Transactional事務注解，然后在其中調(diào)用了update()更新方法，這個方法上標記了@Async 注解。這樣代碼雖然看起來沒有什么問題，但是實際在執(zhí)行update()方法時，由于是其他線程去執(zhí)行的，就會導致有可能 create()方法對應的事務還沒有提交，update() 方法就無法讀取到新插入的 user 記錄，從而導致更新失敗。

解決方案

通過調(diào)整邏輯保證事務在調(diào)用異步方法前被提交

這個問題的原因是由于 @Transactional 和 @Async 注解一起使用導致的，那么我們可以從這個方向入手，首先我們可以先確認將create()方法的事務提交后，然后再去執(zhí)行異步更新方法：

public void create(User user){
? int userId = doCreate(user);
? // ?更新用戶信息
? update(userId);
}
@Transactional
public void doCreate(User user){
? ? // 如果用戶已存在，則先刪除
? delete(user.id);
? // 創(chuàng)建用戶
? return insert(user);
}
@Async
public void update(Integer userId){
? Icon icon = getUserIcon(userId);
? // 更新用戶圖片
? updateUserPohot(userId,icon);
}

異步方法放在事務方法外調(diào)用，這樣異步方法就能夠讀取到已經(jīng)提交的事務數(shù)據(jù)了。

或者我們還可以使用TransactionTemplate來代替 @Transactional 注解:

@Autowired
TransactionTemplate transactionTemplate;
public void create(User user){
? int userId = transactionTemplate.execute(status->{
? ? // 如果用戶已存在，則先刪除
? ? delete(user.id);
? ? // 創(chuàng)建用戶
? ? return insert(user);
? });
? // ?更新用戶信息
? update(userId);
}
@Async
public void update(Integer userId){
? Icon icon = getUserIcon(userId);
? // 更新用戶圖片
? updateUserPohot(userId,icon);
}

通過 TransactionTemplate細化了事務粒度，可以保證在調(diào)用異步方法前事務已經(jīng)被提交。

上面的方案基本都能解決問題，下面是從網(wǎng)上找到的，spring 給出的解決方案：

@Transactional
public void create(User user){
? // 如果用戶已存在，則先刪除
? delete(user.id);
? // 創(chuàng)建用戶
? int userId = insert(user);
? TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization() {
? ? @Override
? ? public void afterCommit() {
? ? ? // ?更新用戶信息
? ? ? update(userId);
? ? }
? });
}
@Async
public void update(Integer userId){
? Icon icon = getUserIcon(userId);
? // 更新用戶圖片
? updateUserPohot(userId,icon);
}

通過將異步方法注冊為事務提交后的操作，這樣Spring可以自動幫我們在事務提交后執(zhí)行對應的操作。

參考資料
異步事務？關(guān)于異步@Async + 事務
 @Transactional 事務提交與 @Async 異步執(zhí)行

到此這篇關(guān)于SpringBoot異步與事務一起使用的問題解決的文章就介紹到這了,更多相關(guān)SpringBoot異步與事務一起使用內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: