Spring 事务及管理方式

news2025/2/19 16:24:13

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 实现的,可能会带来一定的性能开销。

适用场景

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

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

注意事项:

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.3 两种方式的对比

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

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

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

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

GESP2024年9月认证C++七级( 第三部分编程题(1)小杨寻宝)

参考程序&#xff1a; #include <bits/stdc.h> using namespace std; const int N 1e510; vector<int> g[N]; // 图的邻接表 int col[N], dep[N], has[N];// 深度优先遍历&#xff0c;计算每个节点的深度 void dfs(int x, int fa) {dep[x] dep[fa] 1; // 计算…

解锁电商数据宝藏:淘宝商品详情API实战指南

在电商蓬勃发展的今天&#xff0c;数据已成为驱动业务增长的核心引擎。对于商家、开发者以及数据分析师而言&#xff0c;获取精准、实时的商品数据至关重要。而淘宝&#xff0c;作为国内最大的电商平台&#xff0c;其海量商品数据更是蕴含着巨大的价值。 本文将带你深入探索淘…

webshell通信流量分析

环境安装 Apatche2 php sudo apt install apache2 -y sudo apt install php libapache2-mod-php php-mysql -y echo "<?php phpinfo(); ?>" | sudo tee /var/www/html/info.php sudo ufw allow Apache Full 如果成功访问info.php&#xff0c;则环境安…

在 rtthread中,rt_list_entry (rt_container_of) 已知结构体成员的地址,反推出结构体的首地址

rt_list_entry (rt_container_of)宏定义&#xff1a; /*** rt_container_of - return the start address of struct type, while ptr is the* member of struct type.*/ #define rt_container_of(ptr, type, member) \((type *)((char *)(ptr) - (unsigned long)(&((type *…

趣味魔法项目 LinuxPDF —— 在 PDF 中启动一个 Linux 操作系统

最近&#xff0c;一位开源爱好者开发了一个LinuxPDF 项目&#xff08;ading2210/linuxpdf: Linux running inside a PDF file via a RISC-V emulator&#xff09;&#xff0c;它的核心功能是在一个 PDF 文件中启动并运行 Linux 操作系统。它通过巧妙地使用 PDF 文件格式中的 Ja…

【Linux】Socket编程—TCP

&#x1f525; 个人主页&#xff1a;大耳朵土土垚 &#x1f525; 所属专栏&#xff1a;Linux系统编程 这里将会不定期更新有关Linux的内容&#xff0c;欢迎大家点赞&#xff0c;收藏&#xff0c;评论&#x1f973;&#x1f973;&#x1f389;&#x1f389;&#x1f389; 文章目…

新数据结构(9)——Java异常体系

异常的种类 程序本身通常无法主动捕获并处理错误&#xff08;Error&#xff09;&#xff0c;因为这些错误通常表示系统级的严重问题&#xff0c;但程序可以捕获并处理异常&#xff08;Excrption&#xff09;&#xff0c;而Error则被视为一种程序无法或不应尝试恢复的异常类型。…

NixHomepage - 简单的个人网站

&#x1f4bb; NixHomepage - 简单的个人网站 推荐下个人的开源项目&#xff0c;演示网站&#xff0c;项目链接 https://github.com/nixgnauhcuy/NixHomepage&#xff0c;喜欢的话可以为我的项目点个 Star~ &#x1f4f7; 预览 ⚙️ 功能特性 多平台适配 明亮/暗黑模式切换 W…

HCIA项目实践---OSPF的知识和原理总结

9.5 OSPF 9.5.1 从哪些角度评判一个动态路由协议的好坏&#xff1f; &#xff08;1&#xff09;选路佳&#xff08;是否会出环&#xff09; OSPF 协议采用链路状态算法&#xff0c;通过收集网络拓扑信息来计算最短路径&#xff0c;从根本上避免了路由环路的产生。 &#xff08…

Calico网络组件本地部署支持IPv6(Kubernetes)

知其然 问题背景 因项目现场的网络正逐步从IPv4向IPv6迁移&#xff0c;这几年现场服务器基本上都配置了双栈&#xff1b;但随着IPv6铺开&#xff0c;出现了很多纯IPv6的服务器&#xff0c;并且要求通信优先使用IPv6。 在项目建设之初&#xff0c;其实就考虑了上述情况&#…

