Spring的@Transactional注解使用詳細解析
前言
@Transactional 注解相信大家并不陌生,平時開發(fā)中很常用的一個注解,它能保證方法內多個數(shù)據(jù)庫操作要么同時成功、要么同時失敗。
使用@Transactional注解時需要注意許多的細節(jié),不然你會發(fā)現(xiàn)@Transactional總是莫名其妙的就失效了。
事務
聲明式事務:通過AOP(面向切面)方式在方法前使用編程式事務的方法開啟事務,在方法后提交或回滾。用配置文件的方法或注解方法(如:@Transactional)控制事務。
編程式事務:手動開啟、提交、回滾事務。 通俗地去理解兩者的區(qū)別,即聲明式事務只需要“聲明”就可以達到事務的效果;編程式事務需要“編程”才可以達到事務效果。 聲明式事務案例:
@Override
@Transactional
public Map<String, Object> fun() {
}
編程式事務案例
工具類代碼
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.stereotype.Component;
import org.springframework.transaction.TransactionStatus;
import org.springframework.transaction.interceptor.DefaultTransactionAttribute;
@Component
public class Utils {
@Autowired
private DataSourceTransactionManager dataSourceTransactionManager;
// 開啟事務
public TransactionStatus openTx() {
return dataSourceTransactionManager.getTransaction(new DefaultTransactionAttribute());
}
// 提交事務
public void commitTx(TransactionStatus ts) {
dataSourceTransactionManager.commit(ts);
}
// 回滾事務
public void rollbackTx(TransactionStatus ts) {
dataSourceTransactionManager.rollback(ts);
}
}
業(yè)務層代碼
@Service
public class RegisterServiceImpl implements RegisterService {
@Autowired
private Utils utils;
@Override
public void programming(String name,String age,String studentId) {
TransactionStatus ts = null;
try {
// 開啟事務
ts = utils.openTx();
registerMapper.programming( name, age, studentId);
int a=1/0;
registerMapper.programming( name, age, studentId);
if (ts != null) {
// 提交事務
utils.commitTx(ts);
}
} catch (Exception e) {
if (ts != null) {
// 回滾事務
utils.rollbackTx(ts);
}
}
}
}
如以上代碼,開發(fā)者可以通過API自己控制事務。
接下來我們重點看一下聲明式事務
聲明式事務
基于AOP面向切面的,它將具體業(yè)務與事務處理部分解耦,代碼侵入性很低,所以在實際開發(fā)中聲明式事務用的比較多。聲明式事務也有兩種實現(xiàn)方式,一是基于TX和AOP的xml配置文件方式,二種就是基于@Transactional注解了。
聲明式事務管理方法允許開發(fā)者配置的幫助下來管理事務,而不需要依賴底層API進行硬編碼。開發(fā)者可以只使用注解或基于配置的 XML 來管理事務。
@Transactional
2 @GetMapping("/test")
3 public String test() {
4
5 int insert = cityInfoDictMapper.insert(cityInfoDict);
6 }
聲明式事務對代碼沒有侵入性,方法內只需要寫業(yè)務邏輯就可以了,幫助我們節(jié)省了很多代碼,他會自動幫我們進行事務的開啟、提交以及回滾等操作,把程序員從事務管理中解放出來。可以說優(yōu)點很明顯,但是這種方式的缺點也很明顯。
問題一:聲明式事務的粒度問題
首先,聲明式事務有一個局限,那就是他的最小粒度要作用在方法上。
也就是說,如果想要給一部分代碼塊增加事務的話,那就需要把這個部分代碼塊單獨獨立出來作為一個方法。
在大事務耗時過長需要高并發(fā)優(yōu)化的情況下不建議使用聲明式事務,建議采用上面提到的編程式事務方式。
問題二:聲明式事務容易被開發(fā)者忽略
而事務一旦被忽略就容易造成很多故障
首先,如果開發(fā)者沒有注意到一個方法是被事務嵌套的,那么就可能會再方法中加入一些如RPC遠程調用、消息發(fā)送、緩存更新、文件寫入等操作。
我們知道,這些操作如果被包在事務中,有兩個問題:
1、這些操作自身是無法回滾的,這就會導致數(shù)據(jù)的不一致??赡躌PC調用成功了,但是本地事務回滾了,可是PRC調用無法回滾了(這里不討論分布式事務)。
2、在事務中有遠程調用,就會拉長整個事務。那么久會導致本事務的數(shù)據(jù)庫連接一直被占用,那么如果類似操作過多,就會導致數(shù)據(jù)庫連接池耗盡。
有些時候,即使沒有在事務中進行遠程操作,但是有些人還是可能會不經意的進行一些內存操作,如運算?;蛘呷绻龅椒謳旆直淼那闆r,有可能不經意間進行跨庫操作。
問題三:聲明式事務用不對在某些場景下容易失效
這個問題后面我們著重講述一下失效的幾種場景。
下面我們就講講聲明式事務使用的@Transactional注解。
@Transactional介紹
@Transactional 可以作用在接口、類、類方法
作用于類:當把@Transactional 注解放在類上時,表示所有該類的public方法都配置相同的事務屬性信息。
作用于方法:當類配置了@Transactional,方法也配置了@Transactional,方法的事務會覆蓋類的事務配置信息。
作用于接口:不推薦這種使用方法,因為一旦標注在Interface上并且配置了Spring AOP 使用CGLib動態(tài)代理,將會導致@Transactional注解失效。
@Transactional
@RestController
@RequestMapping
public class MybatisPlusController {
@Autowired
private CityInfoDictMapper cityInfoDictMapper;
@Transactional(rollbackFor = Exception.class)
@GetMapping("/test")
public String test() throws Exception {
CityInfoDict cityInfoDict = new CityInfoDict();
cityInfoDict.setParentCityId(2);
cityInfoDict.setCityName("2");
cityInfoDict.setCityLevel("2");
cityInfoDict.setCityCode("2");
int insert = cityInfoDictMapper.insert(cityInfoDict);
return insert + "";
}
}
@Transactional失效場景
接下來我們結合具體的代碼分析一下哪些場景下,@Transactional 注解會失效。
1.@Transactional 應用在非 public 修飾的方法上
如果Transactional注解應用在非public 修飾的方法上,Transactional將會失效。 之所以會失效是因為在Spring AOP 代理時,如上圖所示 TransactionInterceptor (事務攔截器)在目標方法執(zhí)行前后進行攔截,DynamicAdvisedInterceptor(CglibAopProxy 的內部類)的 intercept 方法或 JdkDynamicAopProxy 的 invoke 方法會間接調用 AbstractFallbackTransactionAttributeSource的 computeTransactionAttribute 方法,獲取Transactional 注解的事務配置信息。
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 的屬性配置信息。
注意:protected、private 修飾的方法上使用 @Transactional 注解,雖然事務無效,但不會有任何報錯,這是我們很容犯錯的一點。
2、propagation 設置錯誤
@Transactional 注解屬性 propagation 設置錯誤 這種失效是由于配置錯誤,若是錯誤的配置以下三種 propagation,事務將不會發(fā)生回滾。
- TransactionDefinition.PROPAGATION_SUPPORTS:如果當前存在事務,則加入該事務;如果當前沒有事務,則以非事務的方式繼續(xù)運行。
- TransactionDefinition.PROPAGATION_NOT_SUPPORTED:以非事務方式運行,如果當前存在事務,則把當前事務掛起。
- TransactionDefinition.PROPAGATION_NEVER:以非事務方式運行,如果當前存在事務,則拋出異常。
3、rollbackFor 設置錯誤
@Transactional 注解屬性 rollbackFor 設置錯誤
rollbackFor 可以指定能夠觸發(fā)事務回滾的異常類型。Spring默認拋出了未檢查unchecked異常(繼承自 RuntimeException的異常)或者 Error才回滾事務;其他異常不會觸發(fā)回滾事務。
如果在事務中拋出其他類型的異常,但卻期望 Spring 能夠回滾事務,就需要指定 rollbackFor屬性。
// 希望自定義的異??梢赃M行回滾 @Transactional(propagation= Propagation.REQUIRED,rollbackFor= MyException.class
若在目標方法中拋出的異常是 rollbackFor 指定的異常的子類,事務同樣會回滾。
Spring源碼如下:
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);
}
4、同一個類中方法調用,導致@Transactional失效
開發(fā)中避免不了會對同一個類里面的方法調用,比如有一個類Test,它的一個方法A,A再調用本類的方法B(不論方法B是用public還是private修飾),但方法A沒有聲明注解事務,而B方法有。則外部調用方法A之后,方法B的事務是不會起作用的。這也是經常犯錯誤的一個地方。
那為啥會出現(xiàn)這種情況?其實這還是由于使用Spring AOP代理造成的,因為只有當事務方法被當前類以外的代碼調用時,才會由Spring生成的代理對象來管理。
//@Transactional
@GetMapping("/test")
private Integer A() throws Exception {
CityInfoDict cityInfoDict = new CityInfoDict();
cityInfoDict.setCityName("2");
/**
* B 插入字段為 3的數(shù)據(jù)
*/
this.insertB();
/**
* A 插入字段為 2的數(shù)據(jù)
*/
int insert = cityInfoDictMapper.insert(cityInfoDict);
return insert;
}
@Transactional()
public Integer insertB() throws Exception {
CityInfoDict cityInfoDict = new CityInfoDict();
cityInfoDict.setCityName("3");
cityInfoDict.setParentCityId(3);
return cityInfoDictMapper.insert(cityInfoDict);
}
5、異常被你的 catch“吃了”
導致@Transactional失效 這種情況是最常見的一種@Transactional注解失效場景
1 @Transactional
2 private Integer A() throws Exception {
3 int insert = 0;
4 try {
5 CityInfoDict cityInfoDict = new CityInfoDict();
6 cityInfoDict.setCityName("2");
7 cityInfoDict.setParentCityId(2);
8 /**
9 * A 插入字段為 2的數(shù)據(jù)
10 */
11 insert = cityInfoDictMapper.insert(cityInfoDict);
12 /**
13 * B 插入字段為 3的數(shù)據(jù)
14 */
15 b.insertB();
16 } catch (Exception e) {
17 e.printStackTrace();
18 }
19 }
如果B方法內部拋了異常,而A方法此時try catch了B方法的異常,那這個事務還能正?;貪L嗎?
答案:不能!
會拋出異常:
1org.springframework.transaction.UnexpectedRollbackException: Transaction rolled back because it has been marked as rollback-only
因為當ServiceB中拋出了一個異常以后,ServiceB標識當前事務需要rollback。
但是ServiceA中由于你手動的捕獲這個異常并進行處理,ServiceA認為當前事務應該正常commit。此時就出現(xiàn)了前后不一致,也就是因為這樣,拋出了前面的UnexpectedRollbackException異常。
spring的事務是在調用業(yè)務方法之前開始的,業(yè)務方法執(zhí)行完畢之后才執(zhí)行commit or rollback,事務是否執(zhí)行取決于是否拋出runtime異常。如果拋出runtime exception 并在你的業(yè)務方法中沒有catch到的話,事務會回滾。
在業(yè)務方法中一般不需要catch異常,如果非要catch一定要手動拋出throw new RuntimeException(),否則會導致事務失效,數(shù)據(jù)commit造成數(shù)據(jù)不一致,所以有些時候try catch反倒會畫蛇添足。
6、數(shù)據(jù)庫引擎不支持事務
這種情況出現(xiàn)的概率并不高,事務能否生效數(shù)據(jù)庫引擎是否支持事務是關鍵。
常用的MySQL數(shù)據(jù)庫默認使用支持事務的innodb引擎。
一旦數(shù)據(jù)庫引擎切換成不支持事務的myisam,那事務就從根本上失效了。
到此這篇關于Spring的@Transactional注解使用詳細解析的文章就介紹到這了,更多相關@Transactional注解使用內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家!
相關文章
Java過濾器filter_動力節(jié)點Java學院整理
這篇文章主要介紹了Java過濾器filter,通過過濾器,可以對來自客戶端的請求進行攔截,進行預處理或者對最終響應給客戶端的數(shù)據(jù)進行處理后再輸出2017-07-07
詳解SpringBoot 創(chuàng)建定時任務(配合數(shù)據(jù)庫動態(tài)執(zhí)行)
本篇文章主要介紹了SpringBoot 創(chuàng)建定時任務(配合數(shù)據(jù)庫動態(tài)執(zhí)行),小編覺得挺不錯的,現(xiàn)在分享給大家,也給大家做個參考。一起跟隨小編過來看看吧2017-10-10
使用Spring開啟@Async異步方式(javaconfig配置)
這篇文章主要介紹了使用Spring開啟@Async異步方式(javaconfig配置),具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教2021-08-08

