开发者社区> 游客tqcqp5pa4cdy4> 正文

spring事务的三个坑

简介: spring事务的三个坑
+关注继续查看

回顾


spring源码系列11:事务代理对象的执行那一节,得出的结论

事务执行:通过TransactionInterceptor增强器对

目标方法进行环绕增强。

  1. 调用目标方法前,创建事务。
  2. 执行目标方法
  3. 调用目标方法后,提交事务。

TransactionInterceptor功能增强功能的是实现在父类TransactionAspectSupportinvokeWithinTransaction方法

关键代码:

//创建事务
            TransactionInfo txInfo = createTransactionIfNecessary(tm, txAttr, joinpointIdentification);
            Object retVal = null;
            try {
                //执行目标方法
                retVal = invocation.proceedWithInvocation();
            }
            catch (Throwable ex) {
                //异常回滚
                completeTransactionAfterThrowing(txInfo, ex);
                throw ex;
            }
            finally {
                cleanupTransactionInfo(txInfo);
            }
            //提交事务
            commitTransactionAfterReturning(txInfo);
            return retVal;

最近遇到事务方面的问题。在看了源码后,才对这些问题的出现豁然开朗


事务存在的三个问题


假如有这么一个类

@Service
public class TransactionalService {
    @Autowired
    UserDao userDao;
    public String noTransactionalSave(){
        System.out.println("非事务方法");
        return  save1();
    }
    @Transactional
    public String save1(){
        User user = new User("主动方事务方法",0);
        save2();
        userDao.save(user);
        return "save1";
    }
    @Transactional(propagation = Propagation.REQUIRES_NEW)
    public String save2(){
        User user = new User("被事务方法",1);
        userDao.save(user);
        return "save2";
    }
    @Transactional
    public synchronized String syncSave(){
        System.out.println("锁方法");
        User user = new User("锁方法",0);
        userDao.save(user);
        return "锁";
    }
}

记得在事务代理的创建那一节说过,不管是方法上,还是类上使用 @Transactional。都会对此类进行代理的创建。 创建代理后,调用目标方法首先调用的是代理的方法。

以CGLB为例,执行链

调用方法-->动态代理类.方法-->MethodInterceptor.intercept方法-->MethodInvocation.proceed执行增强器链-->Adivce.invoke方法-->目标方法

我们再看看MethodInterceptor.intercept()方法

@Override
        public Object intercept(Object proxy, Method method, Object[] args, MethodProxy methodProxy) throws Throwable {
            Object oldProxy = null;
            boolean setProxyContext = false;
            Class<?> targetClass = null;
            Object target = null;
            try {
                //是否暴露出代理对象。
                if (this.advised.exposeProxy) {
                    //将代理对象放到事务上下文中。
                    oldProxy = AopContext.setCurrentProxy(proxy);
                    setProxyContext = true;
                }
                // May be null. Get as late as possible to minimize the time we
                // "own" the target, in case it comes from a pool...
                target = getTarget();
                if (target != null) {
                    targetClass = target.getClass();
                }
                List<Object> chain = this.advised.getInterceptorsAndDynamicInterceptionAdvice(method, targetClass);
                Object retVal;
                //没事增强,则使用反射调用目标类方法方法
                //也就是处理非事务方法
                if (chain.isEmpty() && Modifier.isPublic(method.getModifiers())) {
                    
                    Object[] argsToUse = AopProxyUtils.adaptArgumentsIfNecessary(method, args);
                    retVal = methodProxy.invoke(target, argsToUse);
                }
                else {
                    //处理事务方法
                    retVal = new CglibMethodInvocation(proxy, target, method, args, targetClass, chain, methodProxy).proceed();
                }
                retVal = processReturnType(proxy, target, method, retVal);
                return retVal;
            }
            finally {
                if (target != null) {
                    releaseTarget(target);
                }
                if (setProxyContext) {
                    // Restore old proxy.
                    AopContext.setCurrentProxy(oldProxy);
                }
            }
        }


1.同类中非事务方法调事务方法

首先因为有事务注解,所以会生成代理对象。

