AI 助理
备案控制台
开发者社区 开发与运维 文章 正文

线上事务失效及失效场景总结记录

2022-01-14 145
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： 事务注解 @Transactional 失效的3种场景及解决办法

Transactional失效场景介绍


第一种


Transactional注解标注方法修饰符为非public时，@Transactional注解将会不起作用。例如以下代码。


定义一个错误的@Transactional标注实现，修饰一个默认访问符的方法


/*** @author zhoujy* @date 2018年12月06日**/@ComponentpublicclassTestServiceImpl {
@ResourceTestMappertestMapper;
@TransactionalvoidinsertTestWrongModifier() {
intre=testMapper.insert(newTest(10,20,30));
if (re>0) {
thrownewNeedToInterceptException("need intercept");
        }
testMapper.insert(newTest(210,20,30));
    }
}


在同一个包内，新建调用对象，进行访问。


@ComponentpublicclassInvokcationService {
@ResourceprivateTestServiceImpltestService;
publicvoidinvokeInsertTestWrongModifier(){
//调用@Transactional标注的默认访问符方法testService.insertTestWrongModifier();
    }
}


测试用例


@RunWith(SpringRunner.class)
@SpringBootTestpublicclassDemoApplicationTests {
@ResourceInvokcationServiceinvokcationService;
@TestpublicvoidtestInvoke(){
invokcationService.invokeInsertTestWrongModifier();
   }
}


以上的访问方式，导致事务没开启，因此在方法抛出异常时，testMapper.insert(new Test(10,20,30));操作不会进行回滚。如果TestServiceImpl#insertTestWrongModifier方法改为public的话将会正常开启事务，testMapper.insert(new Test(10,20,30));将会进行回滚。


第二种


在类内部调用调用类内部@Transactional标注的方法。这种情况下也会导致事务不开启。示例代码如下。


设置一个内部调用


/*** @author zhoujy* @date 2018年12月06日**/@ComponentpublicclassTestServiceImplimplementsTestService {
@ResourceTestMappertestMapper;
@TransactionalpublicvoidinsertTestInnerInvoke() {
//正常public修饰符的事务方法intre=testMapper.insert(newTest(10,20,30));
if (re>0) {
thrownewNeedToInterceptException("need intercept");
        }
testMapper.insert(newTest(210,20,30));
    }
publicvoidtestInnerInvoke(){
//类内部调用@Transactional标注的方法。insertTestInnerInvoke();
    }
}


测试用例。


@RunWith(SpringRunner.class)
@SpringBootTestpublicclassDemoApplicationTests {
@ResourceTestServiceImpltestService;
/*** 测试内部调用@Transactional标注方法*/@TestpublicvoidtestInnerInvoke(){
//测试外部调用事务方法是否正常//testService.insertTestInnerInvoke();//测试内部调用事务方法是否正常testService.testInnerInvoke();
   }
}


上面就是使用的测试代码，运行测试知道，外部调用事务方法能够征程开启事务，testMapper.insert(new Test(10,20,30))操作将会被回滚；


然后运行另外一个测试用例，调用一个方法在类内部调用内部被@Transactional标注的事务方法，运行结果是事务不会正常开启，testMapper.insert(new Test(10,20,30))操作将会保存到数据库不会进行回滚。


第三种


事务方法内部捕捉了异常，没有抛出新的异常，导致事务操作不会进行回滚。示例代码如下。


/*** @author zhoujy* @date 2018年12月06日**/@ComponentpublicclassTestServiceImplimplementsTestService {
@ResourceTestMappertestMapper;
@TransactionalpublicvoidinsertTestCatchException() {
try {
intre=testMapper.insert(newTest(10,20,30));
if (re>0) {
//运行期间抛异常thrownewNeedToInterceptException("need intercept");
            }
testMapper.insert(newTest(210,20,30));
        }catch (Exceptione){
System.out.println("i catch exception");
        }
    }
}


测试用例代码如下。


@RunWith(SpringRunner.class)
@SpringBootTestpublicclassDemoApplicationTests {
@ResourceTestServiceImpltestService;
@TestpublicvoidtestCatchException(){
testService.insertTestCatchException();
   }
}


