Spring事務原理分析-部分二

時間  2019-12-10
標籤 spring 事務 原理 分析 部分 欄目 Spring 简体版
原文   原文鏈接

Spring事務原理分析-部分二

說明：這是我在螞蟻課堂學習了餘老師Spring手寫框架的課程的一些筆記，部分代碼代碼會用到餘老師的課件代碼。這不是廣告，是我聽了以後以爲很好。java

課堂連接：Spring手寫框架mysql

手寫Spring事務框架

編程事務實現

概述

所謂編程式事務指的是經過編碼方式實現事務，即相似於JDBC編程實現事務管理。管理使用TransactionTemplate或者直接使用底層的PlatformTransactionManager。對於編程式事務管理，spring推薦使用TransactionTemplate。spring

使用編程事務實現手動事務

使用編程事務實現，手動事務 begin、commit、rollbacksql

@Component
public class TransactionUtils {

	@Autowired
	private DataSourceTransactionManager dataSourceTransactionManager;

	// 開啓事務
	public TransactionStatus begin() {
		TransactionStatus transaction = dataSourceTransactionManager.getTransaction(new DefaultTransactionAttribute());
		return transaction;
	}

	// 提交事務
	public void commit(TransactionStatus transactionStatus) {
		dataSourceTransactionManager.commit(transactionStatus);
	}

	// 回滾事務
	public void rollback(TransactionStatus transactionStatus) {
		dataSourceTransactionManager.rollback(transactionStatus);
	}
}

@Service
public class UserService {
	@Autowired
	private UserDao userDao;
	@Autowired
	private TransactionUtils transactionUtils;

	public void add() {
		TransactionStatus transactionStatus = null;
		try {
			transactionStatus = transactionUtils.begin();
			userDao.add("wangmazi", 27);
			int i = 1 / 0;
			System.out.println("我是add方法");
			userDao.add("zhangsan", 16);
			transactionUtils.commit(transactionStatus);
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			if (transactionStatus != null) {
				transactionStatus.rollbackToSavepoint(transactionStatus);
			}
		}

	}

}

複製代碼

AOP技術封裝手動事務

@Component
@Aspect
public class AopTransaction {
	@Autowired
	private TransactionUtils transactionUtils;

	// // 異常通知
	@AfterThrowing("execution(* com.itmayiedu.service.UserService.add(..))")
	public void afterThrowing() {
		System.out.println("程序已經回滾");
		// 獲取程序當前事務 進行回滾
		TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
	}

	// 環繞通知
	@Around("execution(* com.itmayiedu.service.UserService.add(..))")
	public void around(ProceedingJoinPoint proceedingJoinPoint) throws Throwable {
		System.out.println("開啓事務");
		TransactionStatus begin = transactionUtils.begin();
		proceedingJoinPoint.proceed();
		transactionUtils.commit(begin);
		System.out.println("提交事務");
	}

}

複製代碼

使用事務注意事項

事務是程序運行若是沒有錯誤,會自動提交事物,若是程序運行發生異常,則會自動回滾。編程

若是使用了try捕獲異常時.必定要在catch裏面手動回滾。安全

事務手動回滾代碼框架

TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
複製代碼

聲明事務實現

概述

管理創建在AOP之上的。其本質是對方法先後進行攔截，而後在目標方法開始以前建立或者加入一個事務，在執行完目標方法以後根據執行狀況提交或者回滾事務。聲明式事務最大的優勢就是不須要經過編程的方式管理事務，這樣就不須要在業務邏輯代碼中摻瑣事務管理的代碼，只需在配置文件中作相關的事務規則聲明(或經過基於@Transactional註解的方式)，即可以將事務規則應用到業務邏輯中。ide

​ 顯然聲明式事務管理要優於編程式事務管理，這正是spring倡導的非侵入式的開發方式。工具

聲明式事務管理使業務代碼不受污染，一個普通的POJO對象，只要加上註解就能夠得到徹底的事務支持。和編程式事務相比，聲明式事務惟一不足地方是，後者的最細粒度只能做用到方法級別，沒法作到像編程式事務那樣能夠做用到代碼塊級別。可是即使有這樣的需求，也存在不少變通的方法，好比，能夠將須要進行事務管理的代碼塊獨立爲方法等等。學習

XML實現聲明

註解版本聲明

<beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:p="http://www.springframework.org/schema/p" xmlns:context="http://www.springframework.org/schema/context" 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">


	<!-- 開啓註解 -->
	<context:component-scan base-package="com.itmayiedu"></context:component-scan>
	<!-- 1. 數據源對象: C3P0鏈接池 -->
	<bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
		<property name="driverClass" value="com.mysql.jdbc.Driver"></property>
		<property name="jdbcUrl" value="jdbc:mysql://localhost:3306/test"></property>
		<property name="user" value="root"></property>
		<property name="password" value="root"></property>
	</bean>

	<!-- 2. JdbcTemplate工具類實例 -->
	<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
		<property name="dataSource" ref="dataSource"></property>
	</bean>

	<!-- 配置事物 -->
	<bean id="dataSourceTransactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
		<property name="dataSource" ref="dataSource"></property>
	</bean>
	<!-- 開啓註解事物 -->
	<tx:annotation-driven transaction-manager="dataSourceTransactionManager" />
</beans>

複製代碼

用法

@Transactional
	public void add() {
		userDao.add("wangmazi", 27);
		int i = 1 / 0;
		System.out.println("我是add方法");
		userDao.add("zhangsan", 16);
	}

複製代碼

手寫Spring註解版本事務

註解

Jdk1.5新增新技術，註解。不少框架爲了簡化代碼，都會提供有些註解。能夠理解爲插件，是代碼級別的插件，在類的方法上寫：@XXX，就是在代碼上插入了一個插件。

註解不會也不能影響代碼的實際邏輯，僅僅起到輔助性的做用。

註解分類：內置註解(也成爲元註解 jdk 自帶註解)、自定義註解（Spring框架）

什麼是內置註解

（1） @SuppressWarnings 再程序前面加上能夠在javac編譯中去除警告--階段是SOURCE （2） @Deprecated 帶有標記的包，方法，字段說明其過期----階段是SOURCE （3）@Overricle 打上這個標記說明該方法是將父類的方法重寫--階段是SOURCE

@Overricle 案例演示
@Override
	public String toString() {
		return null;
	}

複製代碼
@Deprecated案例演示
new Date().parse("");
複製代碼
@SuppressWarnings 案例演示
@SuppressWarnings({ "all" })
	public void save() {
		java.util.List list = new ArrayList();
	}

複製代碼
實現自定義註解

元註解的做用就是負責註解其餘註解。Java5.0定義了4個標準的meta-annotation類型，它們被用來提供對其它 annotation類型做說明。Java5.0定義的元註解： @Target

@Target說明了Annotation所修飾的對象範圍：Annotation可被用於 packages、types（類、接口、枚舉、Annotation類型）、類型成員（方法、構造方法、成員變量、枚舉值）、方法參數和本地變量（如循環變量、catch參數）。在Annotation類型的聲明中使用了target可更加明晰其修飾的目標。

\1. CONSTRUCTOR:用於描述構造器

\2. FIELD:用於描述域

\3. LOCAL_VARIABLE:用於描述局部變量

\4. METHOD:用於描述方法

\5. PACKAGE:用於描述包

\6. PARAMETER:用於描述參數

\7. TYPE:用於描述類、接口(包括註解類型) 或enum聲明

2.@Retention

表示須要在什麼級別保存該註釋信息，用於描述註解的生命週期（即：被描述的註解在什麼範圍內有效） 3.@Documented 4.@Inherited

使用@interface 定義註解。

@Target(value = { ElementType.METHOD })
@Retention(RetentionPolicy.RUNTIME)
public @interface AddAnnotation {

	int userId() default t 0;

	String userName() default "默認名稱";

	String[]arrays();
}
反射讀取註解信息
	public static void main(String[] args) throws ClassNotFoundException {
		Class classInfo = Class.forName("com.itmayiedu.entity.User");
		// 獲取到全部方法
		Method[] methods = classInfo.getDeclaredMethods();
		for (Method method : methods) {
			System.out.println(method);
			AddAnnotation declaredAnnotation = method.getDeclaredAnnotation(AddAnnotation.class);
			if (declaredAnnotation == null) {
				// 結束本次循環
				continue;
			}
			// 獲取userId
			int userId = declaredAnnotation.userId();
			System.out.println("userId:" + userId);
			// 獲取userName
			String userName = declaredAnnotation.userName();
			System.out.println("userName:" + userName);
			// 獲取arrays
			String[] arrays = declaredAnnotation.arrays();
			for (String str : arrays) {
				System.out.println("str:" + str);
			}
		}
	}



