每天為您推送優(yōu)質(zhì)技術(shù)文章
Spring項目,需要在一個事務中開啟另一個事務。
上面提到的情景可能不常見,但是還是會有的,一旦遇到,如果業(yè)務比較復雜,就會很麻煩,但是還是有解決的方案的,比如將一個service方法拆成兩個方法,也就是將兩個操作的事務分開。
但是這只適用于業(yè)務比較簡單的,如果出現(xiàn)多次數(shù)據(jù)庫的寫操作,而我們調(diào)用的系統(tǒng)只需要其中一個寫操作的最新數(shù)據(jù),如果我們將它分開,那么如果調(diào)用目標系統(tǒng)出現(xiàn)異常的時候,那么之前的寫操作就不能回滾了。
舉個簡單的例子:
@Service
public class ServiceA {
@Transactional
public void doSomething(){
向數(shù)據(jù)庫中添加數(shù)據(jù);
調(diào)用其他系統(tǒng);
}
}
這里就用偽代碼來做示例了,當我們執(zhí)行了“向數(shù)據(jù)庫中添加數(shù)據(jù)”,我們?nèi)?shù)據(jù)庫中查詢,發(fā)現(xiàn)并沒有我們添加的數(shù)據(jù),但是當我們的service這個方法執(zhí)行完成之后,數(shù)據(jù)庫中就有這條數(shù)據(jù)了,這是由于數(shù)據(jù)庫的隔離性造成的。
spring中的事務注解@transactional提供了一個參數(shù):
Propagation propagation() default Propagation.REQUIRED;
這個參數(shù)是定義spring事務的傳遞性的,默認值為required,也就是如果有事務,就加入事務,如果沒有,就創(chuàng)建事務。這個參數(shù)的值有很多,例如REQUIRES_NEW,這個值就代表創(chuàng)建一個新的事務,與原來的事務分開。這個好像能解決我們的問題。
我們將剛剛那個方法修改一下:
@Service
public class ServiceA {
@Transactional
public void doSomething(){
insert();
調(diào)用其他系統(tǒng);
}
@Transactional(propagation = Propagation.REQUIRES_NEW)
public void insert(){
向數(shù)據(jù)庫中添加數(shù)據(jù);
}
}
執(zhí)行之后,發(fā)現(xiàn)結(jié)果還是沒有改變,必須要整體執(zhí)行完成,數(shù)據(jù)庫中數(shù)據(jù)才會出現(xiàn),說明還是在一個事務中。
我們再將代碼修改一下:
@Service
public class ServiceA {
@Autowired
private ServiceB serviceB;
@Transactional
public void doSomething(){
serviceB.insert();
調(diào)用其他系統(tǒng);
}
}
@Service
public class ServiceB {
@Transactional(propagation = Propagation.REQUIRES_NEW)
public void insert(){
向數(shù)據(jù)庫中添加數(shù)據(jù);
}
}
我們將要事務分離出來的方法寫在另一個service中,再次測試,發(fā)現(xiàn)執(zhí)行完插入語句之后,數(shù)據(jù)庫中就已經(jīng)能查到數(shù)據(jù)了,說明事務分離了,完成了我們的需求。
當然spring其實也考慮這個,在spring的配置中,我們只需要添加標簽 <aop:aspectj-autoproxy expose-proxy='true'/>
或者 <aop:config expose-proxy='true'>
,并且在代碼的調(diào)用中要求使用代理對象去調(diào)用即可:
((ServiceA ) AopContext.currentProxy()).insert();
作者:Mazin