如何使用Spring boot的@Transactional进行事务管理

2025-02-12 05:50
文章标签 java 进行 使用 spring 事务管理 boot transactional

本文主要是介绍如何使用Spring boot的@Transactional进行事务管理，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

《如何使用Springboot的@Transactional进行事务管理》这篇文章介绍了SpringBoot中使用@Transactional注解进行声明式事务管理的详细信息,包括基本用法、核心配置...

在 Spring Boot 中，@Transactional 是用于声明式事务管理的关键注解。它基于 Spring 的 AOP（面向切面编程）实现，可以简化数据库事务的管理。

一、前置条件

  • 依赖引入：确保项目中包含 spring-boot-starter-data-jpa 或 spring-boot-starter-jdbc
  • 启用事务管理：Spring Boot 默认自动配置事务管理器（如 DataSourceTransactionManager），无需手动启用。

二、基本用法

1. 在方法上添加注解

@Service
public class UserService {
    @Autowirwww.chinasem.cned
    private UserRepository userRepository;
    @Transactional
    public void createUser(User user) {
        userRepository.save(user);
        // 其他数据库操作
    }
}

2. 在类上添加注解

@Service
@Transactional
public class UserService {
    // 类中所有 public 方法都会应用事务
}

三、核心配置参数

1. 传播行为（Propagation）

控制事务的边界，默认为 Propagation.REQUIRED。

@Transactional(propagation = Propagation.REQUIRES_NEW)http://www.chinasem.cn
public void updateUser(User user) {
    // 始终开启新事务
}

常见选项：

  • REQUIRED（默认）：如果当前存在事务，则加入；否则新建
  • REQUIRES_NEW：始终新建事务，挂起当前事务（如有）
  • SUPPORTS：如果当前存在事务，则加入；否则非事务运行
  • NOT_SUPPORTED：非事务运行，挂起当前事务（如有）
  • MANDATORY：必须在事务中调用，否则抛出异常
  • NEVER：必须在非事务中调用，否则抛出异常

2. 隔离级别（Isolation）

控制事务的隔离性，默认为 Isolation.DEFAULT（使用数据库默认）。

@Transactional(isolation = Isolation.SERIALIZABLE)
public void sensitiveOperation() {
    // 最高隔离级别
}

3. 超时时间（Timeout）

事务超时时间（秒），默认-1（使用数据库默认）。

@Transactional(timeout = 30)
public void longRunningProcess() {
    // 超过30秒将回滚
}

4. 只读模式（readOnly）

优化只读操作，默认为 false。

@Transactional(readOnly = true)
public List<User> findAllUsers() {
    return userRepository.findAll();
}

5. 回滚规则（rollbackFor/noRollbackFor）

指定触发回滚的异常类型：

@Transactional(rollbackFor = CustomException.class)
public void process() throws CustomException {
    // 抛出 CustomException 时回滚
}

四、关键注意事项

1. 方法可见性

必须为 public：由于 Spring AOP 的实现机制，非 public 方法上的 @Transactional 无效

2. 自调用问题

同类中的方法互相调用时，事务不会生效（绕过代理对象）

// 错误示例
public void methodA() {
    methodB(); // 事务不生效
}
@Transactional
public void methodB() { ... }

3. 异常处理

  • 默认回滚条件：抛出 RuntimeException 或 Error
  • 检查型异常（Checked Exception）默认不会触发回滚
// 处理检查型异常
@Transactional(rollbackFor = IOException.class)
public void fileOperation() throws IOException {
    // ...
}

4. 多数据源事务

需配置多个事务管理器，并通过 @Transactional(value = "specificTransactionManager") 指定

五、调试技巧

启用调试日志：

logging.level.org.springframework.transaction.interceptor=TRACE
logging.level.org.springframework.jdbc.datasource.DataSourceTransactionManager=DEBUG

检查代理对象：

System.out.println(userService.getClass().getName());
// 输出应为代理类：com.sun.proxy.$ProxyXX 或 ...$$EnhancerBySpringCGLIB$$...

六、最佳实践

  • 服务层使用：在 ServiceChina编程 层而非 Controller 层使用事务
  • 保持短事务：避免在事务中包含远程调用、文件IO等耗时操作
  • 精确回滚规则：明确指定 rollbackFor 而非依赖默认行为
  • 结合 JPA 使用：
@Transactional
public void updateUserEmail(Long userId, String email) {
    User user = userRepository.findById(userId).orElseThrow();
    user.setEmail(email); // 自动脏检查，事务提交时更新
}

七、完整示例

