jjzjj

Java - @Transaction 异常不回滚

Mingvvv 2024-07-05 原文

文章目录


今天又遇到了 @Transaction 注解失效的情况,明明方法已经发生了运行时错误,但是数据并没有回滚,所以在这里记录一下可能导致注解失效的几种情况。

@Transaction 核心点

事务的实现其实是Spring 通过默认动态代理的方式实现 AOP, 从而实现对目标方法的增强 ,即对带有 @Transaction 注解的方法实现事务相关逻辑的增强,我们真正调用到能够实现事务的方法实质上是调用代理过的对象中被增强过的方法。
显然有重要的两点:

  1. Spring 管理
  2. 动态代理

事务不回滚的情况

没有抛出 RuntimeException 或 Error

只有代码抛出 RuntimeException 运行时异常或 Error的时候才会触发事务回滚。

异常被捕获

注意抛出异常的代码是否被 try…catch… 包裹,是否在获取到异常之后抛出了运行时异常。
如果未抛出,则事务回滚不生效,可以手动抛出异常,也可以手动回滚。
如下,catch 中的两种的方法均可触发回滚效果:

    @Transactional
    public void transTerst() {
        try {
            testDao.insertTest("1");
            testDao.insertTest("2");
            System.out.println(10/0);
        }catch (Exception ex){
//            throw new RuntimeException(ex.getMessage());
            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
        }
    }

@Transaction 未定义在public方法上

因为 Spring 通过动态代理实现 AOP 对方法进行增强而实现事务的一系列相关逻辑,所以从根本之上,Spring 需要能获取到该方法的代理,而 Spring 无法代理到 private 方法上。

@Transaction 方法未被代理增强

没使用被增强过的方法

如下代码,回滚并不会生效:

@Service
public class TransServiceImpl implements ITransService {

    @Autowired
    TestDao testDao;

    @Transactional
    public void transTest1() {
        testDao.insertTest("3");
        testDao.insertTest("4");
    }

    @Override
    public void transTest() {
        try {
            transTest1();
            this.transTest1();
            System.out.println(10/0);
        }catch (Exception ex){
            throw new RuntimeException(ex.getMessage());
        }
    }

重点在与这个方法所在的位置。
其实,在 transTest 方法中 的 transTest1();this.transTest1(); 的意义是一样的,transTest1() 是当前这个类中的方法,this 代表的是这个类自己,这两种写法都是在当前类找到 transTest1() 方法并调用。
而当前类肯定是不会做多余的工作去代理一个自己出来,所以我们在调用 transTest1() 的时候,使用的其实是该类中自身的方法,而不是通过 Spring 增强过的方法,自然没有事务的相关性质。
所以我们需要调用被 Spring 增强过的 transTest1 方法,改成如下代码:

@Service
public class TransServiceImpl implements ITransService {

    @Autowired
    TestDao testDao;

    @Autowired
    ITransService transService;
    
    @Transactional
    public void transTest1() {...}

    @Override
    public void transTest() {
        try {
            transService.transTest1();
            transService.transTest1();
            System.out.println(10/0);
        }catch (Exception ex){
            throw new RuntimeException(ex.getMessage());
        }
    }
}

类未被代理

还有一点也需要注意:

@Service
public class TransServiceImpl implements ITransService {
...
}

这个类中的 @Service 注解也是很关键的,他和 @Component@Configuration 注解一样,代表这个类被注册为 Spring 容器中的 Bean,受 Spring 容器管理。

事务的传播性质

有的时候我们并不是简单的想回滚所有的操作,比如我们有一个主方法里面我们操作了表A ,在我们的子方法里面,我们操作了表B,我们需要的情景是,表B出现的异常导致的数据回滚不影响表A的插入。
首先我们尝试使用 try…catch… 获取主方法中的异常,不让其抛出运行时异常。

@Mapper
public interface TestDao extends BaseMapper<Object> {
    @Insert({"insert into a (field_a)values(#{testValue})"})
    long insertA(String testValue);

