Java声明式事务实战!工作中用这几种就够了!
文章目录
- 1.几种常用的事务传播行为
- 1.1 REQUIRED
- 1.2 REQUIRES_NEW
- 1.2 NESTED
- 2. 事务问题
- 2.1 事务不生效?
- 2.2 事务不回滚?
文章会分为两个部分来讲解,第一部分是声明式事务的几种使用场景。第二部分包含事务没有生效,没有回滚的情况。
1.几种常用的事务传播行为
在实际的应用开发中,有几种事务传播行为比较常用,主要包括以下几种:
-
REQUIRED (默认行为): 这是最常用的传播行为。如果当前没有事务,就新建一个事务;如果已经存在事务,就加入这个事务。适用于大多数需要事务管理的场景,如任何需要保持数据完整性和一致性的操作。
-
REQUIRES_NEW: 始终启动一个新的事务。如果一个事务已经存在,则先将这个存在的事务挂起。这个传播行为适用于需要完全独立于当前事务上下文执行的操作,例如日志记录,这些操作不应该被外部事务的影响而回滚。
-
NESTED: 如果当前存在事务,则在嵌套事务内执行。如果当前没有事务,则其行为与
REQUIRED一样。嵌套事务是一个子事务,它依赖于父事务。父事务失败时,子事务会被回滚。子事务失败,父事务可以决定是回滚还是继续执行。这适用于需要执行一系列操作,其中一些操作可能需要独立于其它操作回滚的场景。 -
SUPPORTS: 如果当前存在事务,则加入事务;如果当前没有事务,则以非事务方式执行。这适用于不需要事务管理的读操作,但如果操作在事务环境中被调用,则能够参与到事务中。
-
NOT_SUPPORTED: 总是非事务地执行,并且挂起任何存在的事务。适用于不应该在事务环境中运行的长时间运行的操作。
但我个人认为前三种很好用,后面两种则看情况了,我没讲到的我认为用处不大,可以忽略。
1.1 REQUIRED
默认的传播行为就是没有就新建,否则就加入当前事务,一般在在方法上加@Transactional即可,(因为很简单就不放代码了,后续会放上代码)但注意该方法要被public修饰,否则事务不会生效,这个后面会细讲。
1.2 REQUIRES_NEW
我认为这个注解对于方法执行中加日志记录很有用,因为不管方法成功或者失败,我们都想记录下是哪里出了问题,此时就可以用到这个注解,点示例如下。
@Service
public class OrderService {@Autowiredprivate LogService logService;@Transactionalpublic void processOrder(Order order) {try {// ... 订单处理逻辑 ...// 模拟可能出现的异常if (someCondition) {throw new RuntimeException("订单处理出现异常");}// ... 更多订单处理逻辑 ...} catch (Exception e) {// 记录日志(即使主事务失败,日志事务仍然可以提交)logService.recordLog(order, e.getMessage());throw e; // 重新抛出异常以确保主事务可以回滚}}
}@Service
public class LogService {@Autowiredprivate LogRepository logRepository;@Transactional(propagation = Propagation.REQUIRES_NEW)public void recordLog(Order order, String message) {LogEntry logEntry = new LogEntry();logEntry.setOrderId(order.getId());logEntry.setMessage(message);logEntry.setTimestamp(new Date());logRepository.save(logEntry); // 保存日志到数据库}
}
1.2 NESTED
这个注解提供了更完备的事务控制,试想这么一个场景,我的父方法需要被事务控制,子方法中出现了异常我也不回滚,但如果父方法中出现了异常,则全部事务回滚。
好好思考下这个场景,使用新建事务就做不到了,因为那已经是两个事务了,而嵌套事务则代表两个事务有关联,但子事务的优先级很低,以父方法中的代码为准,代码如下。
注意,我使用了noRollbackFor = InventoryException.class ,这将导致出现该异常,会往上抛,但是不回滚。
@Service
public class OrderService {@Autowiredprivate InventoryService inventoryService;@Transactional(rollbackFor=Exception.class)public void processOrder(Order order) {try {// ... 订单处理逻辑 ...// 调用扣减库存方法,该方法在自己的嵌套事务中执行inventoryService.deductInventory(order);// ... 更多订单处理逻辑 ...// 模拟可能出现的异常if (someCondition) {throw new RuntimeException("订单处理出现异常");}} catch (Exception e) {// 处理异常,父事务中的异常会导致整个事务(包括嵌套事务)回滚throw e;}}
}@Service
public class InventoryService {@Transactional(propagation = Propagation.NESTED, noRollbackFor = InventoryException.class)public void deductInventory(Order order) {// ... 库存扣减逻辑 ...// 如果出现特定条件,抛出自定义异常,这将只回滚当前嵌套事务if (someCondition) {throw new InventoryException("库存不足");}// ... 更多库存处理逻辑 ...}
}
2. 事务问题
2.1 事务不生效?
- public 方法:通常,只有标注在 public 方法上的 @Transactional 才会被
- Spring AOP代理捕获,因此才会生效。
外部调用:Spring AOP基于代理模式,只有通过代理对象的外部调用方法时,事务才会被触发。如果在同一类中使用this关键字调用另一个方法(即使它被@Transactional注解),事务是不会被触发的。
所以只要满足了这两个条件,事务就一定会生效了。
2.2 事务不回滚?
- 异常的传播:只有当异常从标注了
@Transactional的方法中抛出时,事务才会回滚。如果在方法内部通过try-catch块捕获了异常并处理了,那么事务不会自动回滚。 - 手动回滚:如果需要在catch块中回滚事务,可以通过调用
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly()手动标记事务回滚。 - 运行时异常和错误:默认情况下,Spring只会在出现运行时异常(RuntimeException)或错误(Error)时回滚事务。
所有异常回滚:如果需要让事务在检查型异常(即非运行时异常)抛出时也回滚,可以在@Transactional注解中设置rollbackFor = Exception.class。
以上就是我总结的事务内容,如果有什么错误,欢迎指正。
知识点是没有用的,体系是有用的,我们需要的是体系。
相关文章:
Java声明式事务实战!工作中用这几种就够了!
文章目录 1.几种常用的事务传播行为1.1 REQUIRED1.2 REQUIRES_NEW1.2 NESTED 2. 事务问题2.1 事务不生效?2.2 事务不回滚? 文章会分为两个部分来讲解,第一部分是声明式事务的几种使用场景。第二部分包含事务没有生效,没有回滚的情…...
Abp6.0 使用 appsettings.json配置Serilog.Sinks.MariaDB
Abp6.0中已经启用Serilog,使用Serilog.Sinks.MariaDB包可以保存到MariaDB,mysql中 一种做法是在var loggerConfiguration new LoggerConfiguration( )后使用WriteTo.MariaDB扩展方法来配置,这样在代码中配置不够灵活,修改起来也不方便 其实…...
关于Flume-Kafka-Flume的模式进行数据采集操作
测试是否连接成功: 在主节点flume目录下输入命令: bin/flume-ng agent -n a1 -c conf/ -f job/file_to_kafka.conf -Dflume.root.loggerinfo,console # 这个file_to_kafka.conf文件就是我们的配置文件 然后在另一台节点输入命令进行消费数据: kafka-cons…...
WeTab--颜值与实力并存的浏览器插件
一.前言 现在的浏览器花花绿绿,有大量的广告与信息,令人目不暇接。有没有一款好用的浏览器插件可以解决这个问题呢?我愿称WeTab为版本答案。 WeTab的界面: 干净又整洁。最最关键的是还有智能AI供你服务。 这个WeTabAI就像chatgp…...
【整理】HTTP相关版本对比
1. HTTP/1 超文本传输协议,处于计算机网络中的应用层,HTTP是建立在TCP协议之上,所以HTTP协议的瓶颈及其优化技巧都是基于TCP协议本身的特性。 缺陷: 连接无法复用 ---------- 每次请求经历三次握手和慢启动HOLB(队头…...
spark性能调优 | 默认并行度
Spark Sql默认并行度 看官网,默认并行度200 https://spark.apache.org/docs/2.4.5/sql-performance-tuning.html#other-configuration-options 优化 在数仓中 task最好是cpu的两倍或者3倍(最好是倍数,不要使基数) 拓展 在本地 task需要自己设置&a…...
Python-pptx教程之二操作已有PPT模板文件
文章目录 简单的案例找到要修改的元素修改幻灯片中的文本代码使用示例 修改幻灯片的图片代码使用示例 删除幻灯片代码使用示例 获取PPT中所有的文本内容获取PPT中所有的图片总结 在上一篇中我们已经学会了如何从零开始生成PPT文件,从零开始生成较为复杂的PPT是非常消…...
生活总是自己的,请尽情打扮,尽情可爱,,
同色系拼接羽绒服了解一下 穿上时尚感一下子就突显出来了 90白鸭绒填充,不仅时尚还保暖 设计感满满的羽绒服不考虑一下吗?...
栈和队列的初始化,插入,删除,销毁。
目录 题外话 顺序表和链表优缺点以及特点 一.栈的特点 二. 栈的操作 2.1初始化 2.2 栈的销毁 2.3 栈的插入 2.3 输出top 2.4 栈的删除 2.5 输出栈 题外话 顺序表和链表优缺点以及特点 特点:顺序表,逻辑地址物理地址。可以任意访问,…...
重温《Unix设计哲学》
重温Unix设计哲学 这个世界是复杂的,但往往本质的东西都是简单的。这些原则,不光是用在程序开发,也适用于架构设计,产品设计等等地方。 简洁原则:以简洁为美 不要为了满足自己的虚荣心,企图搞一些花哨的东…...
AIGC创作系统ChatGPT源码,AI绘画源码,支持最新GPT-4-Turbo模型,支持DALL-E3文生图
一、AI创作系统 SparkAi创作系统是基于OpenAI很火的ChatGPT进行开发的Ai智能问答系统和Midjourney绘画系统,支持OpenAI-GPT全模型国内AI全模型。本期针对源码系统整体测试下来非常完美,可以说SparkAi是目前国内一款的ChatGPT对接OpenAI软件系统。那么如…...
Spring条件注解@Conditoinal+ Profile环境切换应用@Profile
Spring条件注解 一、创建一个maven项目 <dependencies><dependency><groupId>org.springframework</groupId><artifactId>spring-context</artifactId><version>5.1.5.RELEASE</version></dependency> </dependenc…...
Scrum框架中的Sprint
上图就是sprint里要做的事。Sprint是scrum框架的核心,是所有的想法、主意转换为价值的地方。所有实现产品目标的必要工作都在sprint里完成,这些工作主要包括Sprint 计划(Sprint planning)、每日站会(Daily Scrum&#…...
openfeign、nacos获取接口提供方真实IP
源码分析 client 是 LoadBalancerFeignClient org.springframework.cloud.openfeign.ribbon.LoadBalancerFeignClient#execute public Response execute(Request request, Request.Options options) throws IOException {try {URI asUri URI.create(request.url());String c…...
Linux系统编程学习 NO.9——git、gdb
前言 本篇文章简单介绍了Linux操作系统中两个实用的开发工具git版本控制器和gdb调试器。 git 什么是git? git是一款开源的分布式版本控制软件。它不仅具有网络功能,还是服务端与客户端一体的软件。它可以高效的处理程序项目中的版本管理。它是Linux内…...
【联邦学习+区块链】TORR: A Lightweight Blockchain for Decentralized Federated Learning
文章目录 I.CONTRIBUTIONII. ASSUMPTIONS AND THREAT MODELA. AssumptionsB. Threat Model III. SYSTEM DESIGNA. Design OverviewB. Block DesignC. InitializationD. Role SelectionE. Storage ProtocolF. Aggregation ProtocolG. Proof of ReliabilityH. Blockchain Consens…...
《网络协议》08. 概念补充
title: 《网络协议》08. 概念补充 date: 2022-10-06 18:33:04 updated: 2023-11-17 10:35:52 categories: 学习记录:网络协议 excerpt: 代理、VPN、CDN、网络爬虫、无线网络、缓存、Cookie & Session、RESTful。 comments: false tags: top_image: /images/back…...
利用NVIDIA DALI读取视频帧
1. NVIDIA DALI简介 NVIDIA DALI全称是NVIDIA Data Loading Library,是一个用GPU加速的数据加载和预处理库,可用于图像、视频和语音数据的加载和处理,从而为深度学习的训练和推理加速。 NVIDIA DALI库的出发点是,深度学习应用中…...
TSINGSEE青犀AI智能分析+视频监控工业园区周界安全防范方案
一、背景需求分析 在工业产业园、化工园或生产制造园区中,周界防范意义重大,对园区的安全起到重要的作用。常规的安防方式是采用人员巡查,人力投入成本大而且效率低。周界一旦被破坏或入侵,会影响园区人员和资产安全,…...
Java 8 Stream API 入门到实践详解
一、告别 for 循环! 传统痛点: Java 8 之前,集合操作离不开冗长的 for 循环和匿名类。例如,过滤列表中的偶数: List<Integer> list Arrays.asList(1, 2, 3, 4, 5); List<Integer> evens new ArrayList…...
vscode(仍待补充)
写于2025 6.9 主包将加入vscode这个更权威的圈子 vscode的基本使用 侧边栏 vscode还能连接ssh? debug时使用的launch文件 1.task.json {"tasks": [{"type": "cppbuild","label": "C/C: gcc.exe 生成活动文件"…...
Linux相关概念和易错知识点(42)(TCP的连接管理、可靠性、面临复杂网络的处理)
目录 1.TCP的连接管理机制(1)三次握手①握手过程②对握手过程的理解 (2)四次挥手(3)握手和挥手的触发(4)状态切换①挥手过程中状态的切换②握手过程中状态的切换 2.TCP的可靠性&…...
跨链模式:多链互操作架构与性能扩展方案
跨链模式:多链互操作架构与性能扩展方案 ——构建下一代区块链互联网的技术基石 一、跨链架构的核心范式演进 1. 分层协议栈:模块化解耦设计 现代跨链系统采用分层协议栈实现灵活扩展(H2Cross架构): 适配层…...
苍穹外卖--缓存菜品
1.问题说明 用户端小程序展示的菜品数据都是通过查询数据库获得,如果用户端访问量比较大,数据库访问压力随之增大 2.实现思路 通过Redis来缓存菜品数据,减少数据库查询操作。 缓存逻辑分析: ①每个分类下的菜品保持一份缓存数据…...
【决胜公务员考试】求职OMG——见面课测验1
2025最新版!!!6.8截至答题,大家注意呀! 博主码字不易点个关注吧,祝期末顺利~~ 1.单选题(2分) 下列说法错误的是:( B ) A.选调生属于公务员系统 B.公务员属于事业编 C.选调生有基层锻炼的要求 D…...
在QWebEngineView上实现鼠标、触摸等事件捕获的解决方案
这个问题我看其他博主也写了,要么要会员、要么写的乱七八糟。这里我整理一下,把问题说清楚并且给出代码,拿去用就行,照着葫芦画瓢。 问题 在继承QWebEngineView后,重写mousePressEvent或event函数无法捕获鼠标按下事…...
从 GreenPlum 到镜舟数据库:杭银消费金融湖仓一体转型实践
作者:吴岐诗,杭银消费金融大数据应用开发工程师 本文整理自杭银消费金融大数据应用开发工程师在StarRocks Summit Asia 2024的分享 引言:融合数据湖与数仓的创新之路 在数字金融时代,数据已成为金融机构的核心竞争力。杭银消费金…...
深度学习之模型压缩三驾马车:模型剪枝、模型量化、知识蒸馏
一、引言 在深度学习中,我们训练出的神经网络往往非常庞大(比如像 ResNet、YOLOv8、Vision Transformer),虽然精度很高,但“太重”了,运行起来很慢,占用内存大,不适合部署到手机、摄…...
k8s从入门到放弃之HPA控制器
k8s从入门到放弃之HPA控制器 Kubernetes中的Horizontal Pod Autoscaler (HPA)控制器是一种用于自动扩展部署、副本集或复制控制器中Pod数量的机制。它可以根据观察到的CPU利用率(或其他自定义指标)来调整这些对象的规模,从而帮助应用程序在负…...
