spring事务传播行为之使用REQUIRES_NEW不回滚

提示：扫一扫查出行
【扫一扫了解最新限行尾号】
复制提示

最近写spring事务时用到REQUIRES_NEW遇到一些不回滚的问题,所以就记录一下。

场景1:在一个服务层里面方法1和方法2都加上事务,其中方法二设置上propagation=Propagation.REQUIRES_NEW,方法1调用方法2并且在执行完方法2后抛出一个异常,如下代码

@Service
public class BookServiceImpl implements BookService { @Autowired
private JdbcTemplate jdbcTemplate; @Transactional(timeout=4)
public void update() {
// TODO Auto-generated method stub
//售卖扣除库存数量
String sellSql = "UPDATE book_stock SET stock = stock - ? WHERE isbn = (SELECT isbn FROM book WHERE NAME = ?)";
//入账的sql 将赚到的钱添加到account表中的balance
String addRmbSql = "UPDATE account SET balance = balance + ? * (SELECT price FROM book WHERE NAME = ?)";
Object []params = {1,"Spring"}; jdbcTemplate.update(sellSql, params); testUpdate(); jdbcTemplate.update(addRmbSql, params); throw new RuntimeException("故意的一个异常");
}
@Transactional(propagation=Propagation.REQUIRES_NEW)
public void testUpdate() {
//这个业务没什么意义,只是用来测试REQUIRES_NEW的当执行后SpringMVC这本书库存-1
String sql = "UPDATE book_stock SET stock = stock - ? WHERE isbn = (SELECT isbn FROM book WHERE NAME = ?)";
Object []params = {1,"SpringMVC"};
jdbcTemplate.update(sql, params); }

三张表分别是对应account表,book表,book_stock表

private static ClassPathXmlApplicationContext ac = new ClassPathXmlApplicationContext("classpath:spring/*.xml"); @Test
public void testREQUIRES_NEW() { BookService bean = ac.getBean(BookService.class); bean.update();
}

结果是无论是方法1还是方法2都回滚了,那么REQUIRES_NEW就不起作用了,为了探索原因我修改了一下代码

在第5行的地方打印出对象的类型是什么

@Test
public void testREQUIRES_NEW() { BookService bean = ac.getBean(BookService.class);
System.out.println("update的调用者:"+bean.getClass());
bean.update();
}

在第11行的地方打印对象类型

@Transactional(timeout=4)
public void update() {
// TODO Auto-generated method stub
//售卖
String sellSql = "UPDATE book_stock SET stock = stock - ? WHERE isbn = (SELECT isbn FROM book WHERE NAME = ?)";
//入账的sql
String addRmbSql = "UPDATE account SET balance = balance + ? * (SELECT price FROM book WHERE NAME = ?)";
Object []params = {1,"Spring"}; jdbcTemplate.update(sellSql, params);
System.out.println("testUpdate的调用者:"+this.getClass());
testUpdate(); jdbcTemplate.update(addRmbSql, params); throw new RuntimeException("故意的一个异常");
}

运行结果是

显然调用update的对象是一个代理对象,调用testUpdate的对象不是一个代理对象,这就是为什么添加REQUIRES_NEW不起作用，想要让注解生效就要用代理对象的方法，不能用原生对象的.

解决方法：在配置文件中添加标签<aop:aspectj-autoproxy expose-proxy="true"></aop:aspectj-autoproxy>将代理暴露出来，使AopContext.currentProxy()获取当前代理

将代码修改为

<tx:annotation-driven transaction-manager="transactionManager"/>

<aop:aspectj-autoproxy expose-proxy="true"></aop:aspectj-autoproxy>

11 12行将this替换为((BookService)AopContext.currentProxy())

@Transactional(timeout=4)
public void update() {
// TODO Auto-generated method stub
//售卖
String sellSql = "UPDATE book_stock SET stock = stock - ? WHERE isbn = (SELECT isbn FROM book WHERE NAME = ?)";
//入账的sql
String addRmbSql = "UPDATE account SET balance = balance + ? * (SELECT price FROM book WHERE NAME = ?)";
Object []params = {1,"Spring"}; jdbcTemplate.update(sellSql, params);
System.out.println("testUpdate的调用者:"+((BookService)AopContext.currentProxy()).getClass());
((BookService)AopContext.currentProxy()).testUpdate(); jdbcTemplate.update(addRmbSql, params); throw new RuntimeException("故意的一个异常");
}

运行结果

调用的对象变成代理对象了那么结果可想而知第一个事务被挂起,第二个事务执行完提交了然后异常触发,事务一回滚 SpringMVC这本书库存-1,其他的不变

我还看到过另一种解决方法

在第7行加一个BookService类型的属性并且给个set方法,目的就是将代理对象传递过来... 看26 27行显然就是用代理对象去调用的方法所以就解决问题了不过还是用第一个方案好

@Service
public class BookServiceImpl implements BookService { @Autowired
private JdbcTemplate jdbcTemplate; private BookService proxy; public void setProxy(BookService proxy) {
this.proxy = proxy;
} @Transactional(timeout=4)
public void update() {
// TODO Auto-generated method stub
//售卖
String sellSql = "UPDATE book_stock SET stock = stock - ? WHERE isbn = (SELECT isbn FROM book WHERE NAME = ?)";
//入账的sql
String addRmbSql = "UPDATE account SET balance = balance + ? * (SELECT price FROM book WHERE NAME = ?)";
Object []params = {1,"Spring"}; jdbcTemplate.update(sellSql, params);
/* System.out.println("testUpdate的调用者:"+((BookService)AopContext.currentProxy()).getClass());
((BookService)AopContext.currentProxy()).testUpdate();*/ System.out.println(proxy.getClass());
proxy.testUpdate(); jdbcTemplate.update(addRmbSql, params); throw new RuntimeException("故意的一个异常");
}

OK这个问题解决那就下一个

场景2:在一个服务层里面方法1和方法2都加上事务,其中方法二设置上propagation=Propagation.REQUIRES_NEW,方法1调用方法2并且在执行方法2时抛出一个异常没注意看是不是觉得两个场景是一样的,因为我是拷贝下来改的... 差别就是在哪里抛出异常这次是在方法2里面抛出异常, 我将代码还原至场景1的第一个解决方案，然后在方法2里面抛出异常代码如下

@Service
public class BookServiceImpl implements BookService { @Autowired
private JdbcTemplate jdbcTemplate; @Transactional(timeout=4)
public void update() {
// TODO Auto-generated method stub
//售卖
String sellSql = "UPDATE book_stock SET stock = stock - ? WHERE isbn = (SELECT isbn FROM book WHERE NAME = ?)";
//入账的sql
String addRmbSql = "UPDATE account SET balance = balance + ? * (SELECT price FROM book WHERE NAME = ?)";
Object []params = {1,"Spring"}; jdbcTemplate.update(sellSql, params); System.out.println("testUpdate的调用者:"+((BookService)AopContext.currentProxy()).getClass());
((BookService)AopContext.currentProxy()).testUpdate(); jdbcTemplate.update(addRmbSql, params); }
@Transactional(propagation=Propagation.REQUIRES_NEW)
public void testUpdate() {
//这个业务没什么意义,只是用来测试REQUIRES_NEW的
String sql = "UPDATE book_stock SET stock = stock - ? WHERE isbn = (SELECT isbn FROM book WHERE NAME = ?)";
Object []params = {1,"SpringMVC"};
jdbcTemplate.update(sql, params); throw new RuntimeException("在方法二里面抛出一个异常");
}

预期结果是testUpdate这个事务是要回滚的,update这个方法的事务正常执行,所以数据库的变化是balance字段的钱要+60 Spring这本书的库存-1,但是结果是数据库完全没有变化

分析:在testUpdate方法内抛异常被spring aop捕获,捕获后异常又被抛出,那么异常抛出后,是不是update方法没有手动捕获,而是让spring aop自动捕获,所以在update方法内也捕获到了异常,因此都回滚了

这张图片的代码是我debug模式下在testUpdate方法中执行到抛出异常的地方再点step over 跳到的地方显然spring aop捕获到了异常后,再次抛出,这就是为什么update方法会捕获到异常

OK问题很简单解决方案也很简单只需要手动捕获该异常,不让spring aop捕获就OK了

将update方法改为

@Transactional(timeout=4)
public void update() {
// TODO Auto-generated method stub
//售卖
String sellSql = "UPDATE book_stock SET stock = stock - ? WHERE isbn = (SELECT isbn FROM book WHERE NAME = ?)";
//入账的sql
String addRmbSql = "UPDATE account SET balance = balance + ? * (SELECT price FROM book WHERE NAME = ?)";
Object []params = {1,"Spring"}; jdbcTemplate.update(sellSql, params); try {
System.out.println("testUpdate的调用者:"+((BookService)AopContext.currentProxy()).getClass());
((BookService)AopContext.currentProxy()).testUpdate();
} catch (RuntimeException e) {
// TODO Auto-generated catch block
System.out.println(e.getMessage());
e.printStackTrace();
} jdbcTemplate.update(addRmbSql, params); }

执行结果 update执行成功 testUpdate回滚