8 Spring的事務處理
阿新 • • 發佈:2021-06-15
8 Spring的事務處理
來自百知教育,非原創
1. 什麼是事務?
保證業務操作完整性的一種資料庫機制
事務的4特點: A C I D
1. A 原子性
2. C 一致性
3. I 隔離性
4. D 永續性
2. 如何控制事務
JDBC: Connection.setAutoCommit(false); Connection.commit(); Connection.rollback(); Mybatis: Mybatis自動開啟事務 sqlSession(Connection).commit(); sqlSession(Connection).rollback(); 結論:控制事務的底層 都是Connection物件完成的。
3.Spring控制事務的開發
Spring是通過AOP的方式進行事務開發
1. 原始物件
public class XXXUserServiceImpl{
private xxxDAO xxxDAO
set get
1. 原始物件 ---》 原始方法 ---》核心功能 (業務處理+DAO呼叫)
2. DAO作為Service的成員變數,依賴注入的方式進行賦值
}
2. 額外功能
1. org.springframework.jdbc.datasource.DataSourceTransactionManager 2. 注入DataSource 1. MethodInterceptor public Object invoke(MethodInvocation invocation){ try{ Connection.setAutoCommit(false); Object ret = invocation.proceed(); Connection.commit(); }catch(Exception e){ Connection.rollback(); } return ret; } 2. @Aspect @Around
3. 切入點
@Transactional
事務的額外功能加入給那些業務方法。
1. 類上:類中所有的方法都會加入事務
2. 方法上:這個方法會加入事務
4 組裝切面
1. 切入點
2. 額外功能
<tx:annotation-driven transaction-manager=""/>
4. Spring控制事務的編碼
-
搭建開發環境 (jar)
<dependency> <groupId>org.springframework</groupId> <artifactId>spring-tx</artifactId> <version>5.1.14.RELEASE</version> </dependency>
-
編碼
<bean id="userService" class="com.baizhiedu.service.UserServiceImpl"> <property name="userDAO" ref="userDAO"/> </bean> <!--DataSourceTransactionManager--> <bean id="dataSourceTransactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"> <property name="dataSource" ref="dataSource"/> </bean> @Transactional public class UserServiceImpl implements UserService { private UserDAO userDAO; <tx:annotation-driven transaction-manager="dataSourceTransactionManager"/>
-
細節
<tx:annotation-driven transaction-manager="dataSourceTransactionManager" proxy-target-class="true"/> 進行動態代理底層實現的切換 proxy-target-class 預設 false JDK true Cglib
Spring中的事務屬性(Transaction Attribute)
1. 什麼是事務屬性
屬性:描述物體特徵的一系列值
性別 身高 體重 ...
事務屬性:描述事務特徵的一系列值
1. 隔離屬性
2. 傳播屬性
3. 只讀屬性
4. 超時屬性
5. 異常屬性
2. 如何新增事務屬性
@Transactional(isloation=,propagation=,readOnly=,timeout=,rollbackFor=,noRollbackFor=,)
3. 事務屬性詳解
1. 隔離屬性 (ISOLATION)
-
隔離屬性的概念
概念:他描述了事務解決併發問題的特徵 1. 什麼是併發 多個事務(使用者)在同一時間,訪問操作了相同的資料 同一時間:0.000幾秒 微小前 微小後 2. 併發會產生那些問題 1. 髒讀 2. 不可重複讀 3. 幻影讀 3. 併發問題如何解決 通過隔離屬性解決,隔離屬性中設定不同的值,解決併發處理過程中的問題。
-
事務併發產生的問題
-
髒讀
一個事務,讀取了另一個事務中沒有提交的資料。會在本事務中產生資料不一致的問題 解決方案 @Transactional(isolation=Isolation.READ_COMMITTED)
-
不可重複讀
一個事務中,多次讀取相同的資料,但是讀取結果不一樣。會在本事務中產生資料不一致的問題 注意:1 不是髒讀 2 一個事務中 解決方案 @Transactional(isolation=Isolation.REPEATABLE_READ) 本質: 一把行鎖
-
幻影讀
一個事務中,多次對整表進行查詢統計,但是結果不一樣,會在本事務中產生資料不一致的問題 解決方案 @Transactional(isolation=Isolation.SERIALIZABLE) 本質:表鎖
-
總結
併發安全: SERIALIZABLE>REPEATABLE_READ>READ_COMMITTED 執行效率: READ_COMMITTED>REPEATABLE_READ>SERIALIZABLE
-
-
資料庫對於隔離屬性的支援
隔離屬性的值 MySQL Oracle ISOLATION_READ_COMMITTED ✅ ✅ IOSLATION_REPEATABLE_READ ✅ ❎ ISOLATION_SERIALIZABLE ✅ ✅ Oracle不支援REPEATABLE_READ值 如何解決不可重複讀 採用的是多版本比對的方式 解決不可重複讀的問題
-
預設隔離屬性
ISOLATION_DEFAULT:會呼叫不同資料庫所設定的預設隔離屬性 MySQL : REPEATABLE_READ Oracle: READ_COMMITTED
-
檢視資料庫預設隔離屬性
-
MySQL
select @@tx_isolation;
-
Oracle
SELECT s.sid, s.serial#, CASE BITAND(t.flag, POWER(2, 28)) WHEN 0 THEN 'READ COMMITTED' ELSE 'SERIALIZABLE' END AS isolation_level FROM v$transaction t JOIN v$session s ON t.addr = s.taddr AND s.sid = sys_context('USERENV', 'SID');
-
-
-
隔離屬性在實戰中的建議
推薦使用Spring指定的ISOLATION_DEFAULT 1. MySQL repeatable_read 2. Oracle read_commited 未來實戰中,併發訪問情況 很低 如果真遇到併發問題,樂觀鎖 Hibernate(JPA) Version MyBatis 通過攔截器自定義開發
2. 傳播屬性(PROPAGATION)
-
傳播屬性的概念
概念:他描述了事務解決巢狀問題的特徵 什麼叫做事務的巢狀:他指的是一個大的事務中,包含了若干個小的事務 問題:大事務中融入了很多小的事務,他們彼此影響,最終就會導致外部大的事務,喪失了事務的原子性
-
傳播屬性的值及其用法
傳播屬性的值 外部不存在事務 外部存在事務 用法 備註 REQUIRED 開啟新的事務 融合到外部事務中 @Transactional(propagation = Propagation.REQUIRED) 增刪改方法 SUPPORTS 不開啟事務 融合到外部事務中 @Transactional(propagation = Propagation.SUPPORTS) 查詢方法 REQUIRES_NEW 開啟新的事務 掛起外部事務,建立新的事務 @Transactional(propagation = Propagation.REQUIRES_NEW) 日誌記錄方法中 NOT_SUPPORTED 不開啟事務 掛起外部事務 @Transactional(propagation = Propagation.NOT_SUPPORTED) 及其不常用 NEVER 不開啟事務 丟擲異常 @Transactional(propagation = Propagation.NEVER) 及其不常用 MANDATORY 丟擲異常 融合到外部事務中 @Transactional(propagation = Propagation.MANDATORY) 及其不常用 -
預設的傳播屬性
REQUIRED是傳播屬性的預設值
-
推薦傳播屬性的使用方式
增刪改 方法:直接使用預設值REQUIRED 查詢 操作:顯示指定傳播屬性的值為SUPPORTS
3. 只讀屬性(readOnly)
針對於只進行查詢操作的業務方法,可以加入只讀屬性,提供執行效率
預設值:false
4. 超時屬性(timeout)
指定了事務等待的最長時間
1. 為什麼事務進行等待?
當前事務訪問資料時,有可能訪問的資料被別的事務進行加鎖的處理,那麼此時本事務就必須進行等待。
2. 等待時間 秒
3. 如何應用 @Transactional(timeout=2)
4. 超時屬性的預設值 -1
最終由對應的資料庫來指定
5. 異常屬性
Spring事務處理過程中
預設 對於RuntimeException及其子類 採用的是回滾的策略
預設 對於Exception及其子類 採用的是提交的策略
rollbackFor = {java.lang.Exception,xxx,xxx}
noRollbackFor = {java.lang.RuntimeException,xxx,xx}
@Transactional(rollbackFor = {java.lang.Exception.class},noRollbackFor = {java.lang.RuntimeException.class})
建議:實戰中使用RuntimeExceptin及其子類 使用事務異常屬性的預設值
4. 事務屬性常見配置總結
1. 隔離屬性 預設值
2. 傳播屬性 Required(預設值) 增刪改 Supports 查詢操作
3. 只讀屬性 readOnly false 增刪改 true 查詢操作
4. 超時屬性 預設值 -1
5. 異常屬性 預設值
增刪改操作 @Transactional
查詢操作 @Transactional(propagation=Propagation.SUPPORTS,readOnly=true)
5. 基於標籤的事務配置方式(事務開發的第二種形式)
基於註解 @Transaction的事務配置回顧
<bean id="userService" class="com.baizhiedu.service.UserServiceImpl">
<property name="userDAO" ref="userDAO"/>
</bean>
<!--DataSourceTransactionManager-->
<bean id="dataSourceTransactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="dataSource"/>
</bean>
@Transactional(isolation=,propagation=,...)
public class UserServiceImpl implements UserService {
private UserDAO userDAO;
<tx:annotation-driven transaction-manager="dataSourceTransactionManager"/>
基於標籤的事務配置
<bean id="userService" class="com.baizhiedu.service.UserServiceImpl">
<property name="userDAO" ref="userDAO"/>
</bean>
<!--DataSourceTransactionManager-->
<bean id="dataSourceTransactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="dataSource"/>
</bean>
事務屬性
<tx:advice id="txAdvice" transacation-manager="dataSourceTransactionManager">
<tx:attributes>
<tx:method name="register" isoloation="",propagation=""></tx:method>
<tx:method name="login" .....></tx:method>
等效於
@Transactional(isolation=,propagation=,)
public void register(){
}
</tx:attributes>
</tx:advice>
<aop:config>
<aop:pointcut id="pc" expression="execution(* com.baizhiedu.service.UserServiceImpl.register(..))"></aop:pointcut>
<aop:advisor advice-ref="txAdvice" pointcut-ref="pc"></aop:advisor>
</aop:config>
-
基於標籤的事務配置在實戰中的應用方式
<bean id="userService" class="com.baizhiedu.service.UserServiceImpl"> <property name="userDAO" ref="userDAO"/> </bean> <!--DataSourceTransactionManager--> <bean id="dataSourceTransactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"> <property name="dataSource" ref="dataSource"/> </bean> 程式設計時候 service中負責進行增刪改操作的方法 都以modify開頭 查詢操作 命名無所謂 <tx:advice id="txAdvice" transacation-manager="dataSourceTransactionManager"> <tx:attributes> <tx:method name="register"></tx:method> <tx:method name="modify*"></tx:method> <tx:method name="*" propagation="SUPPORTS" read-only="true"></tx:method> </tx:attributes> </tx:advice> 應用的過程中,service放置到service包中 <aop:config> <aop:pointcut id="pc" expression="execution(* com.baizhiedu.service..*.*(..))"></aop:pointcut> <aop:advisor advice-ref="txAdvice" pointcut-ref="pc"></aop:advisor> </aop:config>