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 个配置,我们需要配置: DataSourceDataSourceTransactionManagerJdbcTemplate 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
来源:稀土掘金
著作权归作者所有。商业转载请联系作者获得授权,非商业转载请注明出处。



浏览 48
点赞
评论
收藏
分享

手机扫一扫分享

分享
举报
评论
图片
表情
推荐
点赞
评论
收藏
分享

手机扫一扫分享

分享
举报