Spring Boot 嵌套事务详解及失效解决方案

在复杂的业务场景中,嵌套事务可以帮助我们更加精细地控制数据的一致性。然而,在 Spring Boot 中,如果嵌套事务的配置不当,可能会导致事务不生效的问题,尤其是在同一个类中进行方法调用时。

本文将详细介绍嵌套事务的原理、失效的原因以及解决方案,帮助你轻松应对这一问题。


什么是嵌套事务?

嵌套事务是一种事务传播行为,允许在一个事务中嵌套另一个事务。Spring 提供了 PROPAGATION_NESTED 事务传播属性,用于实现嵌套事务。嵌套事务的特点是:

  • 依赖外层事务:嵌套事务的提交取决于外层事务。
  • 可以独立回滚:嵌套事务失败时,可以部分回滚,而不影响外层事务。

嵌套事务失效的原因

Spring 的事务管理基于 AOP 动态代理。当事务方法被直接调用(例如通过 this.method())时,不经过 Spring 的代理,事务功能会失效。

核心问题

  • 内部方法调用不会触发 Spring 的代理逻辑。
  • 因此,事务注解如 @Transactional 无法生效。

示例代码如下:

@Service
public class ExampleService {
    @Autowired
    private DemoRepository demoRepository;

    @Transactional
    public void outerMethod() {
        saveOuter();
        this.innerMethod(); // 内部调用,事务不会生效
    }

    private void saveOuter() {
        DemoEntity entity = new DemoEntity();
        entity.setName("Outer");
        demoRepository.save(entity);
    }

    @Transactional(propagation = Propagation.NESTED)
    public void innerMethod() {
        DemoEntity entity = new DemoEntity();
        entity.setName("Inner");
        demoRepository.save(entity);

        // 模拟异常
        throw new RuntimeException("Inner transaction failed");
    }
}

在上面的代码中,outerMethod 调用了 innerMethod,但由于是通过 this 引用调用的,事务注解 @Transactional 不会生效。


嵌套事务的解决方案

为了解决嵌套事务失效的问题,我们可以通过以下方法确保方法调用走 Spring 的代理机制。


方案一:将嵌套事务方法提取到独立类

innerMethod 方法提取到一个新服务类中,确保通过 Spring 容器管理的代理类调用。

示例代码

  1. 新建一个服务类处理嵌套事务:

    @Service
    public class InnerService {
        @Autowired
        private DemoRepository demoRepository;
    
        @Transactional(propagation = Propagation.NESTED)
        public void innerMethod() {
            DemoEntity entity = new DemoEntity();
            entity.setName("Inner");
            demoRepository.save(entity);
    
            // 模拟异常
            throw new RuntimeException("Inner transaction failed");
        }
    }
    
  2. 修改外层服务类:

    @Service
    public class ExampleService {
        @Autowired
        private InnerService innerService;
    
        @Autowired
        private DemoRepository demoRepository;
    
        @Transactional
        public void outerMethod() {
            saveOuter();
            innerService.innerMethod(); // 通过代理调用,事务生效
        }
    
        private void saveOuter() {
            DemoEntity entity = new DemoEntity();
            entity.setName("Outer");
            demoRepository.save(entity);
        }
    }
    

这种方式最为常见,能够有效解决嵌套事务失效的问题。


方案二:使用 ApplicationContext 获取代理对象

通过 Spring 的 ApplicationContext 获取当前类的代理对象,确保事务方法调用通过代理进行。

示例代码

@Service
public class ExampleService {
    @Autowired
    private DemoRepository demoRepository;

    @Autowired
    private ApplicationContext applicationContext;

    @Transactional
    public void outerMethod() {
        saveOuter();

        // 获取自身代理
        ExampleService proxy = applicationContext.getBean(ExampleService.class);
        proxy.innerMethod(); // 通过代理调用,事务生效
    }

    private void saveOuter() {
        DemoEntity entity = new DemoEntity();
        entity.setName("Outer");
        demoRepository.save(entity);
    }

    @Transactional(propagation = Propagation.NESTED)
    public void innerMethod() {
        DemoEntity entity = new DemoEntity();
        entity.setName("Inner");
        demoRepository.save(entity);

        // 模拟异常
        throw new RuntimeException("Inner transaction failed");
    }
}