因为首先调用的是非事务方法,所以chain.isEmpty()条件成立,走反射执行目标方法。

执行链代理类noTransactionalSave()-->MethodInterceptor.intercept方法-->methodProxy.invoke方法--->目标类.noTransactionalSave()-->目标.save1()方法。

我们看出事务方法save1()虽然有事务注解,但是因为其被非事务方法调用。在本次调用链中,没有走事务增强分支,所以导致了事务的失效。

结论:同类中非事务方法调用事务方法,因为执行链不会走事务增强,导致此次调用中事务方法的事务失效。

解决办法: (1:出现此中业务场景时,可将非事务方法与事务方法抽象到不同的类中。事务方法所在类会创建事务代理,调用事务方法,走事务增强。 (2:看MethodInterceptor.intercept()中开头有一个if(this.advised.exposeProxy)的判断,如果为真,就会把事务代理对象放到事务上下文中,我们可以在非事务方法中,使用AopContext.currentProxy()获取代理对象,强制save1方法走代理执行。

项目中,我们遇到最多的应该就是事务失效问题,以前总是对事务失效问题模模糊糊,最近看了AOP源码,才对此有了深刻理解。


2.同类中事务方法调用事务方法

同类中事务方法调用事务方法,虽然不会出现事务失效问题。但是却会出现事务传播失效问题。

执行链代理方法.save1()--->MethodInterceptor.intercept方法--->methodProxy.invoke方法--->MethodInvocation.proceed执行增强器链-->Adivce.invoke增强方法--->目标方法.save1--->目标方法.save2

可以看出save1是事务方法,会走事务增强,但是save2的调用,是在save1方法增强调用链中,也就是说save2是依靠save1的事务。save2的事务配置,因为没有走Adivce(TransactionInterceptor).invoke增强方法,他的事务传播属性不会被解析。

结论:同类中事务方法调用事务方法,传播属性失效。

解决办法:同1中解决


3.调用同步事务方法

最近同事就遇到了这个问题呢。他在事务方法上加了synchronized关键词,让对此方法的调用强制串行化。

  • 第一个线程查询数据库,没有对应的实例数据,则创建一个数据
  • 第二个线程进入方法查询数据库,有了对应的值,则不用创建。 以此来达到幂等性问题。

想法是好的,但是结果确是有时还是会创建两条。

问题出在哪里呢?

首先: 在动态代理一节讲过,所谓的代理是在内存中生成了新的字节码文件。 在CGLB情况下,TransactionalService类生成的代理类TransactionalService?EnhancerBySpringCGLIB?cdcbf2e8中的syncSave()并没有synchronized修饰的。

public final String syncSave() {
        try {
            MethodInterceptor var10000 = this.CGLIB$CALLBACK_0;
            if (var10000 == null) {
                CGLIB$BIND_CALLBACKS(this);
                var10000 = this.CGLIB$CALLBACK_0;
            }
            return var10000 != null ? (String)var10000.intercept(this, CGLIB$syncSave$1$Method, CGLIB$emptyArgs, CGLIB$syncSave$1$Proxy) : super.syncSave();
        } catch (Error | RuntimeException var1) {
            throw var1;
        } catch (Throwable var2) {
            throw new UndeclaredThrowableException(var2);
        }
    }

其次: 再看看TransactionInterceptor对事务的增强那一段关键代码。事务的增强逻辑是在TransactionInterceptor中的。

//创建事务
            TransactionInfo txInfo = createTransactionIfNecessary(tm, txAttr, joinpointIdentification);
            Object retVal = null;
            try {
                //执行目标方法
                retVal = invocation.proceedWithInvocation();
            }
            catch (Throwable ex) {
                //异常回滚
                completeTransactionAfterThrowing(txInfo, ex);
                throw ex;
            }
            finally {
                cleanupTransactionInfo(txInfo);
            }
            //提交事务
            commitTransactionAfterReturning(txInfo);
            return retVal;

也就是说:两个线程都阻塞到目标方法上,当第一个线程离开目标方法时,他的调用回到了TransactionInterceptor中,做提交事务动作。但是此时第二个线程进入目标方法去执行数据库查询操作,但第一个线程的提交事务动作可能为完成,此时数据库中并没有,所以第二个线程也会创建一个实例数据。这样就可能出现创建两条的情况。

可以看出加锁的范围没有包括到整个事务,把synchronized加到方法上出发点时好的。但是真实的调用确实从代理类开始的,生成的代理类中并没有加synchronized,结合事务的增强。导致了synchronized同步的失效。

结论:@Transcational注解和synchronized锁一起使用会导致同步失效。加锁的范围没有包括到整个事务

解决办法:既然两个在一起,不能使用锁范围覆盖整个事务。那就创造一个覆盖整个事务的调用。锁方法与事务方法分离到不同的类中,在锁方法中调用事务方法,不就完成了锁范围覆盖整个事务了吗


总结


透过表象看本质。

事务虽然给我带来了方便,但是因为代理类的生成,有一些隐形的调用存在,导致了我们错误的判断了调用链,带来一些错误。

所以看到本质,才能正确的使用。


版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
阿里云服务器端口号设置
阿里云服务器初级使用者可能面临的问题之一. 使用tomcat或者其他服务器软件设置端口号后,比如 一些不是默认的, mysql的 3306, mssql的1433,有时候打不开网页, 原因是没有在ecs安全组去设置这个端口号. 解决: 点击ecs下网络和安全下的安全组 在弹出的安全组中,如果没有就新建安全组,然后点击配置规则 最后如上图点击添加...或快速创建.   have fun!  将编程看作是一门艺术,而不单单是个技术。
20823 0
腾讯云服务器 设置ngxin + fastdfs +tomcat 开机自启动
在tomcat中新建一个可以启动的 .sh 脚本文件 /usr/local/tomcat7/bin/ export JAVA_HOME=/usr/local/java/jdk7 export PATH=$JAVA_HOME/bin/:$PATH export CLASSPATH=.
14909 0
使用NAT网关轻松为单台云服务器设置多个公网IP
在应用中,有时会遇到用户询问如何使单台云服务器具备多个公网IP的问题。 具体如何操作呢,有了NAT网关这个也不是难题。
37355 0
使用OpenApi弹性释放和设置云服务器ECS释放
云服务器ECS的一个重要特性就是按需创建资源。您可以在业务高峰期按需弹性的自定义规则进行资源创建,在完成业务计算的时候释放资源。本篇将提供几个Tips帮助您更加容易和自动化的完成云服务器的释放和弹性设置。
20924 0
使用SSH远程登录阿里云ECS服务器
远程连接服务器以及配置环境
14803 0
阿里云ECS云服务器初始化设置教程方法
阿里云ECS云服务器初始化是指将云服务器系统恢复到最初状态的过程,阿里云的服务器初始化是通过更换系统盘来实现的,是免费的,阿里云百科网分享服务器初始化教程: 服务器初始化教程方法 本文的服务器初始化是指将ECS云服务器系统恢复到最初状态,服务器中的数据也会被清空,所以初始化之前一定要先备份好。
16681 0
阿里云服务器如何登录?阿里云服务器的三种登录方法
购买阿里云ECS云服务器后如何登录?场景不同,大概有三种登录方式:
13673 0
如何设置阿里云服务器安全组?阿里云安全组规则详细解说
阿里云安全组设置详细图文教程(收藏起来) 阿里云服务器安全组设置规则分享,阿里云服务器安全组如何放行端口设置教程。阿里云会要求客户设置安全组,如果不设置,阿里云会指定默认的安全组。那么,这个安全组是什么呢?顾名思义,就是为了服务器安全设置的。安全组其实就是一个虚拟的防火墙,可以让用户从端口、IP的维度来筛选对应服务器的访问者,从而形成一个云上的安全域。
19985 0
84
文章
0
问答
文章排行榜
最热
最新
相关电子书
更多
JS零基础入门教程(上册)
立即下载
性能优化方法论
立即下载
手把手学习日志服务SLS,云启实验室实战指南
立即下载