Spring事务失效原因分析解决

非事务方法调用事务方法会出现问题

&＃64;Autowired
private KsAService ksAService;
public void add() {
this.doAdd();
}
&＃64;Transactional
public void doAdd() {
KsA ksA &＃61; new KsA();
ksA.setName("forlan");
ksAService.insert(ksA);
int res &＃61; 1 / 0;
}


原因&＃xff1a;Spring声明式事务是基于动态代理&＃xff08;AOP&＃xff09;实现的对bean的管理和切片&＃xff0c;为我们每个class生成代理对象&＃xff0c;只有代理对象之间调用&＃xff0c;才会触发切面逻辑&＃xff0c;方法A调用方法B&＃xff0c;这里的ksAService是真实对象&＃xff0c;不是代理对象

解决&＃xff1a;

• add方法加上注解&＃64;Transactional
• doAdd方法中使用代理对象来调用

  &＃64;Transactional
public void doAdd() {
KsA ksA &＃61; new KsA();
ksA.setName("forlan");
KsAService ksAService &＃61;(KsAService) AopContext.currentProxy();
ksAService.insert(ksA);
int res &＃61; 1 / 0;
}


&＃64;Transactional
private void doAdd() {
KsA ksA &＃61; new KsA();
ksA.setName("forlan");
ksAService.insert(ksA);
int res &＃61; 1 / 0;
}


原因&＃xff1a;Spring声明式事务是基于动态代理实现

• 非public修饰&＃xff0c;不能被代理
• static修饰的方法属于类&＃xff0c;不属于对象&＃xff0c;不能被重写&＃xff0c;不能被代理
• final修饰的方法不能被重写&＃xff0c;不能被代理

解决&＃xff1a;不使用这些修饰符&＃xff0c;非public、static、final

• static、final&＃xff0c;代理里面一般有提示&＃xff0c;Methods annotated with ‘&＃64;Transactional’ must be overridable
• 注意不要使用非public修饰&＃xff0c;特别是private&＃xff0c;我们很习惯性写成这个

&＃64;Transactional
public void doAdd() throws IOException{
KsA ksA &＃61; new KsA();
ksA.setName("forlan");
ksAService.insert(ksA);
throw new IOException();
}


原因&＃xff1a;使用Spring的&＃64;Transactiona开启事务&＃xff0c;默认Error和RuntimeException及其子类才会回滚
解决&＃xff1a;指定异常回滚&＃64;Transactional(rollbackFor &＃61; Exception.class)

&＃64;Transactional
public void doAdd() throws RuntimeException {
KsA ksA &＃61; new KsA();
ksA.setName("forlan");
ksAService.insert(ksA);
try {
int res &＃61; 1 / 0;
} catch (Exception e) {
// 抛出异常
// 设置手动回滚
}
}


原因&＃xff1a;自己捕获了异常&＃xff0c;则事务无法感知

解决&＃xff1a;

• 抛出异常&＃xff1a;throw new RuntimeException(e.getMessage());
• 设置手动回滚&＃xff1a;TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();

&＃64;Transactional
public void doAdd() {
new Thread(() -> {
KsA ksA &＃61; new KsA();
ksA.setName("forlan");
ksAService.insert(ksA);
}).start();
int res &＃61; 1 / 0;
}


原因&＃xff1a;因为Spring的事务是通过数据库连接来实现不同线程使用不同的数据库连接&＃xff0c;放在ThreadLocal中&＃xff0c;基于同一数据库连接的事务才能同时提交或回滚&＃xff0c;多线程场景下&＃xff0c;拿到的数据库连接是不一样的
解决&＃xff1a;

• 分布式事务保证
• 自己实现事务回滚

A类事务方法调用B类异步方法

public class A{
&＃64;Transactional
public void add() {
KsA ksA &＃61; new KsA();
ksA.setName("forlan");
ksAService.insert(ksA);
}
}
public class B{
&＃64;Async
public void insert(KsA ksA) {
this.ksADao.insert(ksA);
int res &＃61; 1 / 0;
}
}


原因&＃xff1a;同多线程调用问题类似&＃xff0c;异步方法属于开启一个新线程执行了
解决&＃xff1a;

• 异步方法加上&＃64;Transactional

具体可以了解 Spring事务传播行为实战

比如&＃xff1a;使用了&＃64;Transactional(propagation &＃61; Propagation.NOT_SUPPORTED)&＃xff0c;&＃xff08;不支持事务&＃xff09;如果当前存在事务&＃xff0c;就把当前事务挂起

比如&＃xff0c;MySQL中的MyISAM&＃xff0c;是不支持事务的
原因&＃xff1a;Spring事务基于数据库事务实现

我们使用的SpringBoot默认开启事务支持了&＃xff0c;通过我们引入的依赖jar包&＃xff0c;可以发现&＃64;EnableTransactionManagement