首页 星云 工具 资源 星选 资讯 热门工具
:

PDF转图片 完全免费 小红书视频下载 无水印 抖音视频下载 无水印 数字星空

Spring事务传播机制(最全示例)

编程知识
2024年09月24日 13:26

我们在使用Spring框架进行开发时,经常在service层写很多方法,而且这些方法都是带事务的,那么Spring的事务怎么在多个方法之间传播呢?今天我们就仔细聊一聊。

Spring的事务传播机制主要解决在多个方法之间,事务如何传递的问题,通常有7种传播类型:

  • REQUIRED
  • SUPPORTS
  • MANDATORY
  • REQUIRES_NEW
  • NOT_SUPPORTED
  • NEVER
  • NESTED

下面我们就一一演示这7种类型是如何工作的。

基础代码

在讲解7种传播类型之前,我们先看看基础代码,代码很简单,大家先熟悉一下:

public void outerTransaction() {
    //向表中插入文本“outerTransaction”
    TransactionPropagation tp = new TransactionPropagation();
    tp.setMethodName("outerTransaction");
    transactionPropagationMapper.insert(tp);

    //调用innerTransaction方法
    TransactionPropagationService currentProxy = (TransactionPropagationService)AopContext.currentProxy();
    currentProxy.innerTransaction();

    //抛出异常
    int i = 1 / 0 ;
}


public void innerTransaction() {
    //向表中插入文本“innerTransaction”
    TransactionPropagation tp = new TransactionPropagation();
    tp.setMethodName("innerTransaction");
    transactionPropagationMapper.insert(tp);

    //抛出异常
    int i = 1 / 0 ;
}

方法outerTransaction()向表中插入文本"outerTransaction",然后调用innerTransaction()方法,最后通过计算1 / 0抛出异常。

方法innerTransaction()向表中插入文本"innerTransaction",通过计算1 / 0抛出异常。

这里我们在调用innerTransaction()方法时,先获取当前的AOP代理,再通过代理调用。这是因为两个方法在同一个类中,如果不通过代理,直接调用,会脱离Spring事务AOP的管理,导致事务失效。

我们在这两个方法上使用注解,并配置不同的传播机制,通过查看数据库是否插入数据成功来演示不同传播机制的效果。

REQUIRED

REQUIRED是Spring默认的传播机制,__含义:__如果当前存在事务,则加入该事务,如果不存在事务,则创建一个事务。下面我们分别演示一下:

  1. 如果不存在事务,则创建一个事务。具体代码如下:
public void outerTransaction() {
    //向表中插入文本“outerTransaction”
    TransactionPropagation tp = new TransactionPropagation();
    tp.setMethodName("outerTransaction");
    transactionPropagationMapper.insert(tp);

    //调用innerTransaction方法
    TransactionPropagationService currentProxy = (TransactionPropagationService)AopContext.currentProxy();
    currentProxy.innerTransaction();
}


@Transactional(propagation = Propagation.REQUIRED)
public void innerTransaction() {
    //向表中插入文本“innerTransaction”
    TransactionPropagation tp = new TransactionPropagation();
    tp.setMethodName("innerTransaction");
    transactionPropagationMapper.insert(tp);

    //抛出异常
    int i = 1 / 0 ;
}

outerTransaction()方法没有事务注解,虽然调用innerTransaction()方法时有异常抛出,插入数据也应该成功。innerTransaction()方法有事务注解,传播方式为:REQUIRED,由于outerTransaction()没有事务,所以会新创建一个事务,后面有异常抛出,所以数据不会插入成功,我们测试一下,看看结果如何?

和我们的预期是一致的,innerTransaction()创建了新的事务,由于抛出异常,所以数据没有插入成功。

  1. 如果当前存在事务,则加入该事务,代码如下:
@Transactional(propagation = Propagation.REQUIRED)
public void outerTransaction() {
    //向表中插入文本“outerTransaction”
    TransactionPropagation tp = new TransactionPropagation();
    tp.setMethodName("outerTransaction");
    transactionPropagationMapper.insert(tp);

    //调用innerTransaction方法
    TransactionPropagationService currentProxy = (TransactionPropagationService)AopContext.currentProxy();
    currentProxy.innerTransaction();
    
    //抛出异常
    int i = 1 / 0 ;
}


