@Transactional注解详细使用 |
您所在的位置：网站首页 › 数据库注解怎么写 › @Transactional注解详细使用 |
@Transactional注解详细使用
|
目录 一、@Transactional 注解使用注意事项 二、Spring事务的传播规则 三、微服务开发案例 四、Spring 事务源码深度解析 一、@Transactional 注解使用注意事项@Tranasctional注解是Spring 框架提供的声明式注解事务解决方案，我们在开发中使用事务保证方法对数据库操作的原子性，要么全部成功，要么全部失败，在使用@Transactional注解时需要注意以下问题: 1. @Transactional 注解只能用在public 方法上，如果用在protected或者private的方法上，不会报错，但是该注解不会生效。 2. @Transactional注解只能回滚非检查型异常，具体为RuntimeException及其子类和Error子类，可以从Spring源码的DefaultTransactionAttribute类里找到判断方法rollbackOn。 @Override public boolean rollbackOn(Throwable ex) { return (ex instanceof RuntimeException || ex instanceof Error); }3. 使用rollbackFor 属性来定义回滚的异常类型，使用 propagation 属性定义事务的传播行为。如: 回滚Exception类的异常，事务的传播行为支持当前事务，当前如果没有事务，那么会创建一个事务。 @Transactional(rollbackFor = Exception.class,propagation = Propagation.REQUIRED)4. @Transactional注解不能回滚被try{}catch() 捕获的异常。 5. @Transactional注解只能对在被Spring 容器扫描到的类下的方法生效。 其实Spring事务的创建也是有一定的规则，对于一个方法里已经存在的事务，Spring 也提供了解决方案去进一步处理存在事务，通过设置@Tranasctional的propagation 属性定义Spring 事务的传播规则。 二、Spring事务的传播规则Spring事务的传播行为一共有7种，定义在spring-tx模块的Propagation枚举类里，对应的常量值定义在TransactionDefinition接口里,值为int类型的0-6。 PROPAGATION_REQUIRED 支持当前事务，如果当前没有事务，则创建一个事务，这是最常见的选择。 PROPAGATION_SUPPORTS 支持当前事务，如果当前没有事务，就以非事务来执行PROPAGATION_MANDATORY 支持当前事务，如果没有当前事务，就抛出异常。 PROPAGATION_REQUIRES_NEW新建事务，如果当前存在事务，就把当前事务挂起。PROPAGATION_NOT_SUPPORTED以非事务执行操作，如果当前存在事务，则当前事务挂起。 PROPAGATION_NEVER 以非事务方式执行，如果当前存在事务，则抛出异常。PROPAGATION_NESTED如果当前存在事务，则在嵌套事务内执行。如果当前没有事务，则进行与PROPAGATION_REQUIRED 类似的操作。
为了更深入了解Spring 事务的传播规则，跟一下源代码全局搜索getTransaction方法，进入到AbstractPlatformTransactionManager类里的 getTransaction(@Nullable TransactionDefinition definition)
由handleExistingTransaction处理已经存在的事务:
在实际开发中，我们只需要在service类上标记@Transactional注解，类下的方法都能根据指定的异常进行事务回滚。 三、微服务开发案例如果是分布式环境下，得考虑使用分布式事务，此处忽略分布式环境，只演示@Transactional注解的用法。 现有2个服务，workflow服务远程调用payment服务, 设置的事务传播行为为 ：REQUIED
payment服务添加注解: 回滚所有的异常。
用feign实现workflow 服务调用Payment服务: import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestParam; import java.util.List; /** * PaymentInterface * * @Date:2019/8/19 * @remark */ @FeignClient( name = "payment", contextId = "PaymentInterface" ) public interface PaymentInterface { @PostMapping({"/api/implement/payment/cash/transactionData/batch/v2"}) void saveTransactionDatasBatch(@RequestBody List cashTransactionDatas); }测试: workflow 调用payment服务的saveTransactionDatasBatch方法, Payment服务报错，
workflow服务收到错误后执行回滚操作，这个时候去查看payment服务的数据库后发现所有update已回滚。 大家如果想进一步理解transcation的原理，建议继续阅读以下内容。 四、Spring 事务源码深度解析Spring 事务Transaction源码深度解析_Dream_it_possible！的博客-CSDN博客 |
【本文地址】
今日新闻 |
推荐新闻 |