寫(xiě)在前面：雖然使用注解方式配置事務(wù)控制很簡(jiǎn)單，用起來(lái)也很爽，但是在每個(gè)方法前都加上@xxx形式的注解，顯然并不美觀，也不利于代碼的規(guī)范與維護(hù)，所以XML的配置方式是才是重點(diǎn)。

基于注解的事務(wù)控制

基于注解配置事務(wù)控制，相較XML配置來(lái)說(shuō)更加簡(jiǎn)單，但仍需要XML提供依賴(lài)，不能完全擺脫XML。前期準(zhǔn)備工作和XML配置大同小異，這里不做贅述，建議學(xué)習(xí)基于注解配置前先學(xué)習(xí)XML配置事務(wù)控制。

這里給出本次測(cè)試的全部XML配置，具體細(xì)節(jié)在后面依次介紹。

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:context="http://www.springframework.org/schema/context"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
	xmlns:aop="http://www.springframework.org/schema/aop"
	xmlns:tx="http://www.springframework.org/schema/tx"
	xsi:schemaLocation="
		http://www.springframework.org/schema/beans 
		http://www.springframework.org/schema/beans/spring-beans.xsd
		http://www.springframework.org/schema/context
		http://www.springframework.org/schema/context/spring-context.xsd
		http://www.springframework.org/schema/aop
		http://www.springframework.org/schema/aop/spring-aop.xsd 
		http://www.springframework.org/schema/tx
		http://www.springframework.org/schema/tx/spring-tx.xsd ">
	<!-- 配置c3p0數(shù)據(jù)源 -->
	<bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
		<property name="driverClass" value="com.mysql.jdbc.Driver" />
		<property name="jdbcUrl" value="jdbc:mysql://localhost:3306/mybase2" />
		<property name="user" value="root" />
		<property name="password" value="Hudie" />
	</bean>
	
	<!-- 配置JdbcTemplate模板對(duì)象 -->
	<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
		<property name="dataSource" ref="dataSource"></property>
	</bean>
	<!-- 配置service層 -->
	<bean id="userService" class="com.gql.service.UserServiceImp">
		<property name="userDao" ref="userDao"></property>
	</bean>
	
	<!-- 配置dao層 -->
	<bean id="userDao" class="com.gql.dao.UserDaoImp">
		<property name="jdbcTemplate" ref="jdbcTemplate"></property>
	</bean>
	
	<!-- 事務(wù)管理器 -->
	<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
		<!-- 注入 DataSource-->
		<property name="dataSource" ref="dataSource"></property>
	</bean>
	<!-- 注解掃描器 -->
	<context:component-scan base-package="com.gql.service"></context:component-scan>
	<!-- 注解的事務(wù)配置 -->
	<tx:annotation-driven transaction-manager="transactionManager"/>
</beans>

1.配置事務(wù)管理器

 <!-- 事務(wù)管理器 -->
 <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
  <!-- 注入 DataSource-->
  <property name="dataSource" ref="dataSource"></property>
 </bean>

2.在業(yè)務(wù)層使用@Transactional 注解

只需要在業(yè)務(wù)層實(shí)現(xiàn)類(lèi)上加上@Transactional即可。

該注解的屬性和 xml 中的屬性含義一致。該注解可以出現(xiàn)在接口上，類(lèi)上和方法上。

• 出現(xiàn)接口上，表示該接口的所有實(shí)現(xiàn)類(lèi)都有事務(wù)支持。
• 出現(xiàn)在類(lèi)上，表示類(lèi)中所有方法有事務(wù)支持
• 出現(xiàn)在方法上，表示方法有事務(wù)支持。
• 以上三個(gè)位置的優(yōu)先級(jí)：方法>類(lèi)>接口

package com.gql.service;
import java.util.List;
import org.springframework.transaction.annotation.Transactional;
import com.gql.dao.UserDao;
import com.gql.entity.User;
/**
 * 類(lèi)說(shuō)明:
 *		業(yè)務(wù)層實(shí)現(xiàn)類(lèi)
 * @guoqianliang1998.
 */
@Transactional
public class UserServiceImp implements UserService {
	private UserDao userDao;
	
	public void setUserDao(UserDao userDao) {
		this.userDao = userDao;
	}
	@Override
	public void save(User user) {
		userDao.save(user);
		int i = 1/0;
	}
	@Override
	public void update(int id, User user) {
		userDao.update(id, user);
	}
	@Override
	public void delete(int id) {
		userDao.delete(id);
	}
	@Override
	public User getUser(int id) {
		User user = userDao.getUser(id);
		return user;
	}
	@Override
	public List<User> getUserList(int[] ids) {
		List<User> userList = userDao.getUserList(ids);
		return userList;
	}
	@Override
	public List<User> getUserList() {
		List<User> list = userDao.getUserList();
		return list;
	}
}

