SpringBoot-事务管理

在Spring Boot中，当我们使用了spring-boot-starter-jdbc或spring-boot-starter-data-jpa依赖的时候，框架会自动默认分别注入DataSourceTransactionManager或JpaTransactionManager。所以我们不需要任何额外配置就可以用@Transactional注解进行事务的使用。

spring Boot 使用事务非常简单，首先使用注解 @EnableTransactionManagement 开启事务支持后，然后在访问数据库的Service方法上添加注解 @Transactional 便可。

开启事务

@EnableTransactionManagement 开启事务支持
在Service方法上添加注解 @Transactional

@EnableTransactionManagement
@SpringBootApplication(scanBasePackages = "zmx.springboot")
public class Application {
}

@Transactional(rollbackFor = Exception.class)
@Override
public boolean save(StUser entity) {
    // 其它逻辑
    boolean result = super.save(entity);
    // 其它逻辑
    throw new RuntimeException("测试的异常");
}

多个事务管理器

SpringBoot为我们自动做了，对我们并不透明，如果有多个事务管理器，需要手动指定怎么处理@Transactional的value具体指定使用哪个事务管理器

/**
 * 多个事务管理
 */
@Configuration
public class MyTransactionManagementConfigurer implements TransactionManagementConfigurer {

    @Autowired
    @Qualifier("txManager1")
    private PlatformTransactionManager txManager1;

    /**
     * 创建一个自己的事务管理器
     *
     * @param dataSource
     * @return
     */
    @Bean(name = "txManager1")
    public PlatformTransactionManager txManager1(DataSource dataSource) {
        return new DataSourceTransactionManager(dataSource);
    }

    @Bean(name = "txManager2")
    public PlatformTransactionManager txManager2(DataSource dataSource) {
        return new DataSourceTransactionManager(dataSource);
    }

    /**
     * 其返回值代表在拥有多个事务管理器的情况下默认使用的事务管理器
     *
     * @return
     */
    @Override
    public PlatformTransactionManager annotationDrivenTransactionManager() {
        return txManager1;
    }
}

@Transactional(rollbackFor = Exception.class, value = "txManager2")
@Override
public boolean save(StUser entity) {
    boolean result = super.save(entity);
    throw new RuntimeException("测试的异常");
}

指定隔离级别

隔离级别是指若干个并发的事务之间的隔离程度，与我们开发时候主要相关的场景包括：脏读取、重复读、幻读。org.springframework.transaction.annotation.Isolation枚举类中定义了五个表示隔离级别的值：

public enum Isolation {

   /**
    * 这是默认值，表示使用底层数据库的默认隔离级别。对大部分数据库而言，通常这值就是： READ_COMMITTED 
    */
   DEFAULT(TransactionDefinition.ISOLATION_DEFAULT),

   /**
    * 该隔离级别表示一个事务可以读取另一个事务修改但还没有提交的数据。该级别不能防止脏读和不可重复读。
    */
   READ_UNCOMMITTED(TransactionDefinition.ISOLATION_READ_UNCOMMITTED),

   /**
    * 该隔离级别表示一个事务只能读取另一个事务已经提交的数据。该级别可以防止脏读，这也是大多数情况下的推荐值。
    */
   READ_COMMITTED(TransactionDefinition.ISOLATION_READ_COMMITTED),

   /**
    * 该隔离级别表示一个事务在整个过程中可以多次重复执行某个查询，并且每次返回的记录都相同。即使在多次查询之间有新增的数据满足该查询，这些新增的记录也会被忽略。该级别可以防止脏读和不可重复读。
    */
   REPEATABLE_READ(TransactionDefinition.ISOLATION_REPEATABLE_READ),

   /**
    * 所有的事务依次逐个执行，这样事务之间就完全不可能产生干扰，也就是说，该级别可以防止脏读、不可重复读以及幻读。但是这将严重影响程序的性能。通常情况下也不会用到该级别。
    */
   SERIALIZABLE(TransactionDefinition.ISOLATION_SERIALIZABLE);
}

指定方法：通过使用 isolation 属性设置，例如：

@Transactional(isolation = Isolation.DEFAULT)

事务的传播行为

传播行为是指，如果在开始当前事务之前，一个事务上下文已经存在，此时有若干选项可以指定一个事务性方法的执行行为。

public enum Propagation {

   /**
    * 如果当前存在事务，则加入该事务；如果当前没有事务，则创建一个新的事务
    */
   REQUIRED(TransactionDefinition.PROPAGATION_REQUIRED),

   /**
    * 如果当前存在事务，则加入该事务；如果当前没有事务，则以非事务的方式继续运行。
    */
   SUPPORTS(TransactionDefinition.PROPAGATION_SUPPORTS),

   /**
    * 如果当前存在事务，则加入该事务；如果当前没有事务，则抛出异常。
    */
   MANDATORY(TransactionDefinition.PROPAGATION_MANDATORY),

   /**
    * 创建一个新的事务，如果当前存在事务，则把当前事务挂起。
    */
   REQUIRES_NEW(TransactionDefinition.PROPAGATION_REQUIRES_NEW),

   /**
    * 以非事务方式运行，如果当前存在事务，则把当前事务挂起。
    */
   NOT_SUPPORTED(TransactionDefinition.PROPAGATION_NOT_SUPPORTED),

   /**
    * 以非事务方式运行，如果当前存在事务，则抛出异常。
    */
   NEVER(TransactionDefinition.PROPAGATION_NEVER),

   /**
    * 如果当前存在事务，则创建一个事务作为当前事务的嵌套事务来运行；如果当前没有事务，则该取值等价于 REQUIRED 
    */
   NESTED(TransactionDefinition.PROPAGATION_NESTED);

}

指定方法：通过使用 propagation 属性设置，例如：

@Transactional(propagation = Propagation.REQUIRED)

事务实现机制

在应用系统调用声明了 @Transactional 的目标方法时，Spring Framework 默认使用 AOP 代理，在代码运行时生成一个代理对象，根据 @Transactional 的属性配置信息，这个代理对象决定该声明 @Transactional 的目标方法是否由拦截器 TransactionInterceptor 来使用拦截，在 TransactionInterceptor 拦截时，会在目标方法开始执行之前创建并加入事务，并执行目标方法的逻辑, 最后根据执行情况是否出现异常，利用抽象事务管理器 AbstractPlatformTransactionManager 操作数据源 DataSource 提交或回滚事务。

事务实现机制

TransactionTemplate

在spring-boot-autoconfigure.jar自动装配了TransactionTemplate

@Configuration
@ConditionalOnClass({PlatformTransactionManager.class})
@AutoConfigureAfter({JtaAutoConfiguration.class, HibernateJpaAutoConfiguration.class, DataSourceTransactionManagerAutoConfiguration.class, Neo4jDataAutoConfiguration.class})
@EnableConfigurationProperties({TransactionProperties.class})
public class TransactionAutoConfiguration {
        // ...
        @Bean
        @ConditionalOnMissingBean
        public TransactionTemplate transactionTemplate() {
            return new TransactionTemplate(this.transactionManager);
        }
}

try {
    transactionTemplate.execute(transactionStatus -> {
        //...
        // 通过抛出异常来回滚事务
        throw new RuntimeException("模拟插入记录后失败, 检查是否回滚");
    });
} catch (Exception e) {
     System.out.println("Transaction rolled back");
}

参考于：Spring Boot事务管理详解