Spring事务注解@Transactional失效的八种场景分析

下面就是详细讲解“Spring事务注解@Transactional失效的八种场景分析”的完整攻略。

背景

在Spring框架中，使用@Transactional注解可以方便地定义一个事务。但是，在某些情况下，事务可能会失效，这将导致数据一致性问题。本文将对八种可能导致@Transactional失效的场景进行分析并给出解决方案。

问题场景一：事务调用自身方法不生效

在Spring框架中，事务是通过代理实现的。如果一个类的一个方法调用同类的另一个方法，由于没有经过代理，事务将失效。

解决方案：使用@Transactional(propagation = Propagation.REQUIRES_NEW)注解将方法调用改为使用独立的事务。

示例代码：

@Service
public class MyService {

    @Autowired
    private MyDao myDao;

    // 注意：这里的事务注解不会生效
    @Transactional
    public void methodA() {
        // ...
        methodB();
        // ...
    }

    // 使用独立的事务
    @Transactional(propagation = Propagation.REQUIRES_NEW)
    public void methodB() {
        // ...
    }
}

问题场景二：事务调用未标注@Trasactional的方法不生效

类似于问题场景一，如果一个被@Transactional注解的方法调用了一个未被@Transactional注解的方法，由于没有经过代理，事务将失效。

解决方案：在未被@Transactional注解的方法上添加@Transactional(propagation = Propagation.REQUIRED)注解，来确保该方法在同一事务中运行。

示例代码：

@Service
public class MyService {

    @Autowired
    private MyDao myDao;

    // 注意：这里的事务注解不会生效
    @Transactional
    public void methodA() {
        // ...
        methodB();
        // ...
    }

    // 在该方法上添加注解，以确保在同一事务中运行
    @Transactional(propagation = Propagation.REQUIRED)
    public void methodB() {
        // ...
    }
}

问题场景三：事务注解在private方法上不生效

为了提高代码的复用性和可读性，有时候可能会定义一些private方法来完成一定的业务逻辑。但是，由于Spring框架采用动态代理来实现事务管理，所以private方法上的事务注解不会生效。

解决方案：将private方法改为public方法，或者直接在public方法上添加事务注解。

示例代码：

@Service
public class MyService {

    @Autowired
    private MyDao myDao;

    // private方法上的事务注解无效
    @Transactional
    private void doSomething() {
        // ...
    }

    // 将private方法改为public方法
    @Transactional
    public void doSomethingPublic() {
        doSomething();
    }

    // 直接在public方法上添加事务注解
    @Transactional
    public void doSomethingDirectly() {
        // ...
    }
}

问题场景四：unchecked异常导致事务回滚

在默认情况下，Spring框架只会在遇到运行时异常时回滚事务。所以，如果抛出了unchecked异常，事务将会回滚。但是，如果抛出了checked异常，事务将不会回滚。

解决方案：使用@Transactional(rollbackFor = Exception.class)注解设置事务回滚的异常类型，或者直接使用@Transactional(rollbackFor = RuntimeException.class)注解捕捉所有的unchecked异常。

示例代码：

@Service
public class MyService {

    @Autowired
    private MyDao myDao;

    // 捕捉所有的unchecked异常
    @Transactional(rollbackFor = RuntimeException.class)
    public void doSomething() {
        // ...
    }

    // 设置事务回滚的异常类型
    @Transactional(rollbackFor = Exception.class)
    public void doSomethingWithException() throws Exception {
        // ...
    }
}

问题场景五：catch异常导致事务回滚失效

在使用try-catch块处理异常时，如果在catch块中抛出异常，会导致事务失效。

解决方案：在catch块中手动回滚事务，或者使用RuntimeException来确保事务回滚。

示例代码：

@Service
public class MyService {

    @Autowired
    private MyDao myDao;

    @Transactional
    public void doSomething() {
        try {
            // ...
        } catch(Exception ex) {
            // 手动回滚事务
            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
            throw ex;
        }
    }

    @Transactional(rollbackFor = RuntimeException.class)
    public void doSomethingWithRuntimeException() {
        try {
            // ...
        } catch(Exception ex) {
            throw new RuntimeException(ex);
        }
    }
}

问题场景六：事务的传播属性不正确

事务的传播属性指定了该事务与已有事务的关系，例如是否合并到已有事务中。如果事务的传播属性设置不正确，事务将无法正常工作。

解决方案：在@Transactional注解中设置正确的传播属性。

示例代码：

@Service
public class MyService {

    @Autowired
    private MyDao myDao;

    // 该方法的事务将和调用该方法的方法使用同一个事务
    @Transactional(propagation = Propagation.REQUIRED)
    public void doSomething() {
        // ...
    }

    // 该方法的事务将独立于调用该方法的方法使用
    @Transactional(propagation = Propagation.REQUIRES_NEW)
    public void doSomethingElse() {
        // ...
    }
}

问题场景七：事务和AOP的顺序问题

如果一个方法既使用了AOP也使用了事务，而且AOP的切点在事务开始之前执行，那么事务将不会生效。

解决方案：在<tx:annotation-driven>标签的order属性中指定比AOP更高的顺序。这样就能确保事务在AOP之前执行。

示例代码：

<tx:annotation-driven order="1"/>
<aop:aspectj-autoproxy/>

问题场景八：多事务之间的内部invoke会产生非受检异常

如果一个事务方法在调用另一个新启动的事务方法的内部时，内部事务方法发生了非受检异常，由于内部的事务已经提交，父事务也不可能再回滚了。这是非常危险的，可能会导致数据不一致。

解决方案：使用try-catch块来捕获内部事务方法抛出的异常，并手动对内部事务回滚。

示例代码：

@Service
public class MyService {

    @Autowired
    private MyDao myDao;

    @Transactional
    public void testTransaction() {
        // do something

        try {
            // 调用内部的事务方法
            myDao.invokeTransactionalMethod();
        } catch (Exception e) {
            // 手动回滚内部事务
            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
        }

        // do something
    }
}