方案三:使用 AopContext 获取代理对象

Spring 提供了 AopContext.currentProxy() 方法,可以在同一个类中获取当前类的代理对象。

示例代码

@Service
public class ExampleService {
    @Autowired
    private DemoRepository demoRepository;

    @Transactional
    public void outerMethod() {
        saveOuter();

        // 获取代理对象
        ExampleService proxy = (ExampleService) AopContext.currentProxy();
        proxy.innerMethod(); // 通过代理调用,事务生效
    }

    private void saveOuter() {
        DemoEntity entity = new DemoEntity();
        entity.setName("Outer");
        demoRepository.save(entity);
    }

    @Transactional(propagation = Propagation.NESTED)
    public void innerMethod() {
        DemoEntity entity = new DemoEntity();
        entity.setName("Inner");
        demoRepository.save(entity);

        // 模拟异常
        throw new RuntimeException("Inner transaction failed");
    }
}

使用该方案需要在配置中开启 exposeProxy

@Configuration
@EnableTransactionManagement(proxyTargetClass = true)
public class TransactionConfig {
}

总结

嵌套事务在 Spring Boot 中失效的主要原因是方法调用未通过 Spring 的代理机制。我们可以通过以下方式解决:

  1. 将嵌套事务方法提取到独立类(推荐方式)。
  2. 使用 ApplicationContext 获取代理对象
  3. 使用 AopContext 获取代理对象

选择合适的解决方案可以确保嵌套事务在复杂业务场景中正常工作,避免数据一致性问题。希望本文对你有所帮助!

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

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

相关文章

ROS2+OpenCV综合应用--10. AprilTag标签码追踪

1. 简介 apriltag标签码追踪是在apriltag标签码识别的基础上,增加了小车摄像头云台运动的功能,摄像头会保持标签码在视觉中间而运动,根据这一特性,从而实现标签码追踪功能。 2. 启动 2.1 程序启动前的准备 本次apriltag标签码使…

mysql乱码、mysql数据中文问号

网上排出此错误方法的很多,但是 都不简洁,找不到根本原因 主要排查两点: 1.代码中jdbc链接的编码规则 urljdbc:mysql://localhost:3306/title?useUnicodetrue&characterEncodingutf8 将characterEncoding设置为utf8 2.设置mysq…

Presto-简单了解-230403

presto是什么了解一下: 秒级查询引擎(不做存储),GB-PB级不依赖于yarn,有自己的资源管理和执行计划支持多种数据源:hive、redis、kafka presto架构 presto优缺点 presto优点 内存到内存的传输&#xff0…

openGauss连接是报org.opengauss.util.PSQLException: 尝试连线已失败

安装好高斯数据库后然后用java连接时报如下错误: 解决方法: 在openGauss数据库的安装路径下/opt/opengauss/data/single_node(这个路径根据自己实际情况变化)有个pg_hba.conf文件,修改里面host内容如下,我这里设置的是所有ip都能…

mybatis-plus自动填充时间的配置类实现

mybatis-plus自动填充时间的配置类实现 在实际操作过程中,我们并不希望创建时间、修改时间这些来手动进行,而是希望通过自动化来完成,而mybatis-plus则也提供了自动填充功能来实现这一操作,接下来,就来了解一下mybatis…

【Java项目】基于SpringBoot的【人职匹配推荐系统】

【Java项目】基于SpringBoot的【人职匹配推荐系统】 技术简介:本系统使用采用B/S架构、Spring Boot框架、MYSQL数据库进行开发设计。 系统简介:人职匹配推荐系统分为管理员和用户、企业三个权限子模块。 管理员所能使用的功能主要有:首页、个…

Flutter 调试环境下浏览器网络请求跨域问题解决方案

本篇文章主要讲解,Flutter调试环境情况下,浏览器调试报错跨域问题的解决方法,通过本篇文章你可以快速掌握Flutter调试环境情况下的跨域问题。 日期:2024年12月28日 作者:任聪聪 报错现象: 报文信息&#xf…

【每日学点鸿蒙知识】导入cardEmulation、自定义装饰器、CallState状态码顺序、kv配置、签名文件配置