@Service
public class OrderService {
    @Autowired
    private OrderRepository orderRepository;
    @Autowired
    private InventoryService inventoryService;
    @Transactional(
        propagation = Propagation.REQUIRED,
        isolation = Isolation.READ_COMMITTED,
        timeout = 30,
        rollbackFor = {InsufficientStockException.class, PaymentFailedException.class}
    )
    public void placeOrder(Order order) {
        inventoryService.reduceStock(order.getItems()); // 可能抛出 InsufficientStockException
        orderRepository.save(order);
        processPayment(order); // 可能抛出 PaymentFailedException
    }
    private void processPayment(Order order) {
        // 支付逻辑
    }
}

八、适用于关系型数据库

@Transactional 的使用与数据库层有直接关系，但它的事务管理机制是基于数据库事务的。如果 Service 层方法使用了 Elasticsearch 客户端读写 Elasticshttp://www.chinasem.cnearch，那么 @Transactional 的行为会受到影响。

1.@Transactional 的适用范围

  • @Transactional 是 Spring 提供的事务管理机制，主要用于管理数据库事务。
  • 它依赖于底层的事务管理器（如 DataSourceTransactionManager），而这些事务管理器通常是与关系型数据库（如 mysql、PostgreSQL）交互的。

数据库事务：@Transactional 可以确保数据库操作的原子性、一致性、隔离性和持久性（ACID）。非数据库操作：对于非数据库操作（如 Elasticsearch、Redis、文件系统等），@Transactional 无法直接管理其事务。

2.Elasticsearch 与 @Transactional 的关系

Elasticsearch 是一个分布式搜索引擎，它本身不支持传统意义上的事务（ACID）。因此，@Transactional 对 Elasticsearch 的操作没有直接的事务管理能力。

（1）场景分析

假设我们的 Service 方法同时操作了数据库和 Elasticsearch：

@Service
public class UserService {
    @Autowired
    private UserRepository userRepository; // 数据库操作
    @Autowired
    private ElasticsearchClient elasticsearchClient; // Elasticsearch 操作
    @Transactional
    public void createUser(User user) {
        // 操作数据库
        userRepository.save(user);
        // 操作 Elasticsearch
        IndexRequest request = new IndexRequest("users")
            .id(user.getId().toString())
            .source("name", user.getName(), "email", user.getEmail());
        elasticsearchClient.index(request, RequestOptions.DEFAULT);
    }
}

（2）可能出现的问题

  • 数据库事务回滚，Elasticsearch 操作不回滚：
  • 如果 userRepository.save(user) 成功，但后续 Elasticsearch 操作失败，数据库事务会回滚（因为 @Transactional 生效），但 Elasticsearch 的数据已经写入，无法回滚。
  • 数据库事务提交，Elasticsearch 操作失败：
  • 如果数据库操作成功，但 Elasticsearch 操作失败，数据库事务已经提交，而 Elasticsearch 数据未更新，导致数据不一致。

3.如何解决 Elasticsearch 与数据库的事务一致性问题

由于 Elasticsearch 不支持事务，因此需要采用其他机制来保证数据一致性。

（1）手动补偿机制 在 Elasticsearch 操作失败时，手动回滚数据库操作。

示例：

@Transactional
public void createUser(User user) {
    try {
        userRepository.save(user); // 数据库操作
        IndexRequest request = new IndexRequest("users")
            .id(user.getId().toString())
            .source("name", user.getName(), "email", user.getEmail());
        elasticsearchClient.index(request, RequestOptions.DEFAULT); // Elasticsearch 操作
    } catch (Exception e) {
        // Elasticsearch 操作失败，手动回滚数据库
        TransactionASPectSupport.currentTransactionStatus().setRollbackOnly();
        throw e;
    }
}

（2）消息队列（最终一致性）

  • 将 Elasticsearch 操作异步化，通过消息队列（如 Kafka、RabbitMQ）实现最终一致性。
  • 示例：

    数据库操作完成后，发送消息到队列。

    消费者从队列中读取消息并更新 Elasticsearch。

（3）两阶段提交（2PC）

  • 使用分布式事务管理器（如 Seata）实现数据库和 Elasticsearch 的分布式事务。
  • 这种方法复杂度较高，通常不推荐用于 Elasticsearch。

（4）本地消息表

  • 在数据库中创建一张消息表，记录需要同步到 Elasticsearch 的数据。
  • 通过定时任务或事件监听器将数据同步到 Elasticsearch。

总结

  • @Transactional 只对数据库事务有效：它无法管理 Elasticsearch 等非关系型数据存储的事务。
  • Elasticsearch 操作与数据库事务的一致性：需要通过补偿机制、消息队列等方式实现。
    • 设计建议： 尽量避免在同一个事务中混合数据库和 Elasticsearch 操作。
    • 采用异步化或最终一致性方案来保证数据一致性。

如果你有更多具体的业务场景，可以进一步讨论如何设计解决方案！

到此这篇关于使用Spring boot的@Transactional进行事务管理的文章就介绍到这了,更多相关Spring boot @Transactional事务管理内容请搜索China编程(www.chinasem.cn)以前的文章或继续浏览下面的相关文章希望大家以后多多支持China编程(www.chinasem.cnWNdzS)！

