解讀@Transactional失效的幾種情況

更新時間：2024年08月06日 11:20:18 作者：Q z1997

這篇文章主要介紹了@Transactional失效的幾種情況,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教

Spring事務(wù)管理方式
一、數(shù)據(jù)庫本身不支持
二、注解的方法是否為public
三、異常處理不當(dāng)
四、方法內(nèi)部直接調(diào)用
五、多數(shù)據(jù)源事物配置問題
六、新開啟一個線程
七、事務(wù)傳播屬性設(shè)置錯誤
總結(jié)

Spring事務(wù)管理方式

編碼式事務(wù)管理：將事務(wù)控制代碼編寫在業(yè)務(wù)代碼之中。
聲明式事務(wù)管理：基于AOP(面向切面編程)，事務(wù)管理與業(yè)務(wù)邏輯解耦。

聲明式事務(wù)管理的兩種實(shí)現(xiàn)：

(1)在配置文件(xml)中配置。
(2)基于@Transactional注解。

@Transactional使用起來方便，但也需要注意引起@Transactional失效的場景，本文總結(jié)了七種情況，下面進(jìn)行逐一分析：

一、數(shù)據(jù)庫本身不支持

MySql 的 MyISAM 引擎不支持回滾,如果需要自動回滾事務(wù)，需要將MySql的引擎設(shè)置成InnoDB;

二、注解的方法是否為public

//@Transactional注解在private方法上會失效
@Transactional
private void deleteUser() throws MyException{
    userMapper.deleteUserA();
    int i = 1/0;
    userMapper.deleteUserB();
}

idea直接會給出提示Methods annotated with ‘@Transactional’ must be overridable ，原理很簡單，private修飾的方式，spring無法生成動態(tài)代理，AOP代理分別在intercept()和invoke()方法判斷是否進(jìn)行事務(wù)攔截，這兩個方法都會間接調(diào)用AbstractFallbackTransactionAttributeSource類的computeTransactionAttribute方法來獲取事務(wù)控制的相關(guān)屬性。

這其中有以下一段代碼

    /**
     * Same signature as {@link #getTransactionAttribute}, but doesn't cache the result.
     * {@link #getTransactionAttribute} is effectively a caching decorator for this method.
     * <p>As of 4.1.8, this method can be overridden.
     * @since 4.1.8
     * @see #getTransactionAttribute
     */
    protected TransactionAttribute computeTransactionAttribute(Method method, Class<?> targetClass) {
        // Don't allow no-public methods as required.
        if (allowPublicMethodsOnly() && !Modifier.isPublic(method.getModifiers())) {
            return null;
        }
    //...
  }

這段代碼會導(dǎo)致no-public的方法無法進(jìn)入事務(wù)控制，所以一定要確保自己需要進(jìn)行事務(wù)控制的方法包含public修飾符。

三、異常處理不當(dāng)

當(dāng)異常被捕獲后，并且沒有再拋出，那么deleteUserA是不會回滾的，例如：

@Transactional
public void deleteUser() {
    userMapper.deleteUserA();
    try {
        int i = 1 / 0;
        userMapper.deleteUserB();
    } catch (Exception e) {
        e.printStackTrace();
    }
}

異步雖然拋出了，但是拋出的是非RuntimeException類型的異常，依舊不會生效，例如：

@Transactional
public void deleteUser() throws MyException{
    userMapper.deleteUserA();
    try {
        int i = 1 / 0;
        userMapper.deleteUserB();
    } catch (Exception e) {
        throw new MyException();
    }
}

注解為事務(wù)范圍的方法中，事務(wù)的回滾僅僅對于unchecked的異常有效。對于checked異常無效。也就是說事務(wù)回滾僅僅發(fā)生在，出現(xiàn)RuntimeException或Error的時候。通俗一點(diǎn)就是：代碼中出現(xiàn)的空指針等異常，會被回滾。而文件讀寫、網(wǎng)絡(luò)超時問題等，spring就沒法回滾了。

解決方案：如果指定了回滾異常類型為Exception，那么就可以回滾Checked類型異常了。

@Transactional(rollbackFor = Exception.class)

java里面將派生于Error或者RuntimeException（比如空指針，1/0）的異常稱為unchecked異常，其他繼承自java.lang.Exception得異常統(tǒng)稱為Checked Exception，如IOException、TimeoutException等

四、方法內(nèi)部直接調(diào)用

如果先調(diào)用deleteUser()，那么deleteUserA()是不會回滾的，其原因就是@Transactional根本沒生成代理，例如：

public void deleteUser() throws MyException{
    deleteUser2(); // 事物失效
}

@Transactional
public void deleteUser2() throws MyException{
    userMapper.deleteUserA();
    int i = 1 / 0;
    userMapper.deleteUserB();
}

五、多數(shù)據(jù)源事物配置問題

項(xiàng)目中沒有配置事務(wù)管理器，需要在配置類或者配置文件中配置，因?yàn)轫?xiàng)目是多數(shù)據(jù)源的,所以要區(qū)別配置不同數(shù)據(jù)源的事務(wù)管理器，如下：

    @Primary
    @Bean(name = "db1")
    public DataSource getDataSource() {
        return createDataSource();
    }
    @Bean(name = "db1TransactionManager")
    public PlatformTransactionManager txManager(@Qualifier("db1") DataSource dataSource) {
        return new DataSourceTransactionManager(dataSource);
    }

   @Bean(name = "db2")
   public DataSource getDataSource() {
       return buildDataSource();
   }
   @Bean(name = "db2TransactionManager")
   public PlatformTransactionManager txManager(@Qualifier("db2") DataSource dataSource) {
       return new DataSourceTransactionManager(dataSource);
   }

可以看到,兩個事務(wù)管理器配置了不同的beanName,接下來只需要在需要事務(wù)控制的位置加上該事務(wù)管理器的name就可以完美解決!

   @Override
   @Transactional(value = "db1TransactionManager",rollbackFor = Exception.class)
   public int updateOrInsert(BaseRequest<BankTemplateDto> param) {
      ...
   }

六、新開啟一個線程

如下的方式deleteUserA()也不會回滾，因?yàn)閟pring實(shí)現(xiàn)事務(wù)的原理是通過ThreadLocal把數(shù)據(jù)庫連接綁定到當(dāng)前線程中，新開啟一個線程獲取到的連接就不是同一個了，例如：

@Transactional
public void deleteUser() throws MyException{
    userMapper.deleteUserA();
    try {
        //休眠1秒，保證deleteUserA先執(zhí)行
        Thread.sleep(1000);
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
    new Thread(() -> {
        int i = 1/0;
        userMapper.deleteUserB();
    }).start();    
}