运行测试用例发现，虽然抛出异常，但是异常被捕捉了，没有抛出到方法 外， testMapper.insert(new Test(210,20,30))操作并没有回滚。


以上三种就是@Transactional注解不起作用，@Transactional注解失效的主要原因。下面结合spring中对于@Transactional的注解实现源码分析为何导致@Transactional注解不起作用。


@Transactional注解不起作用原理分析


首先不了解@Transactional注解实现原理，然后下面开始结合源码分析下面三种情况。


第一种


@Transactional注解标注方法修饰符为非public时，@Transactional注解将会不起作用。这里分析 的原因是，@Transactional是基于动态代理实现的，@Transactional注解实现原理中分析了实现方法，在bean初始化过程中，对含有@Transactional标注的bean实例创建代理对象，这里就存在一个spring扫描@Transactional注解信息的过程，不幸的是源码中体现，标注@Transactional的方法如果修饰符不是public，那么就默认方法的@Transactional信息为空，那么将不会对bean进行代理对象创建或者不会对方法进行代理调用


@Transactional注解实现原理中，介绍了如何判定一个bean是否创建代理对象，大概逻辑是。根据spring创建好一个aop切点BeanFactoryTransactionAttributeSourceAdvisor实例，遍历当前bean的class的方法对象，判断方法上面的注解信息是否包含@Transactional，如果bean任何一个方法包含@Transactional注解信息，那么就是适配这个BeanFactoryTransactionAttributeSourceAdvisor切点。则需要创建代理对象，然后代理逻辑为我们管理事务开闭逻辑。


spring源码中，在拦截bean的创建过程，寻找bean适配的切点时，运用到下面的方法，目的就是寻找方法上面的@Transactional信息，如果有，就表示切点BeanFactoryTransactionAttributeSourceAdvisor能够应用（canApply）到bean中，

• AopUtils#canApply(org.springframework.aop.Pointcut, java.lang.Class<?>, boolean)

publicstaticbooleancanApply(Pointcutpc, Class<?>targetClass, booleanhasIntroductions) {
Assert.notNull(pc, "Pointcut must not be null");
if (!pc.getClassFilter().matches(targetClass)) {
returnfalse;
   }
MethodMatchermethodMatcher=pc.getMethodMatcher();
if (methodMatcher==MethodMatcher.TRUE) {
// No need to iterate the methods if we're matching any method anyway...returntrue;
   }
IntroductionAwareMethodMatcherintroductionAwareMethodMatcher=null;
if (methodMatcherinstanceofIntroductionAwareMethodMatcher) {
introductionAwareMethodMatcher= (IntroductionAwareMethodMatcher) methodMatcher;
   }
//遍历class的方法对象Set<Class<?>>classes=newLinkedHashSet<Class<?>>(ClassUtils.getAllInterfacesForClassAsSet(targetClass));
classes.add(targetClass);
for (Class<?>clazz : classes) {
Method[] methods=ReflectionUtils.getAllDeclaredMethods(clazz);
for (Methodmethod : methods) {
if ((introductionAwareMethodMatcher!=null&&introductionAwareMethodMatcher.matches(method, targetClass, hasIntroductions)) ||//适配查询方法上的@Transactional注解信息  methodMatcher.matches(method, targetClass)) {
returntrue;
         }
      }
   }
returnfalse;
}


我们可以在上面的方法打断点，一步一步调试跟踪代码，最终上面的代码还会调用如下方法来判断。在下面的方法上断点，回头看看方法调用堆栈也是不错的方式跟踪。


AbstractFallbackTransactionAttributeSource#getTransactionAttribute


  • AbstractFallbackTransactionAttributeSource#computeTransactionAttribute


protected TransactionAttribute computeTransactionAttribute(Method method, Class<?> targetClass) {

  // Don't allow no-public methods as required.

  //非public 方法，返回@Transactional信息一律是null

  if (allowPublicMethodsOnly() && !Modifier.isPublic(method.getModifiers())) {

     return null;

  }

  //后面省略.......

}


不创建代理对象


所以，如果所有方法上的修饰符都是非public的时候，那么将不会创建代理对象。以一开始的测试代码为例，如果正常的修饰符的testService是下面图片中的，经过cglib创建的代理对象。



