天天看點

Spring 如何在一個事務中開啟另一個事務?

Spring 如何在一個事務中開啟另一個事務?

這樣的情景可能不常見,但是還是會有的,一旦遇到,如果業務比較複雜,就會很麻煩,但是還是有解決的方案的,比如将一個service方法拆成兩個方法,也就是将兩個操作的事務分開。

但是這隻适用與業務比較簡單的,如果出現多次資料庫的寫操作,而我們調用的系統隻需要其中一個寫操作的最新資料,如果我們将它分開,那麼如果調用目标系統出現異常的時候,那麼之前的寫操作就不能復原了。

舉個簡單的例子:

@Service
public class ServiceA {

  @Transactional
  public void doSomething(){

    向資料庫中添加資料;

    調用其他系統;
  }
}      

這裡就用僞代碼來做示例了,當我們執行了“向資料庫中添加資料”,我們去資料庫中查詢,發現并沒有我們添加的資料,但是當我們的service這個方法執行完成之後,資料庫中就有這條資料了,這是由于資料庫的隔離性造成的。

Spring中的事務注解 @transactional 提供了一個參數:

Propagation propagation() default Propagation.REQUIRED;      

這個參數是定義 Spring事務的傳遞性的,預設值為:required,也就是如果有事務,就加入事務,如果沒有,就建立事務。

這個參數的值有很多,例如:REQUIRES_NEW,這個值就代表建立一個新的事務,與原來的事務分開。這個好像能解決我們的問題。關注Java技術棧公衆号在背景回複:spring,可擷取一份棧長整理的最新 Spring 系列技術幹貨。

我們将剛剛那個方法修改一下:

@Service
public class ServiceA {

  @Transactional
  public void doSomething(){

    insert();

    調用其他系統;
  }

  @Transactional(propagation = Propagation.REQUIRES_NEW)
  public void insert(){
    向資料庫中添加資料;
  }
}      

執行之後,發現結果還是沒有改變,必須要整體執行完成,資料庫中資料才會出現,說明還是在一個事務中。

Spring的核心思想

,推薦你看看。

我們再将代碼修改一下:

@Service
public class ServiceA {

  @Autowired
  private ServiceB serviceB;
  @Transactional
  public void doSomething(){

    serviceB.insert();

    調用其他系統;
  }
}
@Service
public class ServiceB {

  @Transactional(propagation = Propagation.REQUIRES_NEW)
  public void insert(){
    向資料庫中添加資料;
  }
}      

我們将要事務分離出來的方法寫在另一個service中,再次測試,發現執行完插入語句之後,資料庫中就已經能查到資料了,說明事務分離了,完成了我們的需求。

當然** Spring其實也考慮這個,在 **[Spring](http://mp.weixin.qq.com/s?__biz=MzI3ODcxMzQzMw==&mid=2247491561&idx=2&sn=446e9a25108a71bbb8a0c24a955f3ada&chksm=eb539adfdc2413c9e80a4e0811b83b8978f0d2fc367e0ba60c70e36cce2a5c502c4d98623d95&scene=21#wechat_redirect)的配置中,我們隻需要添加标簽:

aop:aspectj-autoproxy expose-proxy="true"/      

或者:

aop:config expose-proxy="true"      

并且在代碼的調用中要求使用代理對象去調用即可:

((ServiceA ) AopContext.currentProxy()).insert();