spring同一个类中，一个方法调用另外一个注解(@Transactional)方法时，注解失效

傷城~ 2022-04-12 03:51 443阅读 0赞

--------------------

title: “spring同一个类中，一个方法调用另外一个注解(@Transactional)方法时，注解失效”

url: “https://wsk1103.github.io/”

tags:

*  错误笔记

--------------------

**基于spring 3.2.9**  
参考 [https://www.ibm.com/developerworks/cn/java/j-master-spring-transactional-use/index.html][https_www.ibm.com_developerworks_cn_java_j-master-spring-transactional-use_index.html]

### 1. Transactional是什么 ###

Transactional用来声明事务的，包括事务的begin和commit。被注解的public方法或者对象在被调用的时候，spring会为该public方法或者对象中的所有public方法生成一个代理对象来代理被注解的方法。

例如：  
原类->

public class A {
        @Transactional
        public void a() {
            ...            
        }
    }

被代理后

public class Proxy$A extend A{
    
        A a = new A();
    
        //spring扫描注解后，为注解的方法插入一个startTransaction()方法。
        public void a () {
            startTransaction();
    
            a.a();
            commitTransactionAfterReturning();
        }
    }

## 2. 怎么使用@Transactional ##

目前比较流行的使用是基于Java注解声明。  
分为2个步骤：

1.  在spring.xml文件中声明事务的配置信息

<bean id="transactionManager"
              class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
            
            <property name="dataSource" ref="dataSource"></property>
        </bean>
        
        <tx:annotation-driven/>

1.  在public方法或者类上声明@Transactional

@Transactional 注解属性说明：

<table> 
 <thead> 
  <tr> 
   <th>属性名</th> 
   <th>说明</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>value</td> 
   <td>当在xml配置文件中配置多个TransactionManager的时候，可以指定使用哪个事务管理器</td> 
  </tr> 
  <tr> 
   <td>propagation</td> 
   <td>事务的传播行为，默认为Propagation.REQUIRED（表示启动事务）。PROPAGATION_SUPPORTS:如果当前存在事务，则加入该事务，如果没有事务，则以非事务的方式继续进行。 PROPAGATION_NOT_SUPPORTED：以非事务的方法运行，如果当前存在事务，则将事务挂起。PROPAGATION_NEVER：以非事务的方法运行，如果当前存在事务，则抛出异常。</td> 
  </tr> 
  <tr> 
   <td>isolation</td> 
   <td>事务的隔离等级，默认为Isolation.DEFAULT。必须返回 TransactionDefinition 接口上定义的ISOLATION_XXX 常量之一。只有结合PROPAGATION_REQUIRED 或者 PROPAGATION_REQUIRES_NEW 一起声明才有意义。</td> 
  </tr> 
  <tr> 
   <td>timeout</td> 
   <td>默认值为 -1（不超时），单位秒。表示事务必须在规定的时间内处理完成，否则超时。</td> 
  </tr> 
  <tr> 
   <td>readOnly</td> 
   <td>默认false。该事务是否只读。</td> 
  </tr> 
  <tr> 
   <td>rollbackFor</td> 
   <td>用于指定能够触发回滚的异常类型。多个类型以,（英文逗号）隔开</td> 
  </tr> 
  <tr> 
   <td>rollbackForClassName</td> 
   <td>定义异常的名字，这些异常会触发回滚机制。多个类型以,（英文逗号）隔开</td> 
  </tr> 
  <tr> 
   <td>noRollbackFor</td> 
   <td>抛出异常，不回滚。多个类型以,（英文逗号）隔开</td> 
  </tr> 
  <tr> 
   <td>noRollbackForClassName</td> 
   <td>定义异常的名字，抛出异常，不回滚。多个类型以,（英文逗号）隔开</td> 
  </tr> 
 </tbody> 
</table>

示例：

@Transactional(value = "transactionManager", timeout = 5, rollbackFor = {RuntimeException.class, NullPointerException.class},
        readOnly = true, propagation = Propagation.NOT_SUPPORTED)
    public void b() {
        do something...
    }

### 3. 实现机制 ###

1.  spring默认使用AOP扫描被@Transactional的public方法，根据配置信息判断是否由TransactionInterceptor 进行拦截。
2.  TransactionInterceptor 进行拦截，在目标方法执行前创建事务，并执行目标方法。
3.  根据sql执行情况，利用抽象事务管理器AbstractPlatformTransactionManager 操作数据源DataSource ，执行提交或者回滚操作。  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dzazExMDM_size_16_color_FFFFFF_t_70_pic_center]

### 4. 问题重现 ###

该问题是spring的AOP自调用引起的，注意文字开头说明。

public class A {
        a() {
            b();
        }
        //声明事务
        @Transactional
        b() {
            sql操作
        }
    }

如果这个时候直接通过调用a()方法，那么在b()方法运行错误的时候，是不会回滚代码的。原因如下：  
类A会经过spring 中的AOP生成代理对象ProxyA

public class Proxy$A {
         A a = new A();
         
         a() {
             a.a();
         }
         
         b() {
            //开启事务
            startTransaction();
             a.b();
         }
         
    }

然后在运行的时候，是直接调用代理对象A（Proxy$A）中的a()方法，该a()方法直接调用原A类的a()方法，所以不会启动事务，最终导致事务失效。

### 5. 简单验证 ###

测试类

@RunWith(SpringJUnit4ClassRunner.class)
    @SpringBootTest(classes = ConfigApp.class)
    public class ATest {
    
        @Autowired
        private A a;
    
        @Test
        public void run() {
            System.out.println("test a is:" + a.getClass().getName());
            a.run2(a);
        }
    
    }

代理类

package com.t;
    
    import org.springframework.stereotype.Service;
    import org.springframework.transaction.annotation.Transactional;
    
    @Service
    public class A {
    
        @Transactional(rollbackFor = Exception.class)
        public void run1(A a) {
            System.out.println("run1 入参a:" + a.getClass().getName());
            System.out.println("run1 原a:" + this.getClass().getName());
        }
    
        public void run2(A a) {
            System.out.println("run2 入参a:" + a.getClass().getName());
            run1(a);
            System.out.println("run2 原a:" + this.getClass().getName());
        }
    
    }

结果输出

test a is:com.t.A$$EnhancerBySpringCGLIB$$c2ad1d54
    run2 入参a:com.t.A$$EnhancerBySpringCGLIB$$c2ad1d54
    run1 入参a:com.t.A$$EnhancerBySpringCGLIB$$c2ad1d54
    run1 原a:com.t.A
    run2 原a:com.t.A

结果简单说明  
类A被代理后，会在代理对象ProxyA中声明一个新的对象A，并将A中d对应的方法重新封装。当调用原A的方法时，流程就会变成 proxyA.a() -> a.a()

### 5. 解决方法 ###

*  第一种：将b()方法抽出来，重新声明一个类，并且该类交由spring管理控制。
 *  第二种：同时在a()上添加@Transactional注解或者在类上添加。
 *  第三种：在原A类中的a()方法，改为 **((A)AopContext.currentProxy).b()**

[https_www.ibm.com_developerworks_cn_java_j-master-spring-transactional-use_index.html]: https://www.ibm.com/developerworks/cn/java/j-master-spring-transactional-use/index.html
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dzazExMDM_size_16_color_FFFFFF_t_70_pic_center]: /images/20220412/0c7cdf2742964ab887c13d847ed0c177.png