@Transactional(propagation = Propagation.REQUIRED)
public void innerTransaction() {
    //向表中插入文本“innerTransaction”
    TransactionPropagation tp = new TransactionPropagation();
    tp.setMethodName("innerTransaction");
    transactionPropagationMapper.insert(tp);
}

outerTransaction()增加了事务注解,传播类型为REQUIRED,由于之前没有事务,所以新创建了一个事务,然后调用innerTransaction(),innerTransaction()的传播类型也为REQUIRED,由于前面有事务,所以加入事务,最后outerTransaction()抛出异常,由于两个方法在同一个事务中,所以两个数据都不会插入成功。我们测试一下,

和我们的预期是一致的,innerTransaction()加入了outerTransaction()的事务,抛出异常后,两条数据都不会插入成功。

SUPPORTS

如果当前存在事务,则加入该事务,如果不存在事务,则以非事务的方式执行。同样我们分别演示一下。

  1. 如果当前存在事务,则加入该事务,代码如下:
@Transactional(propagation = Propagation.REQUIRED)
public void outerTransaction() {
    //向表中插入文本“outerTransaction”
    TransactionPropagation tp = new TransactionPropagation();
    tp.setMethodName("outerTransaction");
    transactionPropagationMapper.insert(tp);

    //调用innerTransaction方法
    TransactionPropagationService currentProxy = (TransactionPropagationService)AopContext.currentProxy();
    currentProxy.innerTransaction();

    //抛出异常
    int i = 1 / 0 ;
}


@Transactional(propagation = Propagation.SUPPORTS)
public void innerTransaction() {
    //向表中插入文本“innerTransaction”
    TransactionPropagation tp = new TransactionPropagation();
    tp.setMethodName("innerTransaction");
    transactionPropagationMapper.insert(tp);

}

outerTransaction()是有事务的,innerTransaction()的传播类型为:SUPPORTS,则会加入到事务中,由于两个方法在同一个事务中,抛出异常后,两条数据都不会插入成功,我们测试一下,

和预期一致,没有问题。

  1. 如果不存在事务,则以非事务的方式执行,具体代码如下:
public void outerTransaction() {
    //向表中插入文本“outerTransaction”
    TransactionPropagation tp = new TransactionPropagation();
    tp.setMethodName("outerTransaction");
    transactionPropagationMapper.insert(tp);

    //调用innerTransaction方法
    TransactionPropagationService currentProxy = (TransactionPropagationService)AopContext.currentProxy();
    currentProxy.innerTransaction();
}


@Transactional(propagation = Propagation.SUPPORTS)
public void innerTransaction() {
    //向表中插入文本“innerTransaction”
    TransactionPropagation tp = new TransactionPropagation();
    tp.setMethodName("innerTransaction");
    transactionPropagationMapper.insert(tp);
    
    //抛出异常
    int i = 1 / 0 ;
}

我们将outerTransaction()方法的事务注解去掉,抛出异常的位置挪到innerTransaction()中,由于innerTransaction()的传播类型是SUPPORTS,外层是没有事务的,所以innerTransaction()也是没有事务的,虽然抛出了异常,但是不会回滚,两条数据都应该插入成功,我们测试一下,

和预期一致,没有问题。

MANDATORY

如果当前存在事务,则加入到事务当中;如果当前没有事务,则抛出异常。我们分别演示一下,

  1. 如果当前存在事务,则加入到事务当中,代码如下:
@Transactional(propagation = Propagation.REQUIRED)
public void outerTransaction() {
    //向表中插入文本“outerTransaction”
    TransactionPropagation tp = new TransactionPropagation();
    tp.setMethodName("outerTransaction");
    transactionPropagationMapper.insert(tp);

    //调用innerTransaction方法
    TransactionPropagationService currentProxy = (TransactionPropagationService)AopContext.currentProxy();
    currentProxy.innerTransaction();

    //抛出异常
    int i = 1 / 0 ;
}


@Transactional(propagation = Propagation.MANDATORY)
public void innerTransaction() {
    //向表中插入文本“innerTransaction”
    TransactionPropagation tp = new TransactionPropagation();
    tp.setMethodName("innerTransaction");
    transactionPropagationMapper.insert(tp);
}

outerTransaction()方法是有事务的,innerTransaction()方法的传播类型是MANDATORY,会加入到事务中,由于outerTransaction()方法抛出了异常,所以两条数据都不会成功,我们测试一下,