3.開(kāi)啟 spring 對(duì)注解事務(wù)的支持

<!-- 開(kāi)啟 spring 對(duì)注解事務(wù)的支持 -->
 <tx:annotation-driven transaction-manager="transactionManager"/>

4.注解掃描器

<!-- 注解掃描器 -->
 <context:component-scan base-package="com.gql.service"></context:component-scan>

Spring 注解事務(wù)實(shí)現(xiàn)機(jī)制

1.事務(wù)的實(shí)現(xiàn)機(jī)制

AOP動(dòng)態(tài)代理進(jìn)行方法攔截

在應(yīng)用系統(tǒng)調(diào)用聲明@Transactional 的目標(biāo)方法時(shí)，Spring Framework 默認(rèn)使用 AOP 代理，在代碼運(yùn)行時(shí)生成一個(gè)代理對(duì)象，根據(jù)@Transactional 的屬性配置信息，這個(gè)代理對(duì)象決定該聲明@Transactional 的目標(biāo)方法是否由攔截器 TransactionInterceptor 來(lái)使用攔截。

在 TransactionInterceptor 攔截時(shí)，會(huì)在在目標(biāo)方法開(kāi)始執(zhí)行之前創(chuàng)建并加入事務(wù)，并執(zhí)行目標(biāo)方法的邏輯, 最后根據(jù)執(zhí)行情況是否出現(xiàn)異常，利用抽象事務(wù)管理器AbstractPlatformTransactionManager 操作數(shù)據(jù)源 DataSource 提交或回滾事務(wù), 如下圖所示。

注：上面兩個(gè)xxxServiceImpl，表示的是同一個(gè)service的調(diào)用，前面用虛線(xiàn)，表示欲調(diào)用該service的方法，進(jìn)入該service的方法前經(jīng)歷了aop進(jìn)行攔截，然后才真正進(jìn)入該service方法（后面的實(shí)線(xiàn)表示的service）

Spring AOP 代理有 CglibAopProxy 和 JdkDynamicAopProxy 兩種，上圖是以 CglibAopProxy 為例

• 對(duì)于 CglibAopProxy，需要調(diào)用其內(nèi)部類(lèi)的 DynamicAdvisedInterceptor 的 intercept 方法。
• 對(duì)于 JdkDynamicAopProxy，需要調(diào)用其 invoke 方法。

事務(wù)管理器進(jìn)行事務(wù)提交或回滾

事務(wù)管理的框架是由抽象事務(wù)管理器 AbstractPlatformTransactionManager 來(lái)提供的，而具體的底層事務(wù)處理實(shí)現(xiàn)，由 PlatformTransactionManager 的具體實(shí)現(xiàn)類(lèi)來(lái)實(shí)現(xiàn)，如事務(wù)管理器 DataSourceTransactionManager。

不同的事務(wù)管理器管理不同的數(shù)據(jù)資源 DataSource，比如 DataSourceTransactionManager 管理 JDBC 的 Connection。

PlatformTransactionManager，AbstractPlatformTransactionManager 及具體實(shí)現(xiàn)類(lèi)關(guān)系如圖 2 所示。

2.注解方式的事務(wù)使用注意事項(xiàng)

當(dāng)您對(duì) Spring 的基于注解方式的實(shí)現(xiàn)步驟和事務(wù)內(nèi)在實(shí)現(xiàn)機(jī)制有較好的理解之后，就會(huì)更好的使用注解方式的事務(wù)管理，避免當(dāng)系統(tǒng)拋出異常，數(shù)據(jù)不能回滾的問(wèn)題。

正確的設(shè)置 @Transactional 的 propagation 屬性（熟知事務(wù)的傳播特性）

需要注意下面三種 propagation 可以不啟動(dòng)事務(wù)。本來(lái)期望目標(biāo)方法進(jìn)行事務(wù)管理，但若是錯(cuò)誤的配置這三種 propagation，事務(wù)將不會(huì)發(fā)生回滾。

• TransactionDefinition.PROPAGATION_SUPPORTS：如果當(dāng)前存在事務(wù)，則加入該事務(wù)；如果當(dāng)前沒(méi)有事務(wù)，則以非事務(wù)的方式繼續(xù)運(yùn)行。
• TransactionDefinition.PROPAGATION_NOT_SUPPORTED：以非事務(wù)方式運(yùn)行，如果當(dāng)前存在事務(wù)，則把當(dāng)前事務(wù)掛起。
• TransactionDefinition.PROPAGATION_NEVER：以非事務(wù)方式運(yùn)行，如果當(dāng)前存在事務(wù)，則拋出異常。

正確的設(shè)置 @Transactional 的 rollbackFor 屬性