这篇关于如何使用Spring boot的@Transactional进行事务管理的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1153407。

相关文章

使用Python实现矢量路径的压缩、解压与可视化

使用Python实现矢量路径的压缩、解压与可视化

《使用Python实现矢量路径的压缩、解压与可视化》在图形设计和Web开发中,矢量路径数据的高效存储与传输至关重要,本文将通过一个Python示例,展示如何将复杂的矢量路径命令序列压缩为JSON格式,... 目录引言核心功能概述1. 路径命令解析2. 路径数据压缩3. 路径数据解压4. 可视化代码实现详解1
阅读更多...
Pandas透视表(Pivot Table)的具体使用

Pandas透视表(Pivot Table)的具体使用

《Pandas透视表(PivotTable)的具体使用》透视表用于在数据分析和处理过程中进行数据重塑和汇总,本文就来介绍一下Pandas透视表(PivotTable)的具体使用,感兴趣的可以了解一下... 目录前言什么是透视表？使用步骤1. 引入必要的库2. 读取数据3. 创建透视表4. 查看透视表总结前言
阅读更多...
Python 交互式可视化的利器Bokeh的使用

Python 交互式可视化的利器Bokeh的使用

《Python交互式可视化的利器Bokeh的使用》Bokeh是一个专注于Web端交互式数据可视化的Python库,本文主要介绍了Python交互式可视化的利器Bokeh的使用,具有一定的参考价值,感... 目录1. Bokeh 简介1.1 为什么选择 Bokeh1.2 安装与环境配置2. Bokeh 基础2
阅读更多...
SpringBoot UserAgentUtils获取用户浏览器的用法

SpringBoot UserAgentUtils获取用户浏览器的用法

《SpringBootUserAgentUtils获取用户浏览器的用法》UserAgentUtils是于处理用户代理（User-Agent）字符串的工具类,一般用于解析和处理浏览器、操作系统以及设备... 目录介绍效果图依赖封装客户端工具封装IP工具实体类获取设备信息入库介绍UserAgentUtils
阅读更多...
Android使用ImageView.ScaleType实现图片的缩放与裁剪功能

Android使用ImageView.ScaleType实现图片的缩放与裁剪功能

《Android使用ImageView.ScaleType实现图片的缩放与裁剪功能》ImageView是最常用的控件之一,它用于展示各种类型的图片,为了能够根据需求调整图片的显示效果,Android提... 目录什么是 ImageView.ScaleType？FIT_XYFIT_STARTFIT_CENTE
阅读更多...
Spring 中的循环引用问题解决方法

Spring 中的循环引用问题解决方法

《Spring中的循环引用问题解决方法》：本文主要介绍Spring中的循环引用问题解决方法,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考下吧... 目录什么是循环引用？循环依赖三级缓存解决循环依赖二级缓存三级缓存本章来聊聊Spring 中的循环引用问题该如何解决。这里聊
阅读更多...
Java学习手册之Filter和Listener使用方法

Java学习手册之Filter和Listener使用方法

《Java学习手册之Filter和Listener使用方法》：本文主要介绍Java学习手册之Filter和Listener使用方法的相关资料,Filter是一种拦截器,可以在请求到达Servl... 目录一、Filter（过滤器）1. Filter 的工作原理2. Filter 的配置与使用二、Listen
阅读更多...
Pandas使用AdaBoost进行分类的实现

Pandas使用AdaBoost进行分类的实现

《Pandas使用AdaBoost进行分类的实现》Pandas和AdaBoost分类算法,可以高效地进行数据预处理和分类任务,本文主要介绍了Pandas使用AdaBoost进行分类的实现,具有一定的参... 目录什么是 AdaBoost？使用 AdaBoost 的步骤安装必要的库步骤一：数据准备步骤二：模型
阅读更多...
Spring Boot中JSON数值溢出问题从报错到优雅解决办法

Spring Boot中JSON数值溢出问题从报错到优雅解决办法

《SpringBoot中JSON数值溢出问题从报错到优雅解决办法》：本文主要介绍SpringBoot中JSON数值溢出问题从报错到优雅的解决办法,通过修改字段类型为Long、添加全局异常处理和... 目录一、问题背景：为什么我的接口突然报错了？二、为什么会发生这个错误？1. Java 数据类型的“容量”限制
阅读更多...
使用Pandas进行均值填充的实现

使用Pandas进行均值填充的实现

《使用Pandas进行均值填充的实现》缺失数据（NaN值）是一个常见的问题,我们可以通过多种方法来处理缺失数据,其中一种常用的方法是均值填充,本文主要介绍了使用Pandas进行均值填充的实现,感兴趣的... 目录什么是均值填充？为什么选择均值填充？均值填充的步骤实际代码示例总结在数据分析和处理过程中，缺失数
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2