合肥住房城乡建设部的网站/什么是搜索引擎营销?
事务失效场景
-
方法用private或final修饰
Spring底层使用了AOP，而AOP的实现方式有两种，分别是JDK动态代理和CGLIB，JDK动态代理是实现抽象接口，CGLIB是继承父类,无论哪种方式，都需要重写方法来进行方法增强，而用private或final修饰的方法都是不能被重写的 -
方法自调用(如何解决方法自调用导致的事务失效)
UserService类中开启A方法调用B方法，直接调用A方法会导致B方法的Transactional注解不生效，从而导致事务失效
@Component
public class UserService{@Autowiredprivate JdbcTemplate jdbcTemplate;@Transactionalpublic void A() {//this.B()和B()同理B();}@Transactional(propagation = Propagation.NEVER)public void B(){jdbcTemplate.execute("insert into user values(1, 1, '1')");throw new NullPointerException();}
}
为什么事务会失效？Spring生成的代理类大致如下，调用A方法会执行$Proxy0.A()，而B方法是被代理对象target调用的，所以方法不会被增强
public class $Proxy0 extends UserService {private UserService target;public void A() {//建立数据库连接ConnectionConnection connection = DriverManager.getConnection("jdbc:mysql:///user");connection.setAutoCommit(false);try{target.A();}catch(RuntimeException exception){connection.rollback();return;}connection.commit();}
}
- 多线程调用
执行SQL时会从ThreadLocal里获取数据库连接对象，而ThreadLocal是线程隔离的，新线程无法从主线程的ThreadLocal里获取数据库连接对象，所以只能新建一个数据库连接来执行SQL，此时autoCommit默认是true，执行完SQL就会自动提交，抛出异常也就不能回滚了
@Component
public class UserService {@Autowiredprivate JdbcTemplate jdbcTemplate;@Transactionalpublic void B() {new Thread(() -> {jdbcTemplate.execute("insert into user values(1, 1, '1')");throw new NullPointerException();}).start();}
}
-
类没有被Spring管理
-
数据库不支持事务
-
异常被手动try-catch掉了
如何解决方法自调用导致的事务失效
- 自己注入自己
@Component
public class UserService {@Autowiredprivate JdbcTemplate jdbcTemplate;@Autowiredprivate UserService userService;public void A() {//从Spring容器中取出代理对象userService.B();}@Transactionalpublic void B() {jdbcTemplate.execute("insert into user values(1, 1, '1')");throw new NullPointerException();}
}
- 把被调用的方法拆分到别的Bean中，然后再把这个Bean注入进来
- AopContext.currentProxy() + @EnableAspectJAutoProxy(exposeProxy = true)
@Component
public class UserService {@Autowiredprivate JdbcTemplate jdbcTemplate;public void A() {UserService userService = (UserService) AopContext.currentProxy();userService.B();}@Transactionalpublic void B() {jdbcTemplate.execute("insert into user values(1, 1, '1')");throw new NullPointerException();}
}