複製代碼

自定義事務註解

//編程事務（須要手動begin 手動回滾 手都提交）
@Component()
@Scope("prototype") // 設置成原型解決線程安全
public class TransactionUtils {

	private TransactionStatus transactionStatus;
	// 獲取事務源
	@Autowired
	private DataSourceTransactionManager dataSourceTransactionManager;

	// 開啓事務
	public TransactionStatus begin() {
		transactionStatus = dataSourceTransactionManager.getTransaction(new DefaultTransactionAttribute());
		return transactionStatus;
	}

	// 提交事務
	public void commit(TransactionStatus transaction) {
		dataSourceTransactionManager.commit(transaction);
	}

	// 回滾事務
	public void rollback() {
		System.out.println("rollback");
		dataSourceTransactionManager.rollback(transactionStatus);
	}

}

註解類

@Autowired
	private TransactionUtils transactionUtils;

	@AfterThrowing("execution(* com.itmayiedu.service.*.*.*(..))")
	public void afterThrowing() throws NoSuchMethodException, SecurityException {
		// isRollback(proceedingJoinPoint);
		System.out.println("程序發生異常");
		// TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
		// TransactionStatus currentTransactionStatus =
		// TransactionAspectSupport.currentTransactionStatus();
		// System.out.println("currentTransactionStatus:" +
		// currentTransactionStatus);
		transactionUtils.rollback();
	}

	// // 環繞通知 在方法以前和以後處理事情
	@Around("execution(* com.itmayiedu.service.*.*.*(..))")
	public void around(ProceedingJoinPoint proceedingJoinPoint) throws Throwable {

		// 調用方法以前執行
		TransactionStatus transactionStatus = begin(proceedingJoinPoint);
		proceedingJoinPoint.proceed();// 代理調用方法 注意點： 若是調用方法拋出異常不會執行後面代碼
		// 調用方法以後執行
		commit(transactionStatus);
	}

	public TransactionStatus begin(ProceedingJoinPoint pjp) throws NoSuchMethodException, SecurityException {

		// // 判斷是否有自定義事務註解
		ExtTransaction declaredAnnotation = getExtTransaction(pjp);
		if (declaredAnnotation == null) {
			return null;
		}
		// 若是有自定義事務註解，開啓事務
		System.out.println("開啓事務");
		TransactionStatus transactionStatu = transactionUtils.begin();
		return transactionStatu;
	}

	public void commit(TransactionStatus transactionStatu) {
		if (transactionStatu != null) {
			// 提交事務
			System.out.println("提交事務");
			transactionUtils.commit(transactionStatu);
		}
	}

	public ExtTransaction getExtTransaction(ProceedingJoinPoint pjp) throws NoSuchMethodException, SecurityException {
		// 獲取方法名稱
		String methodName = pjp.getSignature().getName();
		// 獲取目標對象
		Class<?> classTarget = pjp.getTarget().getClass();
		// 獲取目標對象類型
		Class<?>[] par = ((MethodSignature) pjp.getSignature()).getParameterTypes();
		// 獲取目標對象方法
		Method objMethod = classTarget.getMethod(methodName, par);
		// // 判斷是否有自定義事務註解
		ExtTransaction declaredAnnotation = objMethod.getDeclaredAnnotation(ExtTransaction.class);
		if (declaredAnnotation == null) {
			System.out.println("您的方法上,沒有加入註解!");
			return null;
		}
		return declaredAnnotation;

	}

	// 回滾事務
	public void isRollback(ProceedingJoinPoint pjp) throws NoSuchMethodException, SecurityException {
		// // 判斷是否有自定義事務註解
		ExtTransaction declaredAnnotation = getExtTransaction(pjp);
		if (declaredAnnotation != null) {
			System.out.println("已經開始回滾事務");
			// 獲取當前事務 直接回滾
			TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
			return;
		}
	}

使用自定義註解

@ExtTransaction
public void add() {
userDao.add("test001", 20);
int i = 1 / 0;
System.out.println("################");
userDao.add("test002", 21);
}


複製代碼
相關文章
相關標籤/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公眾號
   歡迎關注本站公眾號,獲取更多信息
聯繫我們 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程