和预期一致,都没有成功。

  1. 如果当前没有事务,则抛出异常,代码如下:
public void outerTransaction() {
    //向表中插入文本“outerTransaction”
    TransactionPropagation tp = new TransactionPropagation();
    tp.setMethodName("outerTransaction");
    transactionPropagationMapper.insert(tp);

    //调用innerTransaction方法
    TransactionPropagationService currentProxy = (TransactionPropagationService)AopContext.currentProxy();
    currentProxy.innerTransaction();

    //抛出异常
    int i = 1 / 0 ;
}


@Transactional(propagation = Propagation.MANDATORY)
public void innerTransaction() {
    //向表中插入文本“innerTransaction”
    TransactionPropagation tp = new TransactionPropagation();
    tp.setMethodName("innerTransaction");
    transactionPropagationMapper.insert(tp);
}

我们只是去掉了outerTransaction()上的事务注解,我们看一下会不会抛出异常,测试一下,

org.springframework.transaction.IllegalTransactionStateException: No existing transaction found for transaction marked with propagation 'mandatory'

确实是抛出了异常,我们再查看一下数据库的数据,

outerTransaction()方法的数据插入成功了,因为outerTransaction()方法没有事务,虽然后面的方法抛出了异常,但数据还是会插入成功。

REQUIRES_NEW

总是创建一个新的事务,如果当前存在事务,则挂起当前事务。这句话怎么理解呢?我们看看下面的代码,

@Transactional(propagation = Propagation.REQUIRED)
public void outerTransaction() {
    //向表中插入文本“outerTransaction”
    TransactionPropagation tp = new TransactionPropagation();
    tp.setMethodName("outerTransaction");
    transactionPropagationMapper.insert(tp);

    //调用innerTransaction方法
    TransactionPropagationService currentProxy = (TransactionPropagationService)AopContext.currentProxy();
    currentProxy.innerTransaction();

    //抛出异常
    int i = 1 / 0 ;
}

@Transactional(propagation = Propagation.REQUIRES_NEW)
public void innerTransaction() {
    //向表中插入文本“innerTransaction”
    TransactionPropagation tp = new TransactionPropagation();
    tp.setMethodName("innerTransaction");
    transactionPropagationMapper.insert(tp);
}

outerTransaction()是有事务的,innerTransaction()方法的传播类型是REQUIRES_NEW,会创建一个新的事务,虽然outerTransaction()最后抛出了异常,由于两个方法是两个事务,所以异常只会对外层事务回滚,我们测试一下,

innerTransaction()插入数据成功,outerTransaction()方法由于有异常,所以进行了回滚。如果将异常从外层挪到内层,也就是外层不抛出异常,而内层抛出异常,执行结果会是什么样子呢?小伙伴们自己思考一下吧。

NOT_SUPPORTED

以非事务的方式执行操作,如果当前存在事务,则挂起当前事务。这种传播类型说明方法都是非事务的,不管外层有没有事务,我们先看看代码,

@Transactional(propagation = Propagation.REQUIRED)
public void outerTransaction() {
    //向表中插入文本“outerTransaction”
    TransactionPropagation tp = new TransactionPropagation();
    tp.setMethodName("outerTransaction");
    transactionPropagationMapper.insert(tp);

    //调用innerTransaction方法
    TransactionPropagationService currentProxy = (TransactionPropagationService)AopContext.currentProxy();
    currentProxy.innerTransaction();
}

@Transactional(propagation = Propagation.NOT_SUPPORTED)
public void innerTransaction() {
    //向表中插入文本“innerTransaction”
    TransactionPropagation tp = new TransactionPropagation();
    tp.setMethodName("innerTransaction");
    transactionPropagationMapper.insert(tp);
    
    //抛出异常
    int i = 1 / 0 ;
}

outerTransaction()是有事务的,innerTransaction()的传播类型是NOT_SUPPORTED,说明innerTransaction()以非事务执行,数据插入后,抛出异常,由于外层是有事务的,所以外层事务回滚,我们测试一下,

和预期是一致的,内层以非事务执行,插入数据成功,外层有事务,而且有异常,所以事务回滚。

NEVER

以非事务的方式执行操作,如果当前存在事务,则抛出异常。我们具体看一下代码,