如果class中的方法都是非public的那么将不是代理对象。



不进行代理调用


考虑一种情况，如下面代码所示。两个方法都被@Transactional注解标注，但是一个有public修饰符一个没有，那么这种情况我们可以预见的话，一定会创建代理对象，因为至少有一个public修饰符的@Transactional注解标注方法。


创建了代理对象，insertTestWrongModifier就会开启事务吗？答案是不会。


/*** @author zhoujy* @date 2018年12月06日**/@ComponentpublicclassTestServiceImplimplementsTestService {
@ResourceTestMappertestMapper;
@Override@TransactionalpublicvoidinsertTest() {
intre=testMapper.insert(newTest(10,20,30));
if (re>0) {
thrownewNeedToInterceptException("need intercept");
        }
testMapper.insert(newTest(210,20,30));
    }
@TransactionalvoidinsertTestWrongModifier() {
intre=testMapper.insert(newTest(10,20,30));
if (re>0) {
thrownewNeedToInterceptException("need intercept");
        }
testMapper.insert(newTest(210,20,30));
    }
}


原因是在动态代理对象进行代理逻辑调用时，在cglib创建的代理对象的拦截函数中CglibAopProxy.DynamicAdvisedInterceptor#intercept，有一个逻辑如下，目的是获取当前被代理对象的当前需要执行的method适配的aop逻辑。


List<Object>chain=this.advised.getInterceptorsAndDynamicInterceptionAdvice(method, targetClass);


而针对@Transactional注解查找aop逻辑过程，相似地，也是执行一次


  • AbstractFallbackTransactionAttributeSource#getTransactionAttribute
  • AbstractFallbackTransactionAttributeSource#computeTransactionAttribute


也就是说还需要找一个方法上的@Transactional注解信息，没有的话就不执行代理@Transactional对应的代理逻辑，直接执行方法。没有了@Transactional注解代理逻辑，就无法开启事务，这也是上一篇已经讲到的。


第二种


在类内部调用调用类内部@Transactional标注的方法。这种情况下也会导致事务不开启。


经过对第一种的详细分析，对这种情况为何不开启事务管理，原因应该也能猜到；


既然事务管理是基于动态代理对象的代理逻辑实现的，那么如果在类内部调用类内部的事务方法，这个调用事务方法的过程并不是通过代理对象来调用的，而是直接通过this对象来调用方法，绕过的代理对象，肯定就是没有代理逻辑了。


其实我们可以这样玩，内部调用也能实现开启事务，代码如下。


/*** @author zhoujy* @date 2018年12月06日**/@ComponentpublicclassTestServiceImplimplementsTestService {
@ResourceTestMappertestMapper;
@ResourceTestServiceImpltestServiceImpl;
@TransactionalpublicvoidinsertTestInnerInvoke() {
intre=testMapper.insert(newTest(10,20,30));
if (re>0) {
thrownewNeedToInterceptException("need intercept");
        }
testMapper.insert(newTest(210,20,30));
    }
publicvoidtestInnerInvoke(){
//内部调用事务方法testServiceImpl.insertTestInnerInvoke();
    }
}


上面就是使用了代理对象进行事务调用，所以能够开启事务管理，但是实际操作中，没人会闲的蛋疼这样子玩~


第三种


事务方法内部捕捉了异常，没有抛出新的异常，导致事务操作不会进行回滚。


这种的话，可能我们比较常见，问题就出在代理逻辑中，我们先看看源码里卖弄动态代理逻辑是如何为我们管理事务的，这个过程在我的另一篇文章有提到。


  • TransactionAspectSupport#invokeWithinTransaction


代码如下。