默認(rèn)情況下，如果在事務(wù)中拋出了未檢查異常（繼承自 RuntimeException 的異常）或者 Error，則 Spring 將回滾事務(wù)；除此之外，Spring 不會(huì)回滾事務(wù)。

如果在事務(wù)中拋出其他類(lèi)型的異常，并期望 Spring 能夠回滾事務(wù)，可以指定 rollbackFor。

例：@Transactional(propagation= Propagation.REQUIRED,rollbackFor= MyException.class)

通過(guò)分析 Spring 源碼可以知道，若在目標(biāo)方法中拋出的異常是 rollbackFor 指定的異常的子類(lèi)，事務(wù)同樣會(huì)回滾。

清單 3. RollbackRuleAttribute 的 getDepth 方法

private int getDepth(Class<?> exceptionClass, int depth) {
        if (exceptionClass.getName().contains(this.exceptionName)) {
            // Found it!
            return depth;
}
        // If we've gone as far as we can go and haven't found it...
        if (exceptionClass == Throwable.class) {
            return -1;
}
return getDepth(exceptionClass.getSuperclass(), depth + 1);
}

@Transactional 只能應(yīng)用到 public 方法才有效

只有@Transactional 注解應(yīng)用到 public 方法，才能進(jìn)行事務(wù)管理。

這是因?yàn)樵谑褂?Spring AOP 代理時(shí)，Spring 在調(diào)用TransactionInterceptor 在目標(biāo)方法執(zhí)行前后進(jìn)行攔截之前，DynamicAdvisedInterceptor（CglibAopProxy 的內(nèi)部類(lèi)）的intercept 方法或 JdkDynamicAopProxy 的 invoke 方法會(huì)間接調(diào)用 AbstractFallbackTransactionAttributeSource（Spring 通過(guò)這個(gè)類(lèi)獲取@Transactional 注解的事務(wù)屬性配置屬性信息）的 computeTransactionAttribute 方法。

AbstractFallbackTransactionAttributeSource

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

allowPublicMethodsOnly方法由子類(lèi)AnnotationTransactionAttributeSource實(shí)現(xiàn)，該子類(lèi)方法中默認(rèn)是true，所以當(dāng)你加了事務(wù)注解的方法不是public時(shí)，該方法直接返回null

不會(huì)獲取@Transactional 的屬性配置信息，最終會(huì)造成不會(huì)用 TransactionInterceptor 來(lái)攔截該目標(biāo)方法進(jìn)行事務(wù)管理。

避免 Spring 的 AOP 的自調(diào)用問(wèn)題，必須要跨service調(diào)用

在 Spring 的 AOP 代理下，只有目標(biāo)方法由外部調(diào)用（也就是跨service調(diào)用），目標(biāo)方法才由 Spring 生成的代理對(duì)象來(lái)管理，這會(huì)造成自調(diào)用問(wèn)題。

若同一類(lèi)中的其他沒(méi)有@Transactional 注解的方法內(nèi)部調(diào)用有@Transactional 注解的方法，有@Transactional 注解的方法的事務(wù)被忽略，不會(huì)發(fā)生回滾。

示例：

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

insertOrder 盡管有@Transactional 注解，但它被內(nèi)部方法 insert 調(diào)用，事務(wù)被忽略，出現(xiàn)異常事務(wù)不會(huì)發(fā)生回滾。

事務(wù)的傳播問(wèn)題PROPAGATION_REQUIRES_NEW只有在跨service時(shí)才會(huì)有效（也是上面自調(diào)用引起的）

class ServiceA{
  @Transactional(rollbackFor = Exception.class)
  public methodA1(){
     ......
     //該方式，methodA2上的事務(wù)注解不起作用，不會(huì)開(kāi)啟新的事務(wù)，methodA2與methodA1中的數(shù)據(jù)一起提交或回滾
     1.this.methodA2();
     //該方式，methodB1上的事務(wù)會(huì)啟作用
     2.ServiceB.methodB1()
     ......
  };
  @Transactional(propagation = Propagation.REQUIRES_NEW, rollbackFor = Exception.class)
  public methodA2(){
     ......
  };
}
 
class ServiceB{
  @Transactional(propagation = Propagation.REQUIRES_NEW, rollbackFor = Exception.class)
  public methodB1(){
     ......
  };  
}

原因在于，跨Service調(diào)用方法時(shí)，都會(huì)經(jīng)過(guò)org.springframework.aop.framework.CglibAopProxy.DynamicAdvisedInterceptor.intercept()方法，只有經(jīng)過(guò)此處，才能對(duì)事務(wù)進(jìn)行控制。

參考：https://developer.ibm.com/zh/articles/j-master-spring-transactional-use/

以上為個(gè)人經(jīng)驗(yàn)，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。

最新評(píng)論