Spring 源码解析 | Spring 事务
本文主要讲述 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
程序调用
调用代码如下,我们同样还是分为三个步骤:创建容器,获取对象,调用方法。
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
来源:稀土掘金
著作权归作者所有。商业转载请联系作者获得授权,非商业转载请注明出处。