protectedObjectinvokeWithinTransaction(Methodmethod, Class<?>targetClass, finalInvocationCallbackinvocation)
throwsThrowable {
// If the transaction attribute is null, the method is non-transactional.finalTransactionAttributetxAttr=getTransactionAttributeSource().getTransactionAttribute(method, targetClass);
finalPlatformTransactionManagertm=determineTransactionManager(txAttr);
finalStringjoinpointIdentification=methodIdentification(method, targetClass);
if (txAttr==null||!(tminstanceofCallbackPreferringPlatformTransactionManager)) {
// Standard transaction demarcation with getTransaction and commit/rollback calls.//开启事务TransactionInfotxInfo=createTransactionIfNecessary(tm, txAttr, joinpointIdentification);
ObjectretVal=null;
try {
// This is an around advice: Invoke the next interceptor in the chain.// This will normally result in a target object being invoked.//反射调用业务方法retVal=invocation.proceedWithInvocation();
      }
catch (Throwableex) {
// target invocation exception//异常时，在catch逻辑中回滚事务completeTransactionAfterThrowing(txInfo, ex);
throwex;
      }
finally {
cleanupTransactionInfo(txInfo);
      }
//提交事务commitTransactionAfterReturning(txInfo);
returnretVal;
   }
else {
//....................   }
}


所以看了上面的代码就一目了然了，事务想要回滚，必须能够在这里捕捉到异常才行，如果异常中途被捕捉掉，那么事务将不会回滚。

文章标签：
Java
测试技术
Spring
数据库
Kam
目录
相关文章
源码星辰
|
6月前
|
SQL Oracle 关系型数据库
分析索引失效的几种情况
联合索引 is not null 只要在建立的索引列（不分先后）都会走, in null时 必须要和建立索引第一列一起使用,当建立索引第一位置条件是is null 时,其他建立索引的列可以是is null（但必须在所有列 都满足is null的时候）,或者=一个值； 当建立索引的第一位置是=一个值时,其他索引列可以是任何情况（包括is null =一个值）,以上两种情况索引都会走。其他情况不会走。
源码星辰
101 1
源码星辰
|
6月前
|
SQL Oracle 关系型数据库
索引失效的情况分析
大家都知道，一条查询语句走了索引和没走索引的查询效率是非常大的，在我们建好了表，建好了索引后，但是一些不好的sql会导致我们的索引失效，下面介绍一下索引失效的几种情况
源码星辰
43 0
mao29955
|
26天前
|
监控 数据库 索引
避免锁等待超时对数据库性能的影响
【10月更文挑战第16天】避免锁等待超时对数据库性能的影响需要综合考虑多个方面，通过不断地优化和改进，来提高数据库的并发处理能力和稳定性。
mao29955
35 1
郏国上
|
6月前
|
iOS开发
如何让你的应用在后台可以继续处理未完事务
如何让你的应用在后台可以继续处理未完事务
郏国上
57 1
真的很搞笑
|
5月前
|
运维 关系型数据库 分布式数据库
PolarDB产品使用问题之表更新频繁，读取频繁，导致有很多慢日志，时间还很高，该怎么办
PolarDB产品使用合集涵盖了从创建与管理、数据管理、性能优化与诊断、安全与合规到生态与集成、运维与支持等全方位的功能和服务，旨在帮助企业轻松构建高可用、高性能且易于管理的数据库环境，满足不同业务场景的需求。用户可以通过阿里云控制台、API、SDK等方式便捷地使用这些功能，实现数据库的高效运维与持续优化。
真的很搞笑
42 2
1030024444162706
|
6月前
|
SQL 存储 关系型数据库
真正线上索引失效的问题是如何排查的
MySQL索引失效是一种常见问题，在处理慢查询时经常需要考虑索引失效的可能性。 针对索引失效的排查，关键步骤包括确定需要分析的SQL语句，并通过`EXPLAIN`查看其执行计划。主要关注`type`、`key`和`extra`这几个字段。
1030024444162706
180 0
真正线上索引失效的问题是如何排查的
阿甘兄
|
11月前
解决URLClassLoader使用addURL方法失效的问题
解决URLClassLoader使用addURL方法失效的问题
阿甘兄
121 0
凌虚Wayne
|
关系型数据库 MySQL 数据库
并发事务更新问题
并发事务更新问题
凌虚Wayne
60 0
啵啵肠
|
canal 缓存 NoSQL
会不会这是你需要注意的「Redis缓存更新一致性」
会不会这是你需要注意的「Redis缓存更新一致性」
啵啵肠
91 0
CBeann
|
数据库 索引
MysSQL索引会失效的几种情况分析
MysSQL索引会失效的几种情况分析
CBeann
150 0
MysSQL索引会失效的几种情况分析