1、HarmonyOS 无法导入cardEmulation? 在工程entry mudule里的index.ets文件里导入cardEmulation失败 可以按照下面方式添加SystemCapability;在src/main/syscap.json(此文件需要手动创建)中添加如下内容 {"devices": {"gen…

ArcGIS JSAPI 高级教程 - 通过RenderNode实现视频融合效果(不借助三方工具)

ArcGIS JSAPI 高级教程 - 通过RenderNode实现视频融合效果(不借助三方工具) 核心代码完整代码在线示例 地球中展示视频可以通过替换纹理的方式实现,但是随着摄像头和无人机的流行,需要视频和场景深度融合,简单的实现方…

【大模型实战篇】LLaMA Factory微调ChatGLM-4-9B模型

1. 背景介绍 虽然现在大模型微调的文章很多,但纸上得来终觉浅,大模型微调的体感还是需要自己亲自上手实操过,才能有一些自己的感悟和直觉。这次我们选择使用llama_factory来微调chatglm-4-9B大模型。 之前微调我们是用两块3090GPU显卡&…

微信流量主挑战:三天25用户!功能未完善?(新纪元4)

🎉【小程序上线第三天!突破25用户大关!】🎉 嘿,大家好!今天是我们小程序上线的第三天,我们的用户量已经突破了25个!昨天还是16个,今天一觉醒来竟然有25个!这涨…

【工具变量】国际消费中心城市DID数据(2007年-2023年)

数据简介 国际消费中心城市的定位是一个国家乃至全球消费市场消费资源的集中地和关键枢纽,该城市特质不单顺应我国对外交流与开放的不断扩大的趋势,其培育和建设国际消费中心城市的一大意义在于,以地区地域资源中心定位,来推动周围…

如何修复 WordPress 中的“Error establishing a database connection”问题

如何修复 WordPress 中的“Error establishing a database connection”问题 在使用 WordPress 建站时,如果你看到“Error establishing a database connection”的提示,不要慌张。这通常意味着网站无法连接到数据库,因此无法显示内容。下面…

streamlit、shiny、gradio、fastapi四个web APP平台体验

streamlit、shiny、gradio、fastapi四个web APP平台体验 经常被问的问题就是:web APP平台哪个好?该用哪个?刚开始只有用streamlit和shiny,最近体验了一下gradio和fastapi,今天根据自己的体会尝试着回答一下。 使用R语…

http报头解析

http报文 http报文主要有两类是常见的,第一类是请求报文,第二类是响应报文,每个报头除了第一行,都是采用键值对进行传输数据,请求报文的第一行主要包括http方法(GET,PUT, POST&#…

Qwen-Agent

文章目录 一、关于 Qwen-Agent更新准备:模型服务免责声明 二、安装三、快速开发步骤 1:添加自定义工具步骤 2:配置 LLM步骤 3:创建智能体步骤 4:运行智能体 四、FAQ1、支持函数调用(也称为工具调用&#xf…

flux文生图模型实践

flux文生图模型实践 flyfish https://github.com/black-forest-labs/flux Black Forest Labs发布FLUX.1 Tools,这是一套模型全家桶,旨在为FLUX.1基础文本转图像模型添加控制和可操纵性,从而实现对真实图像和生成图像的修改和重新创建。FLU…

【ETCD】【实操篇(十九)】ETCD基准测试实战

目录 1. 设定性能基准要求2. 使用基准测试工具基准测试命令 3. 测试不同的负载和场景4. 监控集群性能5. 评估硬件和网络的影响6. 对比性能基准7. 负载均衡和容错能力测试8. 优化与调优9. 测试在高负载下的表现总结 1. 设定性能基准要求 首先,明确集群性能的目标&am…

Docker Compose 构建 EMQX 集群 实现mqqt 和websocket

EMQX 集群化管理mqqt真香 目录 #目录 /usr/emqx 容器构建 vim docker-compose.yml version: 3services:emqx1:image: emqx:5.8.3container_name: emqx1environment:- "EMQX_NODE_NAMEemqxnode1.emqx.io"- "EMQX_CLUSTER__DISCOVERY_STRATEGYstatic"- …

【Cesium】三、实现开场动画效果

文章目录 实现效果实现方法实现代码组件化 实现效果 实现方法 Cesium官方提供了Camera的flyTo方法实现了飞向目的地的动画效果。 官方API:传送门 这里只需要用到目的地(destination)和持续时间(duration)这两个参数…