Spring 源码解析 ｜ Spring 事务
共 5734字，需浏览 12分钟
·
2021-10-16 20:16
本文主要讲述 Spring 事务的实现，以及申明式事务 @Transactional 使用案例。
Spring 事务
Spring Framework 为事务管理提供的事务管理器，具有以下优点：
集成简单，它作为 Spring Framework 的一部分。
支持申明式事务和编程式事务。
使用简单我们只需要做对应的配置之后，添加
@Transactional即可使用。
环境介绍：
jdk 17 、 spring 6.x
事务管理器
Spring 事务抽象的关键是事务策略的概念。事务策略由定义 TransactionManager，特别是 org.springframework.transaction.PlatformTransactionManager 命令式事务管理的org.springframework.transaction.ReactiveTransactionManager接口和反应式事务管理。下面是 PlatformTransactionManager 的定义：
public interface PlatformTransactionManager extends TransactionManager {
TransactionStatus getTransaction(@Nullable TransactionDefinition definition)
throws TransactionException;
void commit(TransactionStatus status) throws TransactionException;
void rollback(TransactionStatus status) throws TransactionException;
}
复制代码这主要是一个服务提供者接口 (SPI)，尽管您可以从应用程序代码中以编程方式使用它 。因为 PlatformTransactionManager 是一个接口，所以可以根据需要轻松模拟或存根。它与查找策略（例如 JNDI）无关。PlatformTransactionManager 实现的定义与 Spring Framework IoC 容器中的任何其他对象（或 bean）一样。即使在使用 JTA 时，仅此好处就使 Spring Framework 事务成为有价值的抽象。
同样，按照 Spring 的理念，TransactionException可以由任何PlatformTransactionManager接口的方法抛出的是未经检查的（它扩展了java.lang.RuntimeException 异常）。如果事务执行失败。往往在应用程序代码实际上可以从事务失败中恢复的极少数情况下，我们也可以选择捕获 TransactionException 进行自定义处理。
getTransaction(..) 方法 TransactionStatus 根据 TransactionDefinition 参数返回一个对象 。TransactionStatus如果当前调用堆栈中存在匹配的事务，则返回的可能表示新事务或可以表示现有事务。后一种情况的含义是，与 Java EE 事务上下文一样，TransactionStatus 与执行线程相关联（存储到 ThreadLocal 中）。
TransactionDefinition接口提供以下定义：
传播：通常，事务范围内的所有代码都在该事务中运行。但是，如果在事务上下文已经存在时运行事务方法，您可以指定行为。例如，代码可以在现有事务中继续运行（常见情况），或者可以暂停现有事务并创建新事务。
隔离度：此事务与其他事务的工作隔离的程度。例如，这个事务可以看到来自其他事务的未提交的写入。
超时：此事务在超时和被底层事务基础设施自动回滚之前运行的时间。
只读状态：当您的代码读取但不修改数据时，您可以使用只读事务。在某些情况下，只读事务可能是一种有用的优化，如在使用 Hibernate 的时候。
事务状态
TransactionStatus 为事务提供了控制事务执行和查询事务状态的接口， 定义如下:
public interface TransactionStatus extends TransactionExecution, SavepointManager, Flushable {
@Override
boolean isNewTransaction();
boolean hasSavepoint();
@Override
void setRollbackOnly();
@Override
boolean isRollbackOnly();
void flush();
@Override
boolean isCompleted();
}
复制代码使用案例
声明式事务管理
其实 Spring 事务的核心是通过 Spring Aop 进行介入，然后通过 TransactionManager 管理事务执行策略，执行过程中通过 TransactionStatus 进行事务状态的维护。事务代理上调用方法的概念视图：
使用案例
下面是我一个配置 Spring Transtation 事务的一个案例, 我为了方便通过 jdbctemplate 进行 SQL 执行
添加依赖
implementation project(":spring-core")
implementation project(":spring-context")
implementation project(":spring-beans")
implementation project(":spring-aop")
implementation project(":spring-tx")
implementation project(":spring-jdbc")
implementation 'mysql:mysql-connector-java:5.1.34'
复制代码添加配置
这里有 4 个配置，我们需要配置: DataSource 、DataSourceTransactionManager 、JdbcTemplate TransactionTemplate （JDBC 事务管理）
@Configuration
@Import({SummerMainService.class})
public class DataSourceConfig {
@Bean
public JdbcTemplate jdbcTemplate(DataSource dataSource) {
JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
return jdbcTemplate;
}
/**
* JDBC 事务
*
* @param transactionManager
* @return
*/
@Bean
public TransactionTemplate transactionTemplate(DataSourceTransactionManager transactionManager) {
return new TransactionTemplate(transactionManager);
}
/**
* 申明数据源
*
* @return
*/
@Bean
public DataSource dataSource() {
DriverManagerDataSource dataSource = new DriverManagerDataSource();
dataSource.setDriverClassName("com.mysql.jdbc.Driver");
dataSource.setUrl("jdbc:mysql://127.0.0.1/summer_test?useUnicode=true&characterEncoding=utf-8&useSSL=false");
dataSource.setUsername("root");
dataSource.setPassword("root123");
return dataSource;
}
/**
* 申明事务管理器
*
* @return
*/
@Bean
public DataSourceTransactionManager dataSourceTransactionManager(DataSource dataSource) {
DataSourceTransactionManager dataSourceTransactionManager = new DataSourceTransactionManager();
dataSourceTransactionManager.setDataSource(dataSource);
return dataSourceTransactionManager;
}
}
复制代码业务逻辑
下面的逻辑重要是插入一条数据，如果 id % 2 == 0 就进行事务的回滚。
public class SummerMainService {
@Autowired
private JdbcTemplate jdbcTemplate;
/**
* 编程式事务 例子: @Transactional
*/
@Transactional
public void testCommit() {
String uuid = UUID.randomUUID().toString().replace("-", "");
jdbcTemplate.update("insert into summer_main(`name`) value ('" + uuid + "')");
List> maps = jdbcTemplate.queryForList("select * from summer_main where `name` = '" + uuid + "'");
Integer id = null;
if (maps.size() > 0) {
Map stringObjectMap = maps.get(0);
id = Integer.parseInt(String.valueOf(stringObjectMap.get("id")));
if (id % 2 == 0) {
throw new RuntimeException("system error transaction rollback!");
}
}
jdbcTemplate.update("update summer_main set remarks = 'WaKen Notes' where id = " + id);
}
}
复制代码 程序调用
调用代码如下，我们同样还是分为三个步骤：创建容器，获取对象，调用方法。
public class TransactionTest {
public static void main(String[] args) {
AnnotationConfigApplicationContext applicationContext = new AnnotationConfigApplicationContext(DataSourceConfig.class);
SummerMainService summerMainService = applicationContext.getBean(SummerMainService.class);
summerMainService.testCommit();
}
}
复制代码SQL 脚本
DROP TABLE IF EXISTS `summer_main`;
CREATE TABLE `summer_main` (
`id` int(11) unsigned NOT NULL AUTO_INCREMENT COMMENT 'ID',
`name` varchar(200) DEFAULT NULL COMMENT '名称',
`remarks` varchar(200) DEFAULT NULL COMMENT '备注',
PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;
INSERT INTO `summer_main` (`id`, `name`, `remarks`)
VALUES
(1,'1af523e120ee4229aaedea1badd6af69','WaKen Notes'),
(2,'16988516671447afa585dfc3a0069dd6',NULL),
(3,'820708fb5daa469786272f21410b53c1','WaKen Notes'),
(4,'c4247f97ed524d609e6afe2d7db461ff',NULL);
复制代码参考资料
docs.spring.io/spring-fram…
作者：老郑_
链接：https://juejin.cn/post/7018207621685444639
来源：稀土掘金
著作权归作者所有。商业转载请联系作者获得授权，非商业转载请注明出处。