Spring 事务及管理方式

Spring 事务管理是 Spring 框架的核心功能之一,它为开发者提供了一种方便、灵活且强大的方式来管理数据库事务。

1、事务的基本概念

事务是一组不可分割的操作序列,这些操作要么全部成功执行,要么全部失败回滚,以确保数据的一致性和完整性。事务具有四个特性,即 ACID 特性:

  • 原子性(Atomicity):事务中的所有操作要么全部执行成功,要么全部失败回滚。

  • 一致性(Consistency):事务执行前后,数据库的状态必须保持一致。

  • 隔离性(Isolation):多个事务并发执行时,一个事务的执行不能被其他事务干扰。

  • 持久性(Durability):事务一旦提交,其对数据库的更改将永久保存。

2、事务的传播行为

事务的传播行为定义了在嵌套事务场景下,事务如何传播。Spring 定义了 7 种事务传播行为:

  • PROPAGATION_REQUIRED:如果当前存在事务,则加入该事务;如果当前没有事务,则创建一个新的事务。

  • PROPAGATION_SUPPORTS:如果当前存在事务,则加入该事务;如果当前没有事务,则以非事务方式执行。

  • PROPAGATION_MANDATORY:如果当前存在事务,则加入该事务;如果当前没有事务,则抛出异常。

  • PROPAGATION_REQUIRES_NEW:创建一个新的事务,如果当前存在事务,则将当前事务挂起。

  • PROPAGATION_NOT_SUPPORTED:以非事务方式执行操作,如果当前存在事务,则将当前事务挂起。

  • PROPAGATION_NEVER:以非事务方式执行操作,如果当前存在事务,则抛出异常。

  • PROPAGATION_NESTED:如果当前存在事务,则在嵌套事务内执行;如果当前没有事务,则创建一个新的事务。

使用 @Transactional 注解指定传播行为的示例:

import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;

@Service
public class UserService {

    @Transactional(propagation = Propagation.REQUIRES_NEW)
    public void transferMoney() {
        // 执行数据库操作
    }
}

3、事务的隔离级别

事务的隔离级别定义了一个事务对其他事务的可见性。Spring 支持 4 种事务隔离级别:

  • ISOLATION_DEFAULT:使用数据库默认的隔离级别。

  • ISOLATION_READ_UNCOMMITTED:允许读取未提交的数据,可能会导致脏读、不可重复读和幻读。

  • ISOLATION_READ_COMMITTED:只允许读取已提交的数据,可以避免脏读,但可能会导致不可重复读和幻读。

  • ISOLATION_REPEATABLE_READ:确保在同一个事务中多次读取同一数据的结果是一致的,可以避免脏读和不可重复读,但可能会导致幻读。

  • ISOLATION_SERIALIZABLE:最高的隔离级别,确保事务串行执行,可以避免脏读、不可重复读和幻读,但会影响并发性能。

使用 @Transactional 注解指定隔离级别的示例:

import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Isolation;
import org.springframework.transaction.annotation.Transactional;

@Service
public class UserService {

    @Transactional(isolation = Isolation.READ_COMMITTED)
    public void transferMoney() {
        // 执行数据库操作
    }
}

4、Spring 事务管理的实现方式

Spring 提供了两种事务管理方式:编程式事务管理和声明式事务管理。

4.1 编程式事务管理

编程式事务管理需要在代码中显式地管理事务的开始、提交和回滚。Spring 提供了 TransactionTemplatePlatformTransactionManager 来实现编程式事务管理。

使用 TransactionTemplate 的示例:

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.TransactionStatus;
import org.springframework.transaction.support.TransactionCallbackWithoutResult;
import org.springframework.transaction.support.TransactionTemplate;

@Service
public class UserService {

    @Autowired
    private TransactionTemplate transactionTemplate;

    public void transferMoney() {
        transactionTemplate.execute(new TransactionCallbackWithoutResult() {
            @Override
            protected void doInTransactionWithoutResult(TransactionStatus status) {
                try {
                    // 执行数据库操作
                    // 例如:从账户 A 转账到账户 B
                } catch (Exception e) {
                    status.setRollbackOnly();
                }
            }
        });
    }
}

使用 PlatformTransactionManager的示例:

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.PlatformTransactionManager;
import org.springframework.transaction.TransactionDefinition;
import org.springframework.transaction.TransactionStatus;
import org.springframework.transaction.support.DefaultTransactionDefinition;

@Service
public class UserService {
    @Autowired
    private PlatformTransactionManager transactionManager;