@Transactional(propagation = Propagation.REQUIRED)
public void outerTransaction() {
    //向表中插入文本“outerTransaction”
    TransactionPropagation tp = new TransactionPropagation();
    tp.setMethodName("outerTransaction");
    transactionPropagationMapper.insert(tp);

    //调用innerTransaction方法
    TransactionPropagationService currentProxy = (TransactionPropagationService)AopContext.currentProxy();
    currentProxy.innerTransaction();
}

@Transactional(propagation = Propagation.NEVER)
public void innerTransaction() {
    //向表中插入文本“innerTransaction”
    TransactionPropagation tp = new TransactionPropagation();
    tp.setMethodName("innerTransaction");
    transactionPropagationMapper.insert(tp);

    //抛出异常
    int i = 1 / 0 ;
}

outerTransaction()有事务,innerTransaction() 的传播类型是NEVER,由于外层方法有事务,所以要抛异常,外层方法也要回滚,所以两条数据都不会插入成功,我们测试一下,

抛出的异常是:

org.springframework.transaction.IllegalTransactionStateException: Existing transaction found for transaction marked with propagation 'never'

再看看数据库中的数据,

和预期是一致的。

NESTED

如果当前存在事务,则在当前事务中创建一个新的嵌套事务;如果当前没有事务,则创建一个新的任务。我们分别看一下是什么意思。

  1. 如果当前没有事务,则创建一个新的任务。这个感觉和REQUIRED是一样的,我们先看看代码,
public void outerTransaction() {
    //向表中插入文本“outerTransaction”
    TransactionPropagation tp = new TransactionPropagation();
    tp.setMethodName("outerTransaction");
    transactionPropagationMapper.insert(tp);

    //调用innerTransaction方法
    TransactionPropagationService currentProxy = (TransactionPropagationService)AopContext.currentProxy();
    currentProxy.innerTransaction();
}

@Transactional(propagation = Propagation.NESTED)
public void innerTransaction() {
    //向表中插入文本“innerTransaction”
    TransactionPropagation tp = new TransactionPropagation();
    tp.setMethodName("innerTransaction");
    transactionPropagationMapper.insert(tp);

    //抛出异常
    int i = 1 / 0 ;
}

outerTransaction()没有事务,innerTransaction()的传播类型是NESTED,会创建一个新的事务,由于抛出了异常所以内层会回滚,外层没有事务,会插入数据成功,我们测试一下,

和预期一致。

  1. 如果当前存在事务,则在当前事务中创建一个新的嵌套事务。我们再看看代码,
@Transactional(propagation = Propagation.REQUIRED)
public void outerTransaction() {
    //向表中插入文本“outerTransaction”
    TransactionPropagation tp = new TransactionPropagation();
    tp.setMethodName("outerTransaction");
    transactionPropagationMapper.insert(tp);

    //调用innerTransaction方法
    TransactionPropagationService currentProxy = (TransactionPropagationService)AopContext.currentProxy();
    try {
        currentProxy.innerTransaction1();
        currentProxy.innerTransaction2();
    } catch (Exception e) {
        e.printStackTrace();
    }
}

@Transactional(propagation = Propagation.NESTED)
public void innerTransaction1() {
    //向表中插入文本“innerTransaction”
    TransactionPropagation tp = new TransactionPropagation();
    tp.setMethodName("innerTransaction1");
    transactionPropagationMapper.insert(tp);
}

@Transactional(propagation = Propagation.NESTED)
public void innerTransaction2() {
    //向表中插入文本“innerTransaction”
    TransactionPropagation tp = new TransactionPropagation();
    tp.setMethodName("innerTransaction2");
    transactionPropagationMapper.insert(tp);

    //抛出异常
    int i = 1 / 0 ;
}

outerTransaction()有事务,分别调用innerTransaction1()和innerTransaction2() ,并catch异常,innerTransaction1()和innerTransaction2()的传播机制都是NESTED,会分别创建一个内嵌事务,innerTransaction1()正常结束,没有异常,innerTransaction2()抛出异常事务回滚,而外层由于catch了异常,方法也可以正常结束,所以不会回滚。我们预测的是:outerTransaction()插入成功,innerTransaction1()插入成功,innerTransaction2()回滚。我们测试一下,

和我们的预测是一致的。

总结

到此,Spring的7种传播机制就介绍完了。这里边的内容很多,是不好记忆的,其实我们也不必死记硬背,看看源码中的注释就可以了。如果再不行,就翻翻我的博客多看看吧~~

