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

這篇文章主要講解了“SpringBoot異步與事務一起使用的問題怎么解決”，文中的講解內容簡單清晰，易于學習與理解，下面請大家跟著小編的思路慢慢深入，一起來研究和學習“SpringBoot異步與事務一起使用的問題怎么解決”吧！

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

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

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

解決方案

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

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

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

異步方法放在事務方法外調用，這樣異步方法就能夠讀取到已經提交的事務數據了。

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

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

通過 TransactionTemplate細化了事務粒度，可以保證在調用異步方法前事務已經被提交。

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

@Transactional
public void create(User user){
  // 如果用戶已存在，則先刪除
  delete(user.id);
  // 創建用戶
  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可以自動幫我們在事務提交后執行對應的操作。

感謝各位的閱讀，以上就是“SpringBoot異步與事務一起使用的問題怎么解決”的內容了，經過本文的學習后，相信大家對SpringBoot異步與事務一起使用的問題怎么解決這一問題有了更深刻的體會，具體使用情況還需要大家實踐驗證。這里是億速云，小編將為大家推送更多相關知識點的文章，歡迎關注！