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異步與事務一起使用的問題怎麼解決的詳細內容。更多資訊請關注PHP中文網其他相關文章！