首页 > 其他分享 >一文带你掌握Spring事务核心:TransactionDefinition详解!

一文带你掌握Spring事务核心:TransactionDefinition详解!

时间:2023-12-15 13:31:58浏览次数:42  
标签:事务 隔离 TransactionDefinition Spring PROPAGATION 详解 ISOLATION 级别

TransactionDefinition详解 - 程序员古德

TransactionDefinition是Spring框架中用于定义事务属性的核心接口。在Spring的事务管理中,这个接口扮演着至关重要的角色,它允许开发者定制事务的各种属性,如隔离级别、传播行为、超时时间以及是否只读。

基本介绍

TransactionDefinition 接口的主要方法:

  1. getIsolationLevel(): 返回事务的隔离级别。隔离级别定义了事务如何与其他事务隔离,以避免如脏读、不可重复读和幻读等问题。Spring 支持多种隔离级别,如 ISOLATION_DEFAULTISOLATION_READ_UNCOMMITTEDISOLATION_READ_COMMITTEDISOLATION_REPEATABLE_READISOLATION_SERIALIZABLE
  2. getPropagationBehavior(): 返回事务的传播行为。传播行为决定了当一个事务方法被另一个事务方法调用时,应该如何传播事务。例如,是否应该启动新的事务、使用现有事务还是挂起现有事务等。Spring 支持如 PROPAGATION_REQUIREDPROPAGATION_REQUIRES_NEWPROPAGATION_NESTED 等多种传播行为。
  3. getTimeout(): 返回事务的超时时间(以秒为单位)。如果一个事务运行的时间超过了这个指定的时间,那么它可能会被底层的事务管理系统自动回滚。
  4. isReadOnly(): 返回事务是否为只读。一个只读事务意味着这个事务只读取数据但不修改数据。在某些情况下,数据库可以利用这个信息来优化性能。
  5. getName(): 返回事务的名称。这是一个可选属性,可以为事务提供一个名称,以便于识别和调试。

如下一个简单的 TransactionDefinition 案例:

/**
 * @版权 Copyright by 程序员古德 <br>
 * @创建人 程序员古德 <br>
 * @创建时间 2023/09/19 15:37 <br>
 */

@Transactional(isolation = Isolation.READ_COMMITTED, propagation = Propagation.REQUIRES_NEW)  
public void someTransactionalMethod() {  
    // ... business logic ...  
}

在上面的例子中,指定了事务的隔离级别为 READ_COMMITTED 和传播行为为 REQUIRES_NEW。总的来说,TransactionDefinition 接口为 Spring 提供了一种统一和灵活的方式来定义和配置事务的各种属性,使开发者能够根据不同的业务需求调整事务的行为。

场景介绍

电商系统订单处理

在电商系统中,当用户下单时,通常需要在数据库中创建订单记录,同时更新库存和用户的付款状态,这个过程必须是事务性的,以确保数据的一致性。这场景具有以下特点:

  1. 多个库表操作(创建订单、更新库存、更新付款状态)。
  2. 需要确保所有操作都成功才提交事务。

在该场景中 TransactionDefinition 的伪配置如下:

  • 传播行为PROPAGATION_REQUIRED,因为在一个事务上下文中执行所有操作是有意义的。
  • 隔离级别ISOLATION_READ_COMMITTED,以避免脏读,同时允许一定程度的并发。
  • 超时时间:根据业务需要设定,比如30秒。

银行转账系统

在银行转账系统中,从一个账户扣款并向另一个账户存款必须是一个原子操作,如果在扣款后因为某种原因存款失败,整个转账操作必须回滚。这场景具有以下特点:

  1. 涉及两个账户的数据库操作
  2. 需要确保转账操作的原子性

在该场景中 TransactionDefinition 的伪配置如下:

  • 传播行为PROPAGATION_REQUIRED,确保转账操作的原子性。
  • 隔离级别ISOLATION_SERIALIZABLE,因为金融系统通常需要最严格的隔离级别。
  • 超时时间:相对较长,比如60秒,因为金融交易可能涉及更多验证和处理时间。

内容管理系统

在内容管理系统中,发布一篇文章可能包括在数据库中创建文章记录、更新作者统计信息、发送通知等操作,这些操作需要在一个事务中执行,以确保数据的一致性。。这场景具有以下特点:

  1. 多个数据库和外部系统操作(如发送通知)
  2. 需要确保所有操作都成功才提交事务

在该场景中 TransactionDefinition 的伪配置如下:

  • 传播行为PROPAGATION_REQUIRED,以便在一个事务上下文中执行所有操作。
  • 隔离级别ISOLATION_READ_COMMITTED,以平衡性能和一致性。
  • 超时时间:相对较短,比如10秒,因为内容管理系统通常对性能要求较高。

代码案例

假设,我们正在开发一个简单的银行转账系统,需要确保转账操作的原子性。在案例中我们将使用Spring框架的事务管理功能,并通过TransactionDefinition来定义事务属性,核心代码如下:

import org.springframework.beans.factory.annotation.Autowired;  
import org.springframework.jdbc.core.JdbcTemplate;  
import org.springframework.transaction.PlatformTransactionManager;  
import org.springframework.transaction.TransactionDefinition;  
import org.springframework.transaction.TransactionStatus;  
import org.springframework.transaction.support.DefaultTransactionDefinition;  

/**
 * @版权 Copyright by 程序员古德 <br>
 * @创建人 程序员古德 <br>
 * @创建时间 2023/09/19 15:37 <br>
 */
public class BankService {  
  
    @Autowired  
    private PlatformTransactionManager transactionManager;  
  
    @Autowired  
    private JdbcTemplate jdbcTemplate;  
  
    public void transfer(String fromAccount, String toAccount, double amount) {  
        // 定义一个事务属性对象  
        TransactionDefinition transactionDefinition = new DefaultTransactionDefinition();  
        transactionDefinition.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED);  
        transactionDefinition.setIsolationLevel(TransactionDefinition.ISOLATION_READ_COMMITTED);  
        transactionDefinition.setTimeout(10); // 设置超时时间为10秒  
        transactionDefinition.setReadOnly(false); // 事务不是只读的  
  
        // 获取事务状态对象  
        TransactionStatus transactionStatus = transactionManager.getTransaction(transactionDefinition);  
  
        try {  
            // 从源账户扣钱  
            jdbcTemplate.update("UPDATE account SET balance = balance - ? WHERE account_number = ?", amount, fromAccount);  
            // 向目标账户加钱  
            jdbcTemplate.update("UPDATE account SET balance = balance + ? WHERE account_number = ?", amount, toAccount);  
  
            // 提交事务  
            transactionManager.commit(transactionStatus);  
            System.out.println("转账成功!");  
        } catch (Exception e) {  
            // 回滚事务  
            transactionManager.rollback(transactionStatus);  
            System.out.println("转账失败!");  
            throw e; // 或者选择记录错误日志等其他处理方式  
        }  
    }  
}

在这个案例中,我们定义了一个transfer方法,用于执行转账操作。

在方法内部,我们首先创建了一个DefaultTransactionDefinition对象,并通过setPropagationBehaviorsetIsolationLevelsetTimeoutsetReadOnly方法配置了事务的属性,然后,我们通过transactionManager.getTransaction方法获取了一个TransactionStatus对象,该对象代表了当前事务的状态,在try-catch块中,我们执行了实际的数据库操作(扣钱和加钱),并在成功的情况下提交事务,失败的情况下回滚事务。

最后,我们根据事务的执行结果输出相应的提示信息。

源码解读

这里列出了TransactionDefinition核心方法以及变量,其中一些功能含义、功能重复的就以... 其他XXX ... 进行表示,如下:

package org.springframework.transaction;  
  
import java.io.Serializable;  
/**
 * @版权 Copyright by 程序员古德 <br>
 * @创建人 程序员古德 <br>
 * @创建时间 2023/09/19 15:37 <br>
 */
/**  
 * 事务定义接口,用于定义事务的属性。  
 *  
 * @author Juergen Hoeller  
 * @since 16.03.2003  
 */  
public interface TransactionDefinition extends Serializable {  
  
    /**  
     * 支持当前事务,如果当前没有事务,则新建一个事务。  
     * 这是最常见的选择。  
     */  
    int PROPAGATION_REQUIRED = 0;  
  
    //  
  
    /**  
     * 使用默认的事务隔离级别。  
     * 实际的隔离级别由底层数据库决定。  
     */  
    int ISOLATION_DEFAULT = -1;  
  
    // ... 其他隔离级别常量 ...  
  
    /**  
     * 返回事务的传播行为。  
     * <p>事务的传播行为决定了当在一个事务方法中被另一个事务方法调用时,如何使用事务。  
     * 例如:{@code PROPAGATION_REQUIRED}表示当前方法必须在事务中运行。如果当前存在事务,则加入该事务;  
     * 如果当前没有事务,则新建一个事务。</p>  
     * @return 事务的传播行为常量,如{@code PROPAGATION_REQUIRED}等。  
     */  
    int getPropagationBehavior();  
  
    /**  
     * 返回事务的隔离级别。  
     * <p>事务的隔离级别决定了事务如何处理并发问题。不同的隔离级别会影响脏读、不可重复读和幻读等问题。</p>  
     * @return 事务的隔离级别常量,如{@code ISOLATION_READ_COMMITTED}等。  
     */  
    int getIsolationLevel();  
  
    /**  
     * 返回事务的超时时间(以秒为单位)。  
     * <p>如果事务在规定的时间内没有完成,则会被自动回滚。</p>  
     * @return 超时时间(秒),默认值为-1,表示永不超时。  
     */  
    int getTimeout();  
  
    /**  
     * 返回事务是否为只读。  
     * <p>只读事务不会修改数据,因此可以进行一些优化。</p>  
     * @return 如果事务为只读,则返回{@code true};否则返回{@code false}。  
     */  
    boolean isReadOnly();  
  
