Spring @Transactional 深度解析

﹏ヽ暗。殇╰゛Y 2023-07-04 11:25 18阅读 0赞

**事物注解方式: @Transactional**

当标于类前时, 标示类中所有方法都进行事物处理 , 例子:

1 @Transactional public class TestServiceBean implements TestService {}

**当类中某些方法不需要事物时:**

1 @Transactional  
     2 public class TestServiceBean implements TestService { 
     3     private TestDao dao; 
     4     public void setDao(TestDao dao) { 
     5         this.dao = dao; 
     6     } 
     7     @Transactional(propagation =Propagation.NOT_SUPPORTED)
     8     public List getAll() { 
     9         return null; 
    10     } 
    11 }

**事物传播行为介绍:**

@Transactional(propagation=Propagation.REQUIRED) ：如果有事务, 那么加入事务, 没有的话新建一个(默认情况下)  
　　@Transactional(propagation=Propagation.NOT\_SUPPORTED) ：容器不为这个方法开启事务  
　　@Transactional(propagation=Propagation.REQUIRES\_NEW) ：不管是否存在事务,都创建一个新的事务,原来的挂起,新的执行完毕,继续执行老的事务  
　　@Transactional(propagation=Propagation.MANDATORY) ：必须在一个已有的事务中执行,否则抛出异常  
　　@Transactional(propagation=Propagation.NEVER) ：必须在一个没有的事务中执行,否则抛出异常(与Propagation.MANDATORY相反)  
　　@Transactional(propagation=Propagation.SUPPORTS) ：如果其他bean调用这个方法,在其他bean中声明事务,那就用事务.如果其他bean没有声明事务,那就不用事务.

**事物超时设置:**

**　**　@Transactional(timeout=30) //默认是30秒

**事务隔离级别:**

@Transactional(isolation = Isolation.READ\_UNCOMMITTED)：读取未提交数据(会出现脏读, 不可重复读) 基本不使用  
　　@Transactional(isolation = Isolation.READ\_COMMITTED)：读取已提交数据(会出现不可重复读和幻读)  
　　@Transactional(isolation = Isolation.REPEATABLE\_READ)：可重复读(会出现幻读)  
　　@Transactional(isolation = Isolation.SERIALIZABLE)：串行化

MYSQL: 默认为REPEATABLE\_READ级别  
　　SQLSERVER: 默认为READ\_COMMITTED

**脏读** : 一个事务读取到另一事务未提交的更新数据  
**不可重复读** : 在同一事务中, 多次读取同一数据返回的结果有所不同, 换句话说,   
后续读取可以读到另一事务已提交的更新数据. 相反, "可重复读"在同一事务中多次  
读取数据时, 能够保证所读数据一样, 也就是后续读取不能读到另一事务已提交的更新数据  
**幻读** : 一个事务读到另一个事务已提交的insert数据

**@Transactional注解中常用参数说明**

<table> 
 <tbody> 
 <tr> 
 <td> 参数名称 </td> 
 <td> 功能描述 </td> 
 </tr> 
 <tr> 
 <td> readOnly </td> 
 <td> 该属性用于设置当前事务是否为只读事务，设置为true表示只读，false则表示可读写，默认值为false。例如：@Transactional(readOnly=true) </td> 
 </tr> 
 <tr> 
 <td> rollbackFor </td> 
 <td> 该属性用于设置需要进行回滚的异常类数组，当方法中抛出指定异常数组中的异常时，则进行事务回滚。例如： 指定单一异常类：@Transactional(rollbackFor=RuntimeException.class) 指定多个异常类：@Transactional(rollbackFor={RuntimeException.class, Exception.class}) </td> 
 </tr> 
 <tr> 
 <td> rollbackForClassName </td> 
 <td> 该属性用于设置需要进行回滚的异常类名称数组，当方法中抛出指定异常名称数组中的异常时，则进行事务回滚。例如： 指定单一异常类名称：@Transactional(rollbackForClassName="RuntimeException") 指定多个异常类名称：@Transactional(rollbackForClassName={"RuntimeException","Exception"}) </td> 
 </tr> 
 <tr> 
 <td> noRollbackFor </td> 
 <td> 该属性用于设置不需要进行回滚的异常类数组，当方法中抛出指定异常数组中的异常时，不进行事务回滚。例如： 指定单一异常类：@Transactional(noRollbackFor=RuntimeException.class) 指定多个异常类：@Transactional(noRollbackFor={RuntimeException.class, Exception.class}) </td> 
 </tr> 
 <tr> 
 <td> noRollbackForClassName </td> 
 <td> 该属性用于设置不需要进行回滚的异常类名称数组，当方法中抛出指定异常名称数组中的异常时，不进行事务回滚。例如： 指定单一异常类名称：@Transactional(noRollbackForClassName="RuntimeException") 指定多个异常类名称： @Transactional(noRollbackForClassName={"RuntimeException","Exception"}) </td> 
 </tr> 
 <tr> 
 <td> propagation </td> 
 <td> 该属性用于设置事务的传播行为，具体取值可参考表6-7。 例如：@Transactional(propagation=Propagation.NOT_SUPPORTED,readOnly=true) </td> 
 </tr> 
 <tr> 
 <td> isolation </td> 
 <td> 该属性用于设置底层数据库的事务隔离级别，事务隔离级别用于处理多事务并发的情况，通常使用数据库的默认隔离级别即可，基本不需要进行设置 </td> 
 </tr> 
 <tr> 
 <td> timeout </td> 
 <td> 该属性用于设置事务的超时秒数，默认值为-1表示永不超时 </td> 
 </tr> 
 </tbody> 