    @Insert({"insert into b (field_b)values(#{testValue})"})
    long insertB(String testValue);
}

@Service
public class TransServiceImpl implements ITransService {

    @Autowired
    TestDao testDao;

    @Autowired
    ITransService transService;

    @Transactional
    public void insertB() {
        testDao.insertB("b");
        System.out.println(10/0);
    }

    @Override
    @Transactional
    public void transTest() {
        try {
            testDao.insertA("a");
            transService.insertB();
        }catch (Exception ex){
//            DO NOTHING
//            throw new RuntimeException(ex.getMessage());
        }
    }
}

没有异常抛出但是事务回滚

在我们的预期效果中,表B回滚,表A数据正常保存,但是事实上并不是这样。
两个表里面都没有数据,即 transTest 方法中的 SQL 操作也回滚了。


主方法明明没有抛出异常却发生了事务回滚,其实是因为事物的传播性质
子方法沿用了主方法的事务,即插入表A和插入表B这两个操作其实是在同一个事务中进行的。
子方法中发生异常导致事务回滚,主方法提交事务时发现当前事务已经被标记为回滚,无法提交事务,只能执行静默回滚操作
解决办法也很简单,只要主方法和子方法不在一个事务里面就可以了,使用 @Transaction 注解中的 propagation 属性为子方法单独创建一个事务,修改如下:

@Service
public class TransServiceImpl implements ITransService {
    @Autowired
    TestDao testDao;

    @Autowired
    ITransService transService;

    @Transactional(propagation = Propagation.REQUIRES_NEW)
    public void insertB() {...}

    @Override
    @Transactional
    public void transTerst() {...}

这样子方法中异常就不会影响主方法中的插入了。

有关Java - @Transaction 异常不回滚的更多相关文章

  1. java - 等价于 Java 中的 Ruby Hash - 2

    我真的很习惯使用Ruby编写以下代码:my_hash={}my_hash['test']=1Java中对应的数据结构是什么? 最佳答案 HashMapmap=newHashMap();map.put("test",1);我假设? 关于java-等价于Java中的RubyHash,我们在StackOverflow上找到一个类似的问题: https://stackoverflow.com/questions/22737685/

  2. ruby-on-rails - Rails - 乐观锁定总是触发 StaleObjectError 异常 - 2

    我正在学习Rails,并阅读了关于乐观锁的内容。我已将类型为integer的lock_version列添加到我的articles表中。但现在每当我第一次尝试更新记录时,我都会收到StaleObjectError异常。这是我的迁移:classAddLockVersionToArticle当我尝试通过Rails控制台更新文章时:article=Article.first=>#我这样做:article.title="newtitle"article.save我明白了:(0.3ms)begintransaction(0.3ms)UPDATE"articles"SET"title"='dwdwd

  3. ruby - #之间? Cooper 的 *Beginning Ruby* 中的错误或异常 - 2

    在Cooper的书BeginningRuby中,第166页有一个我无法重现的示例。classSongincludeComparableattr_accessor:lengthdef(other)@lengthother.lengthenddefinitialize(song_name,length)@song_name=song_name@length=lengthendenda=Song.new('Rockaroundtheclock',143)b=Song.new('BohemianRhapsody',544)c=Song.new('MinuteWaltz',60)a.betwee

  4. ruby - 在 Ruby 中重新分配常量时抛出异常? - 2

    我早就知道Ruby中的“常量”(即大写的变量名)不是真正常量。与其他编程语言一样,对对象的引用是唯一存储在变量/常量中的东西。(侧边栏:Ruby确实具有“卡住”引用对象不被修改的功能,据我所知,许多其他语言都没有提供这种功能。)所以这是我的问题:当您将一个值重新分配给常量时,您会收到如下警告:>>FOO='bar'=>"bar">>FOO='baz'(irb):2:warning:alreadyinitializedconstantFOO=>"baz"有没有办法强制Ruby抛出异常而不是打印警告?很难弄清楚为什么有时会发生重新分配。 最佳答案