    public void addUser() {
        TransactionDefinition def = new DefaultTransactionDefinition();
        TransactionStatus status = transactionManager.getTransaction(def);
        try {
            // 业务逻辑代码
            transactionManager.commit(status);
        } catch (Exception e) {
            transactionManager.rollback(status);
        }
    }
}

解释 

  • PlatformTransactionManager:Spring 提供的事务管理器接口,用于管理事务的提交、回滚等操作。

  • TransactionDefinition:定义事务的属性,如隔离级别、传播行为等。

  • TransactionStatus:表示当前事务的状态,通过 transactionManager.getTransaction(def) 方法获取。

  • 手动提交和回滚:在代码中手动调用 transactionManager.commit(status) 提交事务,调用 transactionManager.rollback(status) 回滚事务。

优缺点

  • 优点

    • 对事务的控制非常精细,可以根据业务逻辑在代码的任何位置灵活地开启、提交或回滚事务。

    • 适用于复杂的事务处理场景,例如需要根据不同的业务条件动态决定是否提交或回滚事务。

  • 缺点

    • 代码中会包含大量的事务管理代码,导致业务逻辑和事务管理逻辑耦合度高,增加了代码的复杂度和维护难度。

    • 当业务逻辑发生变化时,可能需要同时修改事务管理代码,不符合开闭原则。

适用场景

  • 事务逻辑复杂,需要根据业务条件动态控制事务的提交和回滚。

  • 对事务管理有特殊需求,例如需要在事务中执行一些非数据库操作,并且要保证这些操作与数据库操作的原子性。

4.2 声明式事务管理

声明式事务管理是通过 AOP(面向切面编程)实现的,它允许开发者通过配置的方式来定义事务的边界,而不需要在代码中显式地管理事务。声明式事务管理有两种配置方式:基于 XML 配置和基于注解配置。