【广州大学主办,发表有保障 | IEEE出版,稳定EI检索,往届见刊后快至1个月检索】第二届电气技术与自动化工程国际学术会议 (ETAE 2025)

第二届电气技术与自动化工程国际学术会议 (ETAE 2025) The 2nd International Conference on Electrical Technology and Automation Engineering 大会官网&#xff1a;http://www.icetae.com/【更多详情】 会议时间&#xff1a;2025年4月25-27日 会议地点&#xff1a…

Python项目31:待办事项列表应用1.0(命令行界面+Json+类+初学者必做)

------------★Python练手项目源码★------------ Python项目27&#xff1a;用Tkinter写日志管理系统&#xff08;中下等难度&#xff09; Python项目26&#xff1a;设计学生成绩管理系统&#xff08;简易版&#xff09; Python项目25&#xff1a;带滚动效果的商场抽奖系统&…

Redis 01 02章——入门概述与安装配置

一、入门概述 &#xff08;1&#xff09;是什么 Redis&#xff1a;REmote Dictionary Server&#xff08;远程字典服务器&#xff09;官网解释&#xff1a;Remote Dictionary Server(远程字典服务)是完全开源的&#xff0c;使用ANSIC语言编写遵守BSD协议&#xff0c;是一个高…

Large Language Model Distilling Medication Recommendation Model

摘要&#xff1a;药物推荐是智能医疗系统的一个重要方面&#xff0c;因为它涉及根据患者的特定健康需求开具最合适的药物。不幸的是&#xff0c;目前使用的许多复杂模型往往忽视医疗数据的细微语义&#xff0c;而仅仅严重依赖于标识信息。此外&#xff0c;这些模型在处理首次就…

2025最新版Node.js下载安装~保姆级教程

1. node中文官网地址&#xff1a;http://nodejs.cn/download/ 2.打开node官网下载压缩包&#xff1a; 根据操作系统不同选择不同版本&#xff08;win7系统建议安装v12.x&#xff09; 我这里选择最新版win 64位 3.安装node ①点击对话框中的“Next”&#xff0c;勾选同意后点…

springboot如何将lib和jar分离

遇到一个问题&#xff0c;就是每次maven package或者maven install后target中的jar很大&#xff0c;少的50几MB&#xff0c;大的100多兆 优化前&#xff1a; 优化后&#xff1a; 优化前 优化后压缩率77.2MB4.65MB93% 具体方案&#xff1a; pom.xml中 <build><…

RocketMQ和Kafka如何实现顺序写入和顺序消费?

0 前言 先说明kafka&#xff0c;顺序写入和消费是Kafka的重要特性&#xff0c;但需要正确的配置和使用方式才能保证。本文需要解释清楚Kafka如何通过分区来实现顺序性&#xff0c;以及生产者和消费者应该如何配合。   首先&#xff0c;顺序写入。Kafka的消息是按分区追加写入…

Node.js技术原理分析系列——Node.js调试能力分析

本文由体验技术团队屈金雄原创。 Node.js 是一个开源的、跨平台的 JavaScript 运行时环境&#xff0c;它允许开发者在服务器端运行 JavaScript 代码。Node.js 是基于 Chrome V8引擎构建的&#xff0c;专为高性能、高并发的网络应用而设计&#xff0c;广泛应用于构建服务器端应…

从技术债务到架构升级,滴滴国际化外卖的变革

背 景 商家营销简述 在外卖平台的运营中&#xff0c;我们致力于通过灵活的补贴策略激励商家&#xff0c;与商家共同打造良好的合作关系&#xff0c;也会提供多样化的营销活动&#xff0c;帮助商家吸引更多用户下单。通过这些活动&#xff0c;不仅能够提高商家的销量&#xff0c…

SQL Query美化

推荐一个可以美化Query的网站&#xff01; 名称&#xff1a;SQL formatter | Online free SQL Beautifier 地址&#xff1a;https://sqlformatter.org/# 在处理 SQL 查询语句时&#xff0c;可读性是至关重要的。 杂乱无章的 SQL代码不仅难以理解&#xff0c;还会给后续的维…