</table>

**注意的几点:**

1、@Transactional 只能被应用到public方法上, 对于其它非public的方法,如果标记了@Transactional也不会报错,但方法没有事务功能.  
  
　　2、用 spring 事务管理器,由spring来负责数据库的打开,提交,回滚.默认遇到运行期例外(throw new RuntimeException("注释");)会回滚，即遇到不受检查（unchecked）的例外时回滚；而遇到需要捕获的例外(throw new Exception("注释");)不会回滚,即遇到受检查的例外（就是非运行时抛出的异常，编译器会检查到的异常叫受检查例外或说受检查异常）时，需我们指定方式来让事务回滚要想所有异常都回滚,要加上 @Transactional( rollbackFor=\{Exception.class,其它异常\}) .如果让unchecked例外不回滚： @Transactional(notRollbackFor=RunTimeException.class)  
如下:

1 @Transactional(rollbackFor=Exception.class) //指定回滚,遇到异常Exception时回滚
    2 public void methodName() {
    3 　　　throw new Exception("注释");
    4 }
    5 @Transactional(noRollbackFor=Exception.class)//指定不回滚,遇到运行期例外(throw new RuntimeException("注释");)会回滚
    6 public ItimDaoImpl getItemDaoImpl() {
    7 　　　throw new RuntimeException("注释");
    8 }

3、@Transactional 注解应该只被应用到 public 可见度的方法上。 如果你在 protected、private 或者 package-visible 的方法上使用 @Transactional 注解，它也不会报错， 但是这个被注解的方法将不会展示已配置的事务设置。

4、@Transactional 注解可以被应用于接口定义和接口方法、类定义和类的 public 方法上。然而，请注意仅仅 @Transactional 注解的出现不足于开启事务行为，它仅仅 是一种元数据，能够被可以识别 @Transactional 注解和上述的配置适当的具有事务行为的beans所使用。上面的例子中，其实正是 元素的出现 开启 了事务行为。

5、Spring团队的建议是你在具体的类（或类的方法）上使用 @Transactional 注解，而不要使用在类所要实现的任何接口上。你当然可以在接口上使用 @Transactional 注解，但是这将只能当你设置了基于接口的代理时它才生效。因为注解是不能继承的，这就意味着如果你正在使用基于类的代理时，那么事务的设置将不能被基于类的代理所识别，而且对象也将不会被事务代理所包装（将被确认为严重的）。因此，请接受Spring团队的建议并且在具体的类上使用 @Transactional 注解。

# 注意：  #

## spring 事务处理中，同一个类中:A方法（无事务）调B方法（有事务）,事务不生效问题 ##

问题： 同一个类的不同方法,A方法没有@Transactional，B方法有@Transactional,A调用B方法，事务不起作用

**方法A:无事务控制**

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzM4MDI3NjU2_size_16_color_FFFFFF_t_70][]

**方法B:有事务控制**

![20181117183332207.png][]

