溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊(cè)×
其他方式登錄
點(diǎn)擊 登錄注冊(cè) 即表示同意《億速云用戶服務(wù)條款》

Spring框架中注解配置事務(wù)控制的示例分析

發(fā)布時(shí)間:2021-09-15 16:49:51 來(lái)源:億速云 閱讀:148 作者:小新 欄目:開(kāi)發(fā)技術(shù)

這篇文章主要為大家展示了“Spring框架中注解配置事務(wù)控制的示例分析”,內(nèi)容簡(jiǎn)而易懂,條理清晰,希望能夠幫助大家解決疑惑,下面讓小編帶領(lǐng)大家一起研究并學(xué)習(xí)一下“Spring框架中注解配置事務(wù)控制的示例分析”這篇文章吧。

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

基于注解配置事務(wù)控制,相較XML配置來(lái)說(shuō)更加簡(jiǎn)單,但仍需要XML提供依賴,不能完全擺脫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)類上加上@Transactional即可。

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

  • 出現(xiàn)接口上,表示該接口的所有實(shí)現(xiàn)類都有事務(wù)支持。

  • 出現(xiàn)在類上,表示類中所有方法有事務(wù)支持

  • 出現(xiàn)在方法上,表示方法有事務(wù)支持。

  • 以上三個(gè)位置的優(yōu)先級(jí):方法>類>接口

package com.gql.service;
import java.util.List;
import org.springframework.transaction.annotation.Transactional;
import com.gql.dao.UserDao;
import com.gql.entity.User;
/**
 * 類說(shuō)明:
 *		業(yè)務(wù)層實(shí)現(xiàn)類
 * @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ù), 如下圖所示。

Spring框架中注解配置事務(wù)控制的示例分析

Spring框架中注解配置事務(wù)控制的示例分析

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

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

  • 對(duì)于 CglibAopProxy,需要調(diào)用其內(nè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)實(shí)現(xiàn),如事務(wù)管理器 DataSourceTransactionManager。

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

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

Spring框架中注解配置事務(wù)控制的示例分析

Spring框架中注解配置事務(wù)控制的示例分析

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ù)中拋出其他類型的異常,并期望 Spring 能夠回滾事務(wù),可以指定 rollbackFor。

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

通過(guò)分析 Spring 源碼可以知道,若在目標(biāo)方法中拋出的異常是 rollbackFor 指定的異常的子類,事務(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)部類)的intercept 方法或 JdkDynamicAopProxy 的 invoke 方法會(huì)間接調(diào)用 AbstractFallbackTransactionAttributeSource(Spring 通過(guò)這個(gè)類獲取@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方法由子類AnnotationTransactionAttributeSource實(shí)現(xiàn),該子類方法中默認(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)題。

若同一類中的其他沒(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)行控制。

以上是“Spring框架中注解配置事務(wù)控制的示例分析”這篇文章的所有內(nèi)容,感謝各位的閱讀!相信大家都有了一定的了解,希望分享的內(nèi)容對(duì)大家有所幫助,如果還想學(xué)習(xí)更多知識(shí),歡迎關(guān)注億速云行業(yè)資訊頻道!

向AI問(wèn)一下細(xì)節(jié)

免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。

AI