    /**  
     * 返回事务的名称。  
     * <p>事务名称可以用于日志记录、监控和调试。</p>  
     * @return 事务的名称,如果没有设置则返回{@code null}。  
     */  
    String getName();  
}

核心总结

TransactionDefinitionSpring框架中用于定义事务属性的核心接口,为开发者提供了事务管理的标准化方式。通过它,我们可以设置事务的传播行为、隔离级别、超时时间和只读属性等,确保数据在并发场景中的一致性和完整性。在实际应用中,TransactionDefinition与其他Spring组件如PlatformTransactionManager结合使用,为数据库操作提供了原子性、一致性、隔离性和持久性的保障,是构建健壮、可维护企业级应用的关键。熟悉并正确使用TransactionDefinition,对于提高系统性能和数据安全性具有重要意义。

标签:事务,隔离,TransactionDefinition,Spring,PROPAGATION,详解,ISOLATION,级别
From: https://blog.51cto.com/bytegood/8840291

相关文章

  • Unity3D ugui适配iPhoneX的齐刘海屏幕详解
    Unity3D是一款强大的游戏开发引擎,广泛应用于手机游戏开发。随着苹果推出了iPhoneX,这款全面屏手机的出现给游戏开发者带来了新的适配问题。本文将详解如何在Unity3D中适配iPhoneX的齐刘海屏幕,并给出相应的技术详解和代码实现。对啦!这里有个游戏开发交流小组里面聚集了一帮热爱学习......
  • spring xml配置文件之context:annotation-config
    我们一般在含有Spring的项目中,可能会看到配置项中包含这个配置节点context:annotation-config。<?xmlversion="1.0"encoding="UTF-8"?><beansxmlns="http://www.springframework.org/schema/beans"xmlns:xsi="http://www.w3.org/2001/XMLSchema-......
  • Spring系列:基于Spring-AOP和Spring-Aspects实现AOP切面编程
    目录一、概念及相关术语概念相关术语①横切关注点②通知(增强)③切面④目标⑤代理⑥连接点⑦切入点作用二、基于注解的AOP技术说明准备工作创建切面类并配置各种通知切入点表达式语法重用切入点表达式获取通知的相关信息环绕通知切面的优先级三、基于XML的AOP准备工作实现一、概念......
  • spring cloud生态中Feign、Ribbon、loadbalancer的一些历史
    背景本意是想写个feign中loadbalancer组件和nacos相遇后,一个兼容相关的问题,后面发现Feign这套东西很深,想一篇文章写清楚很难,就先开一篇,讲历史。Feign、OpenFeign、SpringCloudOpenFeignFeignFeign是Java生态中的一个库,这个库的官方目标是:FeignmakeswritingJavahttpclie......
  • SpringBoot+MyBatis-Plus没有扫描到Mapper的问题
    一、问题:WARN22052---[      main]ConfigServletWebServerApplicationContext: NoMyBatismapperwasfoundin'[xxx.xxx.xxxx]'package.Pleasecheckyourconfiguration.WARN22052---[      main]ConfigServletWebServerApplicationConte......
  • Spring-第四章:Spring注解配置
    四、Spring注解配置1、IoC注解1.1常用注解1.2数据装配1.3其他bean的引用1.4集合的装配1.5生命周期1.6实例化时机&scope作用域2、AOP注解......
  • springboot032 图书馆管理系统-计算机毕业设计源码+LW文档
    摘 要随着社会的发展,计算机的优势和普及使得阿博图书馆管理系统的开发成为必需。阿博图书馆管理系统主要是借助计算机,通过对图书借阅等信息进行管理。减少管理员的工作,同时也方便广大用户对所需图书借阅信息的及时查询以及管理。阿博图书馆管理系统的开发过程中,采用B/S架构,主......
  • C 语言注释和变量详解
    C语言中的注释C语言中可以使用注释来解释代码并使其更具可读性。它还可以在测试替代代码时防止执行。单行注释单行注释以两个斜杠(//)开头。//和行末之间的任何文本都会被编译器忽略(不会被执行)。此示例在代码行之前使用单行注释://这是一个注释printf("HelloWorld!");......
  • Spring-第二章:IoC容器
    二、IoC容器1、IoCIoc必须要添加的四个包2、DI3、第一个程序4、IoC容器的类型5、数据装配toString方法不是构造方法不同bean之间的引用使用refArray:数组值可重复Set:集合值不可重复Map:键值对6、bean生命周期6.1练习......
  • Spring Cloud Gateway的Filter中如果有耗时操作应该如何处理?
    1,如果不处理,会大大影响吞吐量;2,springcloudgateway是reactive的编码风格,改造代码难度很大,很不习惯;3,springcloudgateway使用事件线程处理一个http请求4,事件线程比较少(参考nettyeventloop),不能有耗时操作,否则影响吞吐量;5,springcloudgateway可以使用一个异步线程池:boundedE......