  5. java - 从 JRuby 调用 Java 类的问题 - 2

    我正在尝试使用boilerpipe来自JRuby。我看过guide从JRuby调用Java,并成功地将它与另一个Java包一起使用,但无法弄清楚为什么同样的东西不能用于boilerpipe。我正在尝试基本上从JRuby中执行与此Java等效的操作:URLurl=newURL("http://www.example.com/some-location/index.html");Stringtext=ArticleExtractor.INSTANCE.getText(url);在JRuby中试过这个:require'java'url=java.net.URL.new("http://www

  6. java - 我的模型类或其他类中应该有逻辑吗 - 2

    我只想对我一直在思考的这个问题有其他意见,例如我有classuser_controller和classuserclassUserattr_accessor:name,:usernameendclassUserController//dosomethingaboutanythingaboutusersend问题是我的User类中是否应该有逻辑user=User.newuser.do_something(user1)oritshouldbeuser_controller=UserController.newuser_controller.do_something(user1,user2)我

  7. java - 什么相当于 ruby​​ 的 rack 或 python 的 Java wsgi? - 2

    什么是ruby​​的rack或python的Java的wsgi?还有一个路由库。 最佳答案 来自Python标准PEP333:Bycontrast,althoughJavahasjustasmanywebapplicationframeworksavailable,Java's"servlet"APImakesitpossibleforapplicationswrittenwithanyJavawebapplicationframeworktoruninanywebserverthatsupportstheservletAPI.ht

  8. Observability:从零开始创建 Java 微服务并监控它 (二) - 2

    这篇文章是继上一篇文章“Observability:从零开始创建Java微服务并监控它(一)”的续篇。在上一篇文章中,我们讲述了如何创建一个Javaweb应用,并使用Filebeat来收集应用所生成的日志。在今天的文章中,我来详述如何收集应用的指标,使用APM来监控应用并监督web服务的在线情况。源码可以在地址 https://github.com/liu-xiao-guo/java_observability 进行下载。摄入指标指标被视为可以随时更改的时间点值。当前请求的数量可以改变任何毫秒。你可能有1000个请求的峰值,然后一切都回到一个请求。这也意味着这些指标可能不准确,你还想提取最小/

  9. 【Java 面试合集】HashMap中为什么引入红黑树,而不是AVL树呢 - 2

    HashMap中为什么引入红黑树,而不是AVL树呢1.概述开始学习这个知识点之前我们需要知道,在JDK1.8以及之前,针对HashMap有什么不同。JDK1.7的时候,HashMap的底层实现是数组+链表JDK1.8的时候,HashMap的底层实现是数组+链表+红黑树我们要思考一个问题,为什么要从链表转为红黑树呢。首先先让我们了解下链表有什么不好???2.链表上述的截图其实就是链表的结构,我们来看下链表的增删改查的时间复杂度增:因为链表不是线性结构,所以每次添加的时候,只需要移动一个节点,所以可以理解为复杂度是N(1)删:算法时间复杂度跟增保持一致查:既然是非线性结构,所以查询某一个节点的时候

  10. SPI接收数据异常问题总结 - 2

    SPI接收数据左移一位问题目录SPI接收数据左移一位问题一、问题描述二、问题分析三、探究原理四、经验总结最近在工作在学习调试SPI的过程中遇到一个问题——接收数据整体向左移了一位(1bit)。SPI数据收发是数据交换,因此接收数据时从第二个字节开始才是有效数据,也就是数据整体向右移一个字节(1byte)。请教前辈之后也没有得到解决,通过在网上查阅前人经验终于解决问题,所以写一个避坑经验总结。实际背景:MCU与一款芯片使用spi通信,MCU作为主机,芯片作为从机。这款芯片采用的是它规定的六线SPI,多了两根线:RDY和INT,这样从机就可以主动请求主机给主机发送数据了。一、问题描述根据从机芯片手

随机推荐