**原因：在一个Service内部，事务方法之间的嵌套调用，普通方法和事务方法之间的嵌套调用，都不会开启新的事务.是因为spring采用动态代理机制来实现事务控制，而动态代理最终都是要调用原始对象的，而原始对象在去调用方法时，是不会再触发代理了！**

**下面是解决方案:**

1.把方法B抽离到另外一个XXService中去,并且在这个Service中注入XXService,使用XXService调用方法B;

显然,这种方式一点也不优雅,且要产生很多冗余文件,看起来很烦,实际开发中也几乎没人这么做吧?.反正我不建议采用此方案;

2.通过在方法内部获得当前类代理对象的方式,通过代理对象调用方法B

上面说了:动态代理最终都是要调用原始对象的，而原始对象在去调用方法时，是不会再触发代理了！

所以我们就使用代理对象来调用,就会触发事务;

综上解决方案,我觉得第二种方式方便. 那怎么获取代理对象呢? 这里提供两种方式:

1.使用 ApplicationContext 上下文对象获取该对象;

2.使用 AopContext.currentProxy() 获取代理对象,但是需要配置exposeProxy=true

这里使用的是第二种解决方案,具体操作如下:

springboot启动类加上注解:@EnableAspectJAutoProxy(exposeProxy = true)

![20181117185337876.png][]

方法内部获取代理对象调用方法

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzM4MDI3NjU2_size_16_color_FFFFFF_t_70 1][]

完了后再测试,数据顺利回滚,至此,问题得到解决!

建议封装工具类

import org.springframework.aop.framework.AopContext;
 
 /**
 * @author 
 * @date 2019-04-08
 * @since v1.0.0
 */
 public class AopUtils {
 
 private AopUtils() {}
 
 @SuppressWarnings("unchecked")
 public static <T> T getAopProxyInstance(T t) {
 try {
 return (T)AopContext.currentProxy();
 } catch (IllegalStateException e) {
 return t;
 }
 }
 
 }

在service内部调用：

AopUtils.getAopProxyInstance(this). 添加事务回滚方法（接口B）

==========================================================

### @Transactional 只能应用到 public 方法才有效 ###

只有@Transactional 注解应用到 public 方法，才能进行事务管理。这是因为在使用 Spring AOP 代理时，Spring 在调用在图 1 中的 TransactionInterceptor 在目标方法执行前后进行拦截之前，DynamicAdvisedInterceptor（CglibAopProxy 的内部类）的的 intercept 方法或 JdkDynamicAopProxy 的 invoke 方法会间接调用 AbstractFallbackTransactionAttributeSource（Spring 通过这个类获取表 1. @Transactional 注解的事务属性配置属性信息）的 computeTransactionAttribute 方法。

清单 6. AbstractFallbackTransactionAttributeSource

> protected TransactionAttribute computeTransactionAttribute(Method method,
>  Class<?> targetClass) {
>      // Don't allow no-public methods as required.
>      if (allowPublicMethodsOnly() && !Modifier.isPublic(method.getModifiers())) {
> return null;
>     }
> }

这个方法会检查目标方法的修饰符是不是 public，若不是 public，就不会获取@Transactional 的属性配置信息，最终会造成不会用 TransactionInterceptor 来拦截该目标方法进行事务管理。

### 避免 Spring 的 AOP 的自调用问题 ###

在 Spring 的 AOP 代理下，只有目标方法由外部调用，目标方法才由 Spring 生成的代理对象来管理，这会造成自调用问题。若同一类中的其他没有@Transactional 注解的方法内部调用有@Transactional 注解的方法，有@Transactional 注解的方法的事务被忽略，不会发生回滚。见清单 7 举例代码展示。

清单 7.自调用问题举例

>     @Service
>     public class OrderService {
>       private void insert() {
>      insertOrder();
>     }
>     
>     
>     
>       @Transactional
>       public void insertOrder() {
>           //insert log info
>           //insertOrder
>           //updateAccount
>      }
>     }

insertOrder 尽管有@Transactional 注解，但它被内部方法 insert 调用，事务被忽略，出现异常事务不会发生回滚。

上面的两个问题@Transactional 注解只应用到 public 方法和自调用问题，是由于使用 Spring AOP 代理造成的。为解决这两个问题，使用 AspectJ 取代 Spring AOP 代理。