@Transactional 注解默认的事务隔离级别是 ISOLATION_DEFAULT(使用数据库默认的隔离级别

@Transactional 注解默认的事务传播行为是 PROPAGATION_REQUIRED(如果当前存在事务,则加入该事务;如果当前没有事务,则创建一个新的事务

基于注解配置的示例:

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

@Service
public class UserService {

    @Autowired
    private UserDao userDao;

    @Transactional
    public void transferMoney() {
        // 执行数据库操作
        // 例如:从账户 A 转账到账户 B
    }
}

解释

  • @Transactional 注解:在方法上添加 @Transactional 注解,Spring 会自动管理该方法的事务。如果方法执行过程中抛出异常,Spring 会自动回滚事务。

在配置类中开启事务注解支持:

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.transaction.PlatformTransactionManager;
import org.springframework.transaction.annotation.EnableTransactionManagement;

import javax.sql.DataSource;

@Configuration
@EnableTransactionManagement
public class AppConfig {

    @Autowired
    private DataSource dataSource;

    @Bean
    public PlatformTransactionManager transactionManager() {
        return new DataSourceTransactionManager(dataSource);
    }
}

优缺点

  • 优点

    • 事务管理代码与业务逻辑分离,降低了代码的耦合度,使业务代码更加简洁、清晰,易于维护。

    • 通过配置的方式定义事务,提高了开发效率,减少了重复代码。

  • 缺点

    • 事务的控制粒度相对较粗,不够灵活。例如,无法在方法内部的某个具体位置精确控制事务的提交和回滚。

    • 由于是基于 AOP 实现的,可能会带来一定的性能开销。

适用场景

  • 事务逻辑相对简单,且事务边界比较固定的场景。

  • 大多数业务方法都需要相同的事务管理策略,通过统一的注解配置可以提高开发效率。

4.2.1 注意事项

1. 注意 @Transactional 注解位置

该注解可以用在方法上,此时仅对该方法生效。要确保该方法是 public 的,因为 Spring AOP 基于代理模式,默认情况下,只有 public 方法才会被代理增强。

若将注解放在类上,意味着该类中的所有 public 方法都会启用事务管理。不过,要注意如果类中有部分方法不需要事务,这种方式可能会带来不必要的事务开销。

2.异常处理与回滚规则

默认回滚规则:@Transactional 默认只对 RuntimeException 及其子类和 Error 进行回滚。如果业务代码中抛出的是受检异常(如 IOException),默认情况下事务不会回滚。

import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.io.IOException;

@Service
public class UserService {
    @Transactional
    public void saveUser() throws IOException {
        // 业务逻辑
        throw new IOException("文件操作异常"); // 默认不回滚
    }
}

自定义回滚规则:可通过 rollbackFornoRollbackFor 属性来指定需要回滚和不需要回滚的异常类型。

import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.io.IOException;

@Service
public class UserService {
    @Transactional(rollbackFor = {IOException.class})
    public void saveUser() throws IOException {
        // 业务逻辑
        throw new IOException("文件操作异常"); // 会回滚
    }
}

 3. 事务传播行为和隔离级别

合理选择传播行为:传播行为定义了事务方法如何与当前事务进行交互,有 REQUIREDSUPPORTSMANDATORY 等多种传播行为。例如,REQUIRED 是最常用的传播行为,若当前存在事务则加入,不存在则创建新事务;而 SUPPORTS 表示若当前存在事务则加入,不存在则以非事务方式执行。要根据业务需求合理选择,避免不必要的事务嵌套。

import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;

@Service
public class UserService {
    @Transactional(propagation = Propagation.REQUIRED)
    public void saveUser() {
        // 业务逻辑
    }
}

隔离级别定义了一个事务对其他事务的可见性,有 READ_UNCOMMITTEDREAD_COMMITTEDREPEATABLE_READSERIALIZABLE 等。过高的隔离级别会增加事务的并发控制开销,要根据业务需求选择合适的隔离级别,如大多数场景使用 READ_COMMITTED 即可。

import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Isolation;
import org.springframework.transaction.annotation.Transactional;

@Service
public class UserService {
    @Transactional(isolation = Isolation.READ_COMMITTED)
    public void saveUser() {
        // 业务逻辑
    }
}

4. 代理机制

内部方法调用问题

同一类内方法调用:Spring AOP 基于代理模式,当在同一个类的一个无事务方法中调用有 @Transactional 注解的方法时,事务不会生效。因为这种调用没有经过代理对象,而是直接调用目标对象的方法。

import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

@Service
public class UserService {
    public void nonTransactionalMethod() {
        this.transactionalMethod(); // 事务不生效
    }

    @Transactional
    public void transactionalMethod() {
        // 业务逻辑
    }
}

 可以通过注入自身代理对象来解决,或者将有事务的方法提取到另一个服务类中。

5. 数据源和事务管理器配置

确保数据源与事务管理器匹配:要保证数据源和事务管理器的配置正确且相互匹配。如果使用多个数据源,需要为每个数据源配置相应的事务管理器,并在 @Transactional 注解中指定使用的事务管理器。

import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

@Service
public class UserService {
    @Transactional("transactionManager2")
    public void saveUser() {
        // 业务逻辑
    }
}

6. 缩小事务范围,减少事务持有时间:尽量将不需要事务的操作放在事务之外执行,缩小事务的范围,减少事务持有锁的时间,从而提高并发性能。例如,先进行查询操作,再将需要事务的更新操作放在事务方法中。

4.2.2 @Transactional 注解失效的情况

1. 注解应用在非 public 方法上

Spring AOP 基于代理模式实现事务管理,@Transactional 注解只能应用在 public 方法上。如果应用在非 public 方法上,事务将失效。

import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

@Service
public class UserService {
    // 非 public 方法,事务失效
    @Transactional
    protected void saveUser() {
        // 数据库操作
    }
}

解决办法:将方法的访问修饰符改为 public

2. 同一类中方法调用

在同一个类中,一个方法调用另一个带有 @Transactional 注解的方法,事务会失效。这是因为 Spring AOP 是基于代理模式,同一类中的方法调用不会经过代理对象。

import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

@Service
public class UserService {
    public void outerMethod() {
        innerMethod();
    }

    @Transactional
    public void innerMethod() {
        // 数据库操作
    }
}

解决办法:可以通过注入自身代理对象来调用带有事务的方法。

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

@Service
public class UserService {
    @Autowired
    private UserService self;

    public void outerMethod() {
        self.innerMethod();
    }

    @Transactional
    public void innerMethod() {
        // 数据库操作
    }
}

3. 异常类型不匹配

@Transactional 注解默认只对 RuntimeException 及其子类和 Error 进行回滚。如果抛出的异常不是这些类型,事务不会回滚。

import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.io.IOException;

@Service
public class UserService {
    @Transactional
    public void saveUser() throws IOException {
        // 数据库操作
        throw new IOException("IO 异常");
    }
}

解决办法:可以通过 rollbackFor 属性指定需要回滚的异常类型。

import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.io.IOException;

@Service
public class UserService {
    @Transactional(rollbackFor = Exception.class)
    public void saveUser() throws IOException {
        // 数据库操作
        throw new IOException("IO 异常");
    }
}

4. 数据库不支持事务

不同的数据库对事务的支持不同,例如 MySQL 的 MyISAM 存储引擎不支持事务,即使使用 @Transactional 注解,事务也不会生效。

解决办法:将数据库表的存储引擎改为支持事务的引擎,如 MySQL 的 InnoDB。

5. 事务传播行为配置错误

@Transactional 注解的 propagation 属性用于配置事务的传播行为,如果配置不当,可能导致事务失效。

import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;

@Service
public class UserService {
    @Transactional(propagation = Propagation.NOT_SUPPORTED)
    public void saveUser() {
        // 数据库操作
    }
}

Propagation.NOT_SUPPORTED 表示以非事务方式执行操作,如果当前存在事务,将把当前事务挂起。

根据业务需求选择合适的事务传播行为,如 Propagation.REQUIRED 表示如果当前没有事务,就新建一个事务,如果已经存在一个事务中,加入到这个事务中。

import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;

@Service
public class UserService {
    @Transactional(propagation = Propagation.REQUIRED)
    public void saveUser() {
        // 数据库操作
    }
}

6. 没有开启 Spring 事务管理

如果没有在 Spring 配置中开启事务管理,@Transactional 注解将不会生效。

解决办法
在 Spring Boot 项目中,在主类上添加 @EnableTransactionManagement 注解。

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.transaction.annotation.EnableTransactionManagement;

@SpringBootApplication
@EnableTransactionManagement
public class Application {
    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }
}

4.3 两种方式的对比

编程式事务管理声明式事务管理
代码耦合度高,事务管理代码与业务逻辑代码紧密耦合低,事务管理代码与业务逻辑代码分离
灵活性高,可以在代码中根据具体情况灵活控制事务的开始、提交和回滚相对较低,主要通过注解配置事务属性
可维护性低,事务管理代码分散在业务逻辑代码中,维护困难高,事务管理代码集中在注解中,易于维护
适用场景适用于事务管理逻辑复杂,需要根据具体情况灵活控制事务的场景适用于大多数业务场景,特别是事务管理逻辑相对简单的场景

综上所属,编程式事务管理适合复杂的事务处理场景,而声明式事务管理则更适合事务逻辑相对简单、需要提高开发效率和降低代码耦合度的场景。在实际开发中,可以根据具体需求选择合适的事务管理方式。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:/a/971759.html

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

百达翡丽(Patek Philippe):瑞士制表的巅峰之作(中英双语)

百达翡丽(Patek Philippe):瑞士制表的巅峰之作 在钟表界,百达翡丽(Patek Philippe) 一直被誉为“世界三大名表”之一,并且常被认为是其中的至高存在。一句“没人能真正拥有一枚百达翡丽&#x…

153~173笔记

Pinia是Vue的最新状态管理工具,是Vuex的替代品 提供更加简单的API(去掉了mutation) 提供符合,组合式风格的API(和Vue3新语法统一) 去掉了modules的概念,每一个store都是一个独立的模块 配合Type…

【论文笔记】Transformer^2: 自适应大型语言模型

Code repo: https://github.com/SakanaAI/self-adaptive-llms 摘要 自适应大型语言模型(LLMs)旨在解决传统微调方法的挑战,这些方法通常计算密集且难以处理多样化的任务。本文介绍了Transformer(Transformer-Squared)…

c语言-链表习题

1.尾插法 Q6544 涉及: (1)创建链表 struct stu* createList() {struct stu *head NULL, *tail NULL, *newNode;char choice;char name[20];float price;do {printf("请输入书名 价格:\n");scanf("%s %f",…

阿里云一键部署DeepSeek-V3、DeepSeek-R1模型

目录 支持的模型列表 模型部署 模型调用 WebUI使用 在线调试 API调用 关于成本 FAQ 点击部署后服务长时间等待 服务部署成功后,调用API返回404 请求太长导致EAS网关超时 部署完成后,如何在EAS的在线调试页面调试 模型部署之后没有“联网搜索…

Springboot集成Spring AI和Milvus,验证RAG构建过程

在当今信息爆炸的时代,如何高效地管理和利用海量的知识数据成为了企业和开发者面临的重大挑战。基于AI的大模型和检索增强生成(RAG, Retrieval-Augmented Generation)技术为这一难题提供了全新的解决方案。通过结合向量数据库、Embedding技术…

用React实现一个登录界面

使用React来创建一个简单的登录表单。以下是一个基本的React登录界面示例: 1. 设置React项目 如果你还没有一个React项目,你可以使用Create React App来创建一个。按照之前的步骤安装Create React App,然后创建一个新项目。 2. 创建登录组…

Python爬虫实战:股票分时数据抓取与存储 (1)

在金融数据分析中,股票分时数据是投资者和分析师的重要资源。它能够帮助我们了解股票在交易日内的价格波动情况,从而为交易决策提供依据。然而,获取这些数据往往需要借助专业的金融数据平台,其成本较高。幸运的是,通过…

通过BingAPI爬取Bing半个月内壁纸

通过BingAPI爬取Bing半个月内壁纸 一、前言二、爬虫代码三、代码说明 一、前言 爬取Bing搜索网站首页壁纸的方式主要有两种,第一种为间接爬取,即并不直接对Bing网站发起请求,而是对那些收集汇总了Bing壁纸的网站发起请求,爬取图片…

matlab汽车动力学半车垂向振动模型

1、内容简介 matlab141-半车垂向振动模型 可以交流、咨询、答疑 2、内容说明 略 3、仿真分析 略 4、参考论文 略

在Ubuntu24.04上安装Stable-Diffusion1.10.1版本

之前曾介绍过在Ubuntu22.04上安装Stable-Diffusion: 在Ubuntu22.04上部署Stable Diffusion_ubuntu stable dif-CSDN博客 这个安装我们使用conda python虚拟机。这次我们介绍的是在Ubuntu24.04安装Stable-Diffusion的最新版本V1.10.1(截止到今天最新版&…

功能测试与接口测试详解

🍅 点击文末小卡片,免费获取软件测试全套资料,资料在手,涨薪更快 本文主要分为两个部分: 第一部分:主要从问题出发,引入接口测试的相关内容并与前端测试进行简单对比,总结两者之前的…

IDEA集成DeepSeek

使用版本: IDEA 2024.3,Python3.11 通过CodeGPT插件安装: 1. 安装Python环境,安装完成后python --version验证是否成功 2. DeepSeek官网获取API Key 3. IDEA中安装CodeGPT插件 文件->设置->插件,搜"CodeGPT" …

DeepSeek笔记(二):DeepSeek局域网访问

如果有多台电脑,可以通过远程访问,实现在局域网环境下多台电脑共享使用DeepSeek模型。在本笔记中,首先介绍设置局域网多台电脑访问DeepSeek-R1模型。 一、启动Ollama局域网访问 1.配置环境变量 此处本人的操作系统是Windows11,…

计算机视觉-OpenCV图像处理

1.Matplotlib数据可视化(绘制图像直方图、可视化矩阵) # Matplotlib 数据可视化(绘制图像直方图、可视化矩阵) # 本节主要讲解如何使用 Matplotlib 绘制图像直方图和可视化矩阵。 # 1. 绘制图像直方图 # 2. 可视化矩阵# 1. 绘制图…

golangAPI调用deepseek

目录 1.deepseek官方API调用文档1.访问格式2.curl组装 2.go代码1. config 配置2.模型相关3.错误处理4.deepseekAPI接口实现5. 调用使用 3.响应实例 1.deepseek官方API调用文档 1.访问格式 现在我们来解析这个curl 2.curl组装 // 这是请求头要加的参数-H "Content-Type:…

闭源大语言模型的怎么增强:提示工程 检索增强生成 智能体

闭源大语言模型的怎么增强 提示工程 检索增强生成 智能体 核心原理 提示工程:通过设计和优化提示词,引导大语言模型进行上下文学习和分解式思考,激发模型自身的思维和推理能力,使模型更好地理解和生成文本,增强其泛用性和解决问题的能力。检索增强生成:结合检索的准确…

《计算机视觉》——角点检测和特征提取sift

角点检测 角点的定义: 从直观上理解,角点是图像中两条或多条边缘的交点,在图像中表现为局部区域内的灰度变化较为剧烈的点。在数学和计算机视觉中,角点可以被定义为在两个或多个方向上具有显著变化的点。比如在一幅建筑物的图像…

具身智能在智能巡检机器人中的应用——以开关柜带电操作机器人为例

随着机器人技术和人工智能的迅速发展,具身智能在各行业的应用日益广泛,尤其是在电力行业中的智能巡检领域。传统的电力巡检和维护工作通常需要人工操作,存在着高温、高压、强电磁场等危险环境,且效率较低。开关柜带电操作机器人作…

基于SpringBoot实现的大学社团平台系统实现功能八

一、前言介绍: 1.1 项目摘要 随着高校社团活动的日益丰富和多样化,学生对于社团管理和参与的需求也在不断增加。传统的社团管理方式往往存在效率低下、信息不透明等问题,无法满足现代学生对于便捷、高效社团管理的需求。因此,利…