From:https://www.cnblogs.com/boboooo/p/18429072
本文地址: http://www.shuzixingkong.net/article/2267
0评论
提交 加载更多评论
其他文章 CodeMaid:一款基于.NET开发的Visual Studio代码简化和整理实用插件
前言 今天大姚给大家分享一款由.NET开源、免费、强大的Visual Studio代码简化、整理、格式化实用插件:CodeMaid。 工具介绍 CodeMaid是一款由.NET开源、免费、强大的Visual Studio实用插件,旨在帮助开发者简化、清理和格式化他们的C#、C++、VB.NET、F#
CodeMaid:一款基于.NET开发的Visual Studio代码简化和整理实用插件 CodeMaid:一款基于.NET开发的Visual Studio代码简化和整理实用插件 CodeMaid:一款基于.NET开发的Visual Studio代码简化和整理实用插件
基于SqlAlchemy+Pydantic+FastApi的Python开发框架
随着大环境的跨平台需求越来越多,对与开发环境和实际运行环境都有跨平台的需求,Python开发和部署上都是跨平台的,本篇随笔介绍基于SqlAlchemy+Pydantic+FastApi的Python开发框架的技术细节,以及一些技术总结。
基于SqlAlchemy+Pydantic+FastApi的Python开发框架 基于SqlAlchemy+Pydantic+FastApi的Python开发框架 基于SqlAlchemy+Pydantic+FastApi的Python开发框架
Hugging Face 论文平台 Daily Papers 功能全解析
文/ Adeena, 在快速发展的研究领域,保持对最新进展的关注至关重要。为了帮助开发者和研究人员跟踪 AI 领域的前沿动态,Hugging Face 推出了 Daily Papers 页面。自发布以来,Daily Papers 已展示了由 AK 和社区研究人员精心挑选的高质量研究。在过去一年里,已
Hugging Face 论文平台 Daily Papers 功能全解析 Hugging Face 论文平台 Daily Papers 功能全解析 Hugging Face 论文平台 Daily Papers 功能全解析
flink 大批量任务提交 yarn 失败问题
问题现象 用户迁移到新集群后,反馈他们开发平台大量 flink 任务提交失败了,当时集群的 yarn 资源是足够的 排查过程 用户是在他们的开发平台上提交的,查看他们失败的任务,发现是他们提交端主动 Kill 的,接着沟通发现他们提交平台有个逻辑就是提交到 yarn 的 flink 任务,如果在 2
flink 大批量任务提交  yarn 失败问题 flink 大批量任务提交  yarn 失败问题
使用 Nuxt Kit 的构建器 API 来扩展配置
title: 使用 Nuxt Kit 的构建器 API 来扩展配置 date: 2024/9/24 updated: 2024/9/24 author: cmdragon excerpt: 摘要:本文详细介绍了如何使用 Nuxt Kit 的构建器 API 来扩展和定制 Nuxt 3 项目的 webp
使用 Nuxt Kit 的构建器 API 来扩展配置 使用 Nuxt Kit 的构建器 API 来扩展配置
在Linux 中使用 pidstat 命令监控进程性能
一、安装 pidstat 命令 检查系统是否已经安装了 pidstat 打开终端,输入以下命令检查是否已经安装了 pidstat: pidstat -V 如果显示版本信息,说明已经安装,可以跳过安装步骤。如果提示找不到命令,那么继续下一步安装。 更新包管理器 在安装 pidstat 前,建议先更新系
技术解读:华为云如何携手昇腾、鸿蒙等根生态,助力开发者技术创新
分享在华为云上通过生态协同,基于昇腾云服务、HarmoyOS、盘古大模型等产品实现技术创新、商业成功的故事,了解根生态各技术趋势及最新前沿科技。
技术解读:华为云如何携手昇腾、鸿蒙等根生态,助力开发者技术创新 技术解读:华为云如何携手昇腾、鸿蒙等根生态,助力开发者技术创新 技术解读:华为云如何携手昇腾、鸿蒙等根生态,助力开发者技术创新
Vscode 远程切换Python虚拟环境
本文简要介绍了Vscode 远程切换Python 虚拟环境的详细步骤和配置方法,同时详细介绍了如何在VSCode中创建虚拟环境的方法。