美文网首页
spring事务原理及坑

spring事务原理及坑

作者: ffxxbb5 | 来源:发表于2019-06-13 15:36 被阅读0次

    事务原理

    开启事务有两种方式,可以通过在代码里加上开启事务的代码,叫编程式事务。
    还可以通过加@Transactional注解来开启事务,叫声明式事务,比较常用。

    那为什么加上@Transactional就可以开启事务了呢?这么强大的。

    其实它主要依靠于java的动态代理实现的,java动态代理有两种,分别式jdk动态代理和CGLib动态代理。

    • 什么是代理?
      代理(Proxy)是一种设计模式,提供了对目标对象另外的访问方式;即通过代理对象访问目标对象.这样做的好处是:可以在目标对象实现的基础上,增强额外的功能操作,即扩展目标对象的功能.

    例如:春运的时候我们通过车票代售点或者黄牛去买票,其中车票代售点或者黄牛就可以算是售票大厅的代理,他们有什么特点呢?
    1.代售点卖的也是售票大厅的票,它自己是没有票的,它只是行使售票大厅的权利
    2.它可以有属于自己的行为特征,比如不需要排队啊,每张硬座票收5元手续费啊等等。


    image.png
    • jdk动态代理和CGLib分别用在什么情况下?
      JDK动态代理只能用于带接口的,CGLIB则带不带接口都行
    • 下面看看怎么用代码实现动态代理
      jdk动态代理实现
    --接口类
    public interface User {
    
        public String say();
    
        public String doSomething();
    } 
    --接口实现类
    public class UserImpl implements  User{
        @Override
        public String say() {
            System.out.println("user-------say-------");
            doSomething();
            return "1111";
        }
    
        @Override
        public String doSomething() {
            System.out.println("user---------doSomething--------");
            return "22222";
        }
    }
    --代理类
    --实现InvocationHandler 接口
    public class UserDynamicProxy implements InvocationHandler {
    
        private Object target;
    
        public UserDynamicProxy(Object target){
            this.target=target;
        }
    
        @Override
        public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
             //方法调用前的处理事情
            System.out.println("before Proxy ------------");
            method.invoke(target,args);
            //方法调用后的处理事情
            System.out.println(" after Proxy ---------------");
            return null;
        }
    
        public  Object getInstance(){
            //获取动态代理类
            return Proxy.newProxyInstance(target.getClass().getClassLoader(), target.getClass().getInterfaces(), this);
        }
    }
    --动态代理测试类
    public class ProxyTest {
        public static void main(String[] args) {
            User user=new UserImpl();
            UserDynamicProxy proxy=new UserDynamicProxy(user);
            User userproxy=(User) proxy.getInstance();
    
            userproxy.doSomething();
    
            userproxy.say();
    
        }
    }
    //打印结果
    before Proxy ------------
    user---------doSomething--------
     after Proxy ---------------
    before Proxy ------------
    user-------say-------
     after Proxy ---------------
    

    CGLib动态代理实现

    --user接口和实现类同上
    --代理类 实现MethodInterceptor接口
    public class CglibProxy implements MethodInterceptor {
    
        @Override
        public Object intercept(Object o, Method method, Object[] objects, MethodProxy methodProxy) throws Throwable {
            System.out.println("before------------");
            //注意,这里是调用invokeSuper,不是invoke
            Object result =methodProxy.invokeSuper(o,objects);
            System.out.println("after---------");
    
    
            return result;
        }
    
        public Object getProxy(Class clazz){
            return Enhancer.create(clazz,this);
        }
    }
    --测试类
    public class CglibTest {
    
        public static void main(String[] args) {
            CglibProxy cglibProxy=new CglibProxy();
            User user=(User)cglibProxy.getProxy(UserImpl.class);
            user.doSomething();
            user.say();
        }
    }
    
    

    spring的事务注解就是利用动态代理技术实现的,通过在代理类加上事务的处理,来达到开启事务的效果,我们通过源码来看看

    我们看service,确实是生成了代理类,而且是Cglib动态代理类,我们进去CglibAopProxy看看


    image.png

    我们找到TransactionInterceptor 类,里面有一个方法invoke,


    image.png
    跟进去invokeWithinTransaction方法看看,此方法正式对我们的方法织入事务的代码。(源码有空再看看了)
    image.png

    假如有个接口,它包含两个方法a和b,然后有一个类实现了该接口。在该实现类里在a上标上事务注解、b上不标,此时事务是怎样的?

       @Override
        //@Transactional
        public String save(String value,String exFlag) {
    
            Demo demo = new Demo();
            demo.setGroupId("111");
            demo.setDemoField(value);
            demo.setCreateTime(new Date());
            demo.setAppName("ffxxbb1");
            demoMapper.save(demo);
    
            save2(value);
    //        if(Objects.nonNull(exFlag)){
    //            throw new RuntimeException("异常");
    //        }
    
            return "success";
        }
        @Transactional
        public String save2(String value) {
    
            Test test=new Test();
            test.setName("ffxxbb");
            testMapper.save(test);
            if(1==1){
                throw new RuntimeException("异常");
            }
            return null;
        }
    

    按道理我们在save2上加了事务的注解,应该在出现异常的时候,会回滚业务的,可是结果却跟我们想的不一样,结果两张表都插入数据了。
    我们在分析一下,我们的代理肯定是为有注解的类生成了代理,即save2是由代理增强的,有事务处理的,而save1是没有的,我们在controller调用save方法,会先通过代理类,执行事务的处理逻辑,然后进到我们的实现方法调用save,此时上下文是在我们的实现类,调用save2,所以跟save2时候有注解没关系了,因为他调用的不是代理类的save2方法了,所以事务是没效果的。
    可以通过获取代理类,调用save2方法

     @Override
        //@Transactional
        public String save(String value,String exFlag) {
    
            Demo demo = new Demo();
            demo.setGroupId("111");
            demo.setDemoField(value);
            demo.setCreateTime(new Date());
            demo.setAppName("ffxxbb1");
            demoMapper.save(demo);
            //获取代理类
            DemoService dempproxy=(DemoServiceImpl)AopContext.currentProxy();
            dempproxy.save2(value);
           // save2(value);
    //        if(Objects.nonNull(exFlag)){
    //            throw new RuntimeException("异常");
    //        }
    
            return "success";
        }
    

    要在类上加上注解
    @EnableAspectJAutoProxy(proxyTargetClass = true, exposeProxy = true)
    这样save2就是有事务的了,异常后会回滚。

    事务是由代理加进去的,所以关键就是代理如何生成。按照上面所说的代理应该具备的特点来看,只能通过继承的方式生成一个子类来充当代理.
    所以,private方法不能被继承,final方法不能被重写,static方法和继承不相干,所以它们3个的事务不起作用,Spring选择让protected方法和package方法不支持事务
    所以,只有public方法支持事务。

    总结

    只要是以代理方式实现的声明式事务,无论是JDK动态代理,还是CGLIB直接写字节码生成代理,都只有public方法上的事务注解才起作用。而且必须在代理类外部调用才行,如果直接在目标类里面调用,事务照样不起作用。

    相关文章

      网友评论

          本文标题:spring事务原理及坑

          本文链接:https://www.haomeiwen.com/subject/eqmjfctx.html