Spring Boot 2系列(九):Transaction(事务)的支持

  要理解 Spring Boot 的事务,必须先理解 Spring 的事务机制,可以参考Spring事务机制

自动配置的事务管理器

JDBC访问

Spring Boot 已经定义了实现 PlatformTransactionManager接口的 DataSourceTransactionManagerBean, 配置在org.springframework.boot.autoconfigure.jdbc.DataSourceTransactionManagerAutoConfiguration类文件中。
DataSourceTransactionManager 继承自抽象类 AbstractPlatformTransactionManager,抽象类实现了 PlatformTransactionManager 这个统一的接口。

1
2
3
4
5
6
7
8
9
10
11
@Bean
@ConditionalOnMissingBean(PlatformTransactionManager.class)
public DataSourceTransactionManager transactionManager(
DataSourceProperties properties) {
DataSourceTransactionManager transactionManager = new DataSourceTransactionManager(
this.dataSource);
if (this.transactionManagerCustomizers != null) {
this.transactionManagerCustomizers.customize(transactionManager);
}
return transactionManager;
}

JPA访问

Spring Boot Jpa 是基于 Hibernate 实现的,在org.springframework.boot.autoconfigure.orm.jpa.JpaBaseConfiguration类文件里定义了 PlatformTransactionManager 接口的实现 JpaTransactionManager 的 Bean 。

1
2
3
4
5
6
7
8
9
@Bean
@ConditionalOnMissingBean
public PlatformTransactionManager transactionManager() {
JpaTransactionManager transactionManager = new JpaTransactionManager();
if (this.transactionManagerCustomizers != null) {
this.transactionManagerCustomizers.customize(transactionManager);
}
return transactionManager;
}

在自动配置类 org.springframework.boot.autoconfigure.orm.jpa.HibernateJpaAutoConfiguration 引入了 HibernateJpaConfiguration,自动配置了 JPA的事务。

Transactional自动配置

org.springframework.boot.autoconfigure.transaction.TransactionAutoConfiguration事务自动配置依赖于 JtaAutoConfiguration,HibernateJpaAutoConfiguration,DataSourceTransactionManagerAutoConfiguration自动配置的事务,还开启了声明式事务的支持。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
@Configuration
@ConditionalOnClass(PlatformTransactionManager.class)
@AutoConfigureAfter({ JtaAutoConfiguration.class, HibernateJpaAutoConfiguration.class,
DataSourceTransactionManagerAutoConfiguration.class,
Neo4jDataAutoConfiguration.class })
@EnableConfigurationProperties(TransactionProperties.class)
public class TransactionAutoConfiguration {

...................

//开启了声名式事务的支持
@Configuration
@ConditionalOnBean(PlatformTransactionManager.class)
@ConditionalOnMissingBean(AbstractTransactionManagementConfiguration.class)
public static class EnableTransactionManagementConfiguration {

@Configuration
@EnableTransactionManagement(proxyTargetClass = false)
@ConditionalOnProperty(prefix = "spring.aop", name = "proxy-target-class", havingValue = "false", matchIfMissing = false)
public static class JdkDynamicAutoProxyConfiguration {

}

@Configuration
@EnableTransactionManagement(proxyTargetClass = true)
@ConditionalOnProperty(prefix = "spring.aop", name = "proxy-target-class", havingValue = "true", matchIfMissing = true)
public static class CglibAutoProxyConfiguration {

}
}
}

事务使用

在 Spring Boot中,无须显式使用@EnableTransactionManagement注解来开启事务支持,Spring Boot 通过自动配置,默认就提供了事务的支持,在实际开发中,只需在业务层的类或方法上添加@Transactional注解即可启用事务(相当于XML中的<tx:annotation-driven/>配置方式)。

事务一般是在一条sqlSession里执行多表或多条SQL操作时需要用到。在程序执行遇到运行时异常抛出异常时才会触发事务,在实际开发中抛出异常还得在Controller捕获异常并做最终的处理。

开发时,一般在业务层使用try...catch....捕获异常,在catch里面抛出异常来触发事务,在控制层同样使用try...catch....接收异常,在catch里处理异常并转换为用户可识别的异常消息。

业务层

  1. 业务层
    方法上添加**@Transactional**注解启用事务,捕获并抛出异常来触发事务
    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    @Service
    public class UserServerImpl{

    @Autowired
    private UserMapper userMapper;

    @Override
    @Transactional
    public void addUser(User user) {
    try {
    userMapper.insertUser(user);
    userMapper.insertUserAddress(user.getAddress());

    } catch (Exception e) {
    throw e;
    }
    }
    }
  2. 控制层
    捕获业务层抛出的异常,在catch里处理异常转换为可识别的异常消息。
    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    @RestController
    @RequestMapping(value = "/user")
    public class UserController {

    @Autowired
    private UserService userService;

    @RequestMapping("/saveUser")
    public RespResult saveUser(User user) {
    RespResult respResult = new RespResult();
    try {
    userService.saveUser(user);
    respResult.setState(true).setCodeAndMsg(ResultCodeAndMsg.SUCCESS);
    } catch (Exception e) {
    respResult.setState(false).setCode(4001).setMsg("保存用户失败");
    }
    return respResult;
    }
    }

分布式事务框架

在此备注,后续研究

  1. spring-boot-starter-jta-atomikos
  2. spring-boot-stater-jta-bitronix

Spring Boot 2系列(九):Transaction(事务)的支持

http://blog.gxitsky.com/2018/05/30/SpringBoot-09-transaction/

作者

光星

发布于

2018-05-30

更新于

2022-06-17

许可协议

评论