需要将下面的 AspectJ 信息添加到 xml 配置信息中，或者指定注解EnableTransactionManagement的属性。

AspectJ 的 xml 配置信息

> <tx:annotation-driven mode="aspectj" />
> <bean id="transactionManager"
> class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
> <property name="dataSource" ref="dataSource" />
> </bean>
> <bean
> class="org.springframework.transaction.aspectj.AnnotationTransactionAspect"
> factory-method="aspectOf">
> <property name="transactionManager" ref="transactionManager" />
> </bean>

AspectJ 的 JavaConfig配置信息

>     @EnableTransactionManagement(mode = AdviceMode.ASPECTJ, proxyTargetClass = true)
>     public class Application {
>     }

同时在 Maven 的 pom 文件中加入 spring-aspects 和 aspectjrt 的 dependency 以及 aspectj-maven-plugin。

AspectJ 的 pom 配置信息

>      <dependency>
>          <groupId>org.springframework</groupId>
>          <artifactId>spring-aspects</artifactId>
>          <version>4.3.2.RELEASE</version>
>      </dependency>
>      <dependency>
>          <groupId>org.aspectj</groupId>
>          <artifactId>aspectjrt</artifactId>
>          <version>1.8.9</version>
>      </dependency>
>          <plugin>
>              <groupId>org.codehaus.mojo</groupId>
>              <artifactId>aspectj-maven-plugin</artifactId>
>              <version>1.9</version>
>              <configuration>
>                  <showWeaveInfo>true</showWeaveInfo>
>                  <aspectLibraries>
>                      <aspectLibrary>
>                          <groupId>org.springframework</groupId>
>                          <artifactId>spring-aspects</artifactId>
>                      </aspectLibrary>
>                  </aspectLibraries>
>              </configuration>
>              <executions>
>                  <execution>
>                      <goals>
>                          <goal>compile</goal>
>                          <goal>test-compile</goal>
>                      </goals>
>                  </execution>
>              </executions>
>          </plugin>

————————————————

目前实现AOP的技术：AspectJ和Spring AOP，这两个的核心区别：

1）AspectJ需要用到额外的编译器，这个比较麻烦，需要在工程外处理，不易于移植。AOP是在jdk基础上实现了，不用额外添加jdk外的执行文件。

2）因为是编译器期执行，在运行时没有开销，所以性能上AspectJ肯定是强于AOP的。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96eWM4OC5ibG9nLmNzZG4ubmV0_size_16_color_FFFFFF_t_70][]

**Spring AOP的实现方式**

Spring AOP实现主要是通过代理类的方式实现，有jdk代理和CGLIB代理两种方式，

1）CGLIB介绍：https://blog.csdn.net/danchu/article/details/70238002

2）CGLIB和Java动态代理的区别

2.1）Java动态代理只能够对接口进行代理，不能对普通的类进行代理（因为所有生成的代理类的父类为Proxy，Java类继承机制不允许多重继承）；CGLIB能够代理普通类；

2.2）Java动态代理使用Java原生的反射API进行操作，在生成类上比较高效；CGLIB使用ASM框架直接对字节码进行操作，在类的执行过程中比较高效

3）Spring AOP默认的使用方式：

如果目标对象没有实现接口，则默认会采用CGLIB代理；

如果目标对象实现了接口，默认会采用Java动态代理；

Spring AOP 代理有 CglibAopProxy 和 JdkDynamicAopProxy 两种，以 CglibAopProxy 为例，对于 CglibAopProxy，需要调用其内部类的 DynamicAdvisedInterceptor 的 intercept 方法。对于 JdkDynamicAopProxy，需要调用其 invoke 方法。

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzM4MDI3NjU2_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20181117182421347.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzM4MDI3NjU2,size_16,color_FFFFFF,t_70
[20181117183332207.png]: https://img-blog.csdnimg.cn/20181117183332207.png
[20181117185337876.png]: https://img-blog.csdnimg.cn/20181117185337876.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzM4MDI3NjU2_size_16_color_FFFFFF_t_70 1]: https://img-blog.csdnimg.cn/20181117185508123.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L20wXzM4MDI3NjU2,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96eWM4OC5ibG9nLmNzZG4ubmV0_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20200210174211252.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly96eWM4OC5ibG9nLmNzZG4ubmV0,size_16,color_FFFFFF,t_70