首页 > 编程知识 正文

spring事务传播机制,spring事务传播机制原理

时间:2023-05-03 14:42:34 阅读:242661 作者:1473

事务的传播行为,默认值为 Propagation.REQUIRED。可选的值有:

PROPAGATION.REQUIRED:如果当前没有事务,则创建一个新事务。如果当前存在事务,就加入该事务。该设置是最常用的设置。
PROPAGATION.SUPPORTS:支持当前事务,如果当前存在事务,就加入该事务。如果当前不存在事务,就以非事务执行。
PROPAGATION.MANDATORY:支持当前事务,如果当前存在事务,就加入该事务,如果当前不存在事务,就抛出异常。
PROPAGATION.REQUIRE_NEW:创建新事务,无论当前存不存在事务,都创建新事务。
PROPAGATION.NOT_SUPPORTED:以非事务方式执行操作,如果当前事务存在,就把当前事务挂起。
PROPAGATION.NEVER:以非事务方式执行,如果当前存在事务,则抛出异常。
PROPAGATION.NESTED:如果当前存在事务,则在嵌套事务内执行。如果当前没有事务,则按 REQUIRED 属性执行。
@Transactional 的 propagation 属性代码示例
比如如下代码,save 方法首先调用 method1 方法,然后抛出了异常,就会导致事务回滚,如下两条数据都不会插入数据库。

@Transactional(propagation = Propagation.REQUIRED)
public void save() {

method1();User user = new User("kadxz");userMapper.insertSelective(user);if(true) {throw new RuntimeException("save 抛异常了");}

}

public void method1() {
User user = new User(“czdbd”);
userMapper.insertSelective(user);
}
现在有需求如下,就算 save 方法的后面抛异常了,也不能影响 method1 方法的数据插入。一般方法时给 method1 加入一个新的事务,这样 method1 就会在这个新的事务中执行,原来的事务不会影响到新的事务。例如给 method1 加 propagation 属性为 Propagation.REQUIRES_NEW 的事务。

@Transactional(propagation = Propagation.REQUIRED)
public void save() {

method1();User user = new User("kadxz");userMapper.insertSelective(user);if(true) {throw new RuntimeException("save 抛异常了");}

}

@Transactional(propagation = Propagation.REQUIRES_NEW)
public void method1() {
User user = new User(“czdbd”);
userMapper.insertSelective(user);
}
运行之后,发现并没有起作用,数据也是没有插入数据库。通过查看日志发现,两个方法都是处于同一个事务中,method1 方法并没有创建一个新的事务。

通过 Spring 官方文档可以知道:在默认的代理模式下,只有目标方法由外部调用,才能被 Spring 的事务拦截器拦截。在同一个类中的两个方法直接调用,是不会被 Spring 的事务拦截器拦截,就像上面的 save 方法直接调用了同一个类中 method1 方法,method1 方法不会被 Spring 的事务拦截器拦截。可以使用 AspectJ 取代 Spring AOP 代理来解决这个问题。但是这里不展开。

为了解决这个问题,我们可以新建一个类:

@Service
public class OtherServiceImpl implements OtherService {

@Autowiredprivate UserMapper userMapper;@Transactional(propagation = Propagation.REQUIRES_NEW)public void method1() {User user = new User("psdlf");userMapper.insertSelective(user);}

}
然后再 save 方法中调用 otherService.method1 方法

@Autowired
private OtherService otherService;

@Transactional(propagation = Propagation.REQUIRED)
@Override
public void save() {

otherService.method1();User user = new User("kadxz");userMapper.insertSelective(user);if (true) { throw new RuntimeException("save 抛异常了");}

}
这下,otherService.method1 方法的数据插入成功,save 方法的数据未插入,事务回滚。继续查看日志:

f2739d4f4349c4b593dbb4d78921182e.png
从日志可以看出,首先创建了 save 方法的事务,由于 otherService.method1 方法的 @Transactional 的 propagation 属性为 Propagation.REQUIRES_NEW,所以接着暂停了 save 方法的事务,重新创建了 otherService.method1 方法的事务,接着 otherService.method1 方法的事务提交,接着 save 方法的事务回滚,这就印证了只有目标方法由外部调用,才能被 Spring 的事务拦截器拦截。

Spring 事务传播机制总结
Spring 事务传播机制总共有 7 种,其中使用最多的应该是 PROPAGATION_REQUIRES、PROPAGATION_REQUIRES_NEW 和 PROPAGATION_NESTED。其中所谓的嵌套事务,是指外层的事务如果回滚,会导致内层的事务也回滚;但是内层的事务如果回滚,仅仅是滚回自己的代码。

比如现在有一段业务代码,方法 A 调用方法 B,我希望的是如果方法 A 出错了,此时仅仅回滚方法 A,不能回滚方法 B,这个时候可以给方法 B 使用 REQUIRES_NEW 传播机制,让他们两的事务是不同的。

如果方法 A 调用方法 B,如果出错,方法 B 只能回滚它自己,方法 A 可以带着方法 B 一起回滚。那这种情况可以给方法 B 加上 NESTED 嵌套事务。

版权声明:该文观点仅代表作者本人。处理文章:请发送邮件至 三1五14八八95#扣扣.com 举报,一经查实,本站将立刻删除。