使用@Transactional應注意的問題

@Transactional 基本原理概述

在應用系統調用聲明@Transactional 的目標方法時,Spring Framework 默認使用 AOP 代理,在代碼運行時生成一個代理對象,根據@Transactional 的屬性配置信息,這個代理對象決定該聲明@Transactional 的目標方法是否由攔截器 TransactionInterceptor 來使用攔截,在 TransactionInterceptor 攔截時,會在在目標方法開始執行以前建立並加入事務,並執行目標方法的邏輯, 最後根據執行狀況是否出現異常,利用抽象事務管理器AbstractPlatformTransactionManager 操做數據源 DataSource 提交或回滾事務。java

你須要注意的事

  1. @Transactional 只能被應用到public方法上, 對於其它非public的方法,若是標記了@Transactional也不會報錯,但方法沒有事務功能
  2. Spring團隊的建議是你在具體的類(或類的方法)上使用 @Transactional 註解,而不要使用在類所要實現的任何接口上。
  3. 固然能夠在接口上使用 @Transactional 註解,可是這將只能當你設置了基於接口的代理時它才生效。由於註解是不能繼承的,這就意味着若是你正在使用基於類的代理時,那麼事務的設置將不能被基於類的代理所識別,並且對象也將不會被事務代理所包裝(將被確認爲嚴重的)。所以,仍是在具體的類上使用 @Transactional 註解比較好。
  4. 避免 Spring 的 AOP 的自調用問題:自調用就是方法A內調用本類的另外一個加上事務註解的方法B時,方法B中對數據庫的操做是不帶事務的。

Spring AOP 代理下,只有目標方法由外部調用,目標方法才由 Spring 生成的代理對象來管理,這會形成自調用問題。若同一類中的其餘沒有@Transactional 註解的方法內部調用有@Transactional 註解的方法,有@Transactional 註解的方法的事務被忽略,不會發生回滾。spring

失效緣由
image數據庫

方法one方法two都是public的:app

  • classA中 ,任意要調用classB的方法,是經過spring代理的方式,那麼spring的註解纔會生效
  • classA中,方法one 調用同class內的方法two,即this調用,spring註解不會生效(例如@Cachable,@Transaction)

解決方法

既然已知緣由,那麼解決的方法就有了,核心思想就是如何得到動態代理對象,而不是使用this去調用。async

方案一:使用AspectJ代理ide

@Service
public class OrderService {
    private void insert() {
        insertOrder();
    }
@Transactional
    public void insertOrder() {
        //insert log info
        //insertOrder
        //updateAccount
       }
}

insertOrder 儘管有@Transactional 註解,但它被內部方法 insert 調用,事務被忽略,出現異常事務不會發生回滾。this

上面的兩個問題@Transactional 註解只應用到 public 方法和自調用問題,是因爲使用 Spring AOP 代理形成的。爲解決這兩個問題,可使用 AspectJ取代 Spring AOP 代理,但如今有更好的解決方法。代理

方案二:利用AopContext.currentProxy()方法得到代理指針

方法的意思是嘗試返回當前AOP代理。這種作法很是簡潔,可是在默認狀況下是不起做用的!由於AopContext中拿不到currentProxy,會報空指針。須要一些額外的配置,但不能對全部的註解攔截都有效,這是由於這些註解不是用的AspectJ代理,若是是@Transactional事務註解的話, 則是生效的,具體細節要翻源碼了,這裏不推薦使用。code

方案三:經過ApplicationContext來得到動態代理對象(推薦)

@Component
public class AsyncService implements ApplicationContextAware {

    private ApplicationContext applicationContext;

    public void async1() {
        System.out.println("1:" + Thread.currentThread().getName());
        // 使用AppicationContext來得到動態代理的bean
        this.applicationContext.getBean(AsyncService.class).async2();
    }

    @Async
    public void async2() {
        System.out.println("2:" + Thread.currentThread().getName());
    }

    // 注入ApplicationContext
    @Override
    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
        this.applicationContext = applicationContext;
    }
}
相關文章
相關標籤/搜索