@Transactional解讀(作用、失效場景與解決方式)
一、了解@Transactional注解
先要知道事務(wù)是什么,但既然知道了這個注解,不知道事務(wù)是什么,那就重新再去學(xué)習(xí)一遍數(shù)據(jù)庫吧,這里講解開發(fā)中代碼實(shí)現(xiàn)事務(wù)的方式
1、編程式事務(wù)(開發(fā)用的很少了)
基于底層的API,如PlatformTransactionManager
、TransactionDefinition
和 TransactionTemplate
等核心接口,開發(fā)者完全可以通過編程的方式來進(jìn)行事務(wù)管理。
@SpringBootTest @Slf4j public class Test { @Autowired PlatformTransactionManager transactionManager; @Autowired private TransactionTemplate transactionTemplate; @Autowired UserService userService; @Test public void transactionManagerTest(){ //事務(wù)基礎(chǔ)信息 超時時間、隔離級別、傳播屬性等 DefaultTransactionDefinition def = new DefaultTransactionDefinition();; // 定義事務(wù)屬性 // 設(shè)置傳播行為屬性, 默認(rèn)事務(wù)級別。 當(dāng)前無事務(wù)則新建事務(wù),已有事務(wù)則加入事務(wù)。 def.setPropagationBehavior(DefaultTransactionDefinition.PROPAGATION_REQUIRED); // 獲得事務(wù)狀態(tài) TransactionStatus status = transactionManager.getTransaction(def); try { log.info("執(zhí)行事務(wù)方法"); // 這里用到 lombok 的鏈?zhǔn)骄幊?,很簡單的原理,set一般不是返回void嗎,只需要改為返回當(dāng)前對象,就是this,就可以實(shí)現(xiàn)此功能了 User user = new User().setName("張三"); // 事務(wù)操作 // 數(shù)據(jù)庫操作 userService.insertUser(user); //手動設(shè)置異常 int i = 1 / 0; // 事務(wù)提交 transactionManager.commit(status);// 提交事務(wù) } catch (Exception e) { // 事務(wù)提交 transactionManager.rollback(status); log.error("執(zhí)行事務(wù)異常,需要回滾"); } } @Test public void transactionTemplateTest() { Object execute = transactionTemplate.execute(new TransactionCallback() { /** * @param transactionStatus 事務(wù)運(yùn)行狀態(tài)信息 是否是新事務(wù)、是否已被標(biāo)記為回滾等 * @return */ @Override public Object doInTransaction(TransactionStatus transactionStatus) { try { log.info("執(zhí)行事務(wù)方法"); User user = new User().setName("張三"); userService.insertUser(user); // 手動設(shè)置異常 int i = 1 / 0; log.info("正常執(zhí)行完成"); return "成功"; } catch (Exception e) { log.error("執(zhí)行事務(wù)異常,需要回滾",e); transactionStatus.setRollbackOnly(); return "失敗"; } } }); } }
2、聲明式事務(wù)(主流,也是本文的主角==@Transactional==)
聲明式事務(wù)管理方法允許開發(fā)者配置的幫助下來管理事務(wù),而不需要依賴底層API進(jìn)行硬編碼。
開發(fā)者可以只使用注解或基于配置的 XML 來管理事務(wù)。
@Test // 這個注解還是有很多坑需要注意,這在后文中會講 @Transactional(rollbackFor = Exception.class) public void transactionalTest(){ // 只用正常些業(yè)務(wù)代碼就可以了,一切交給 Spring 來處理,這里 @Transactional 注解用到的知識就是 AOP try { User user = new User().setName("張三"); // 數(shù)據(jù)庫操作 userService.insertUser(user); // 手動設(shè)置異常 int i = 1 / 0; } catch (Exception e) { log.error("執(zhí)行事務(wù)異常,需要回滾",e); // 如果異常被 try 、 catch 吞了是不會回滾的,所有手動拋出去 throw e; } }
二、@Transactional介紹
1、@Transactional注解可以作用于哪些地方?
@Transactional 可以作用在接口、類、類方法
- 作用于類:當(dāng)把@Transactional 注解放在類上時,表示所有該類的public方法都配置相同的事務(wù)屬性信息。
- 作用于方法:當(dāng)類配置了@Transactional,方法也配置了@Transactional,方法的事務(wù)會覆蓋類的事務(wù)配置信息。
- 作用于接口:不推薦這種使用方法,因?yàn)橐坏?biāo)注在Interface上并且配置了Spring AOP 使用CGLib動態(tài)代理,將會導(dǎo)致@Transactional注解失效
@Transactional(rollbackFor = Exception.class) @RestController @Slf4j public class TestController { @Autowired UserService userService; @RequestMapping("/test") // 這個注解還是有很多坑需要注意,這在后文中會講 @Transactional(rollbackFor = Exception.class) public void transactionalTest(){ // 只用正常些業(yè)務(wù)代碼就可以了,一切交給 Spring 來處理,這里 @Transactional 注解用到的知識就是 AOP try { User user = new User().setName("張三"); // 數(shù)據(jù)庫操作 userService.insertUser(user); // 手動設(shè)置異常 int i = 1 / 0; } catch (Exception e) { log.error("執(zhí)行事務(wù)異常,需要回滾",e); // 如果異常被 try 、 catch 吞了是不會回滾的,所有手動拋出去 throw e; } } }
2、@Transactional注有哪些屬性?
propagation屬性
propagation 代表事務(wù)的傳播行為,默認(rèn)值為 Propagation.REQUIRED
,其他的屬性信息如下:
Propagation.REQUIRED
:如果當(dāng)前存在事務(wù),則加入該事務(wù),如果當(dāng)前不存在事務(wù),則創(chuàng)建一個新的事務(wù)。( 也就是說如果A方法和B方法都添加了注解,在默認(rèn)傳播模式下,A方法內(nèi)部調(diào)用B方法,會把兩個方法的事務(wù)合并為一個事務(wù) )Propagation.SUPPORTS
:如果當(dāng)前存在事務(wù),則加入該事務(wù);如果當(dāng)前不存在事務(wù),則以非事務(wù)的方式繼續(xù)運(yùn)行。Propagation.MANDATORY
:如果當(dāng)前存在事務(wù),則加入該事務(wù);如果當(dāng)前不存在事務(wù),則拋出異常。Propagation.REQUIRES_NEW
:重新創(chuàng)建一個新的事務(wù),如果當(dāng)前存在事務(wù),暫停當(dāng)前的事務(wù)。( 當(dāng)類A中的 a 方法用默認(rèn)Propagation.REQUIRED模式,類B中的 b方法加上采用 Propagation.REQUIRES_NEW模式,然后在 a 方法中調(diào)用 b方法操作數(shù)據(jù)庫,然而 a方法拋出異常后,b方法并沒有進(jìn)行回滾,因?yàn)镻ropagation.REQUIRES_NEW會暫停 a方法的事務(wù) )Propagation.NOT_SUPPORTED
:以非事務(wù)的方式運(yùn)行,如果當(dāng)前存在事務(wù),暫停當(dāng)前的事務(wù)。Propagation.NEVER
:以非事務(wù)的方式運(yùn)行,如果當(dāng)前存在事務(wù),則拋出異常。Propagation.NESTED
:和 Propagation.REQUIRED 效果一樣。
isolation 屬性
isolation :事務(wù)的隔離級別,默認(rèn)值為Isolation.DEFAULT
Isolation.DEFAULT
:使用底層數(shù)據(jù)庫默認(rèn)的隔離級別。Isolation.READ_UNCOMMITTED
:讀未提交Isolation.READ_COMMITTED
:讀已提交Isolation.REPEATABLE_READ
:可重復(fù)讀Isolation.SERIALIZABLE
:串行化
timeout 屬性
- timeout :事務(wù)的超時時間,默認(rèn)值為 -1。
- 如果超過該時間限制但事務(wù)還沒有完成,則自動回滾事務(wù)。
readOnly 屬性
- readOnly :指定事務(wù)是否為只讀事務(wù),默認(rèn)值為 false;
- 為了忽略那些不需要事務(wù)的方法,比如讀取數(shù)據(jù),可以設(shè)置 read-only 為 true。
rollbackFor 屬性
- rollbackFor :用于指定能夠觸發(fā)事務(wù)回滾的異常類型
- 可以指定多個異常類型
noRollbackFor屬性
- noRollbackFor:拋出指定的異常類型,不回滾事務(wù)
- 也可以指定多個異常類型
三、@Transactional失效場景與解決辦法
1、@Transactional 應(yīng)用在非 public 修飾的方法上
首先JDK動態(tài)代理肯定只能是public,因?yàn)榻涌诘臋?quán)限修飾符只能是public,所以其他的修飾符不可以使用,cglib代理的方式是可以代理protected方法的如果支持protected,大概率會造成當(dāng)切換代理的實(shí)現(xiàn)方式時表現(xiàn)不同,所以會出現(xiàn)很多的bug,然后造成一系列的問題
之所以會失效是因?yàn)樵赟pring AOP 代理時,如上圖所示 TransactionInterceptor (事務(wù)攔截器)在目標(biāo)方法執(zhí)行前后進(jìn)行攔截,DynamicAdvisedInterceptor(CglibAopProxy 的內(nèi)部類)的 intercept 方法或 JdkDynamicAopProxy 的 invoke 方法會間接調(diào)用 AbstractFallbackTransactionAttributeSource的 computeTransactionAttribute方法,獲取Transactional 注解的事務(wù)配置信息。
AbstractFallbackTransactionAttributeSource類:
protected TransactionAttribute computeTransactionAttribute(Method method, Class<?> targetClass) { // Don't allow no-public methods as required. if (allowPublicMethodsOnly() && !Modifier.isPublic(method.getModifiers())) { return null; }
這個方法會檢查目標(biāo)方法的修飾符是不是 public,若不是 public,就不會獲取@Transactional 的屬性配置信息,最終會造成不會用 TransactionInterceptor 來攔截該目標(biāo)方法進(jìn)行事務(wù)管理。
2、@Transactional 注解屬性 propagation 設(shè)置錯誤
這種失效是由于配置錯誤,若是錯誤的配置以下三種 propagation,事務(wù)將不會發(fā)生回滾。
TransactionDefinition.PROPAGATION_SUPPORTS
:如果當(dāng)前存在事務(wù),則加入該事務(wù);如果當(dāng)前沒有事務(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ù),則拋出異常。
3、@Transactional 注解屬性 rollbackFor 設(shè)置錯誤
rollbackFor 可以指定能夠觸發(fā)事務(wù)回滾的異常類型。
Spring默認(rèn)拋出了未檢查unchecked異常(繼承自 RuntimeException 的異常)或者 Error才回滾事務(wù);其他異常不會觸發(fā)回滾事務(wù)。
如果在事務(wù)中拋出其他類型的異常,但卻期望 Spring 能夠回滾事務(wù),就需要指定 rollbackFor屬性。
若在目標(biāo)方法中拋出的異常是 rollbackFor 指定的異常的子類,事務(wù)同樣會回滾。
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); }
所以一般使用
@Transactional(rollbackFor = Exception.class)
就可以了,但可以根據(jù)業(yè)務(wù)自定義異常類
4、同一個類中方法調(diào)用,導(dǎo)致@Transactional失效
開發(fā)中避免不了會對同一個類里面的方法調(diào)用,比如有一個類Test,它的一個方法A,A再調(diào)用本類的方法B(不論方法B是用public還是private修飾),但方法A沒有聲明注解事務(wù),而B方法有。則外部調(diào)用方法A之后,方法B的事務(wù)是不會起作用的。這也是經(jīng)常犯錯誤的一個地方。
那為啥會出現(xiàn)這種情況?其實(shí)這還是由于使用Spring AOP代理造成的,因?yàn)橹挥挟?dāng)事務(wù)方法被當(dāng)前類以外的代碼調(diào)用時,才會由Spring生成的代理對象來管理。
錯誤入下:(但反過來(transactionalTest方法(@Transactional在transactionalTest方法上)調(diào)用Test方法)可以讓@Transactional生效)
@RestController @Slf4j public class TestController { @Autowired UserService userService; @RequestMapping("/test") public void Test(){ // 這里就相當(dāng)于使用了 this.transactionalTest(); 使用的是本地對象的方法,沒有用到spring容器,就無法觸發(fā)AOP,導(dǎo)致事務(wù)失效 transactionalTest(); } // 這個注解還是有很多坑需要注意,這在后文中會講 @Transactional(rollbackFor = Exception.class) public void transactionalTest(){ // 只用正常些業(yè)務(wù)代碼就可以了,一切交給 Spring 來處理,這里 @Transactional 注解用到的知識就是 AOP try { User user = new User().setName("張三"); // 數(shù)據(jù)庫操作 userService.insertUser(user); // 手動設(shè)置異常 int i = 1 / 0; } catch (Exception e) { log.error("執(zhí)行事務(wù)異常,需要回滾",e); // 如果異常被 try 、 catch 吞了是不會回滾的,所有手動拋出去 throw e; } } }
解決方法:使用該類的Spring代理對象就可以了
- 1、AopContext.currentProxy()獲得當(dāng)前代理對象,注意:類上也需要加@EnableAspectJAutoProxy注解(推薦)
@RestController @Slf4j @EnableAspectJAutoProxy(proxyTargetClass = true,exposeProxy = true) public class TestController { @Autowired UserService userService; @RequestMapping("/test") public void Test(){ // 這里就相當(dāng)于使用了 this.transactionalTest(); 使用的是本地對象的方法,沒有用到spring容器,就無法觸發(fā)AOP,導(dǎo)致事務(wù)失效 ((TestController) AopContext.currentProxy()).transactionalTest(); } // 這個注解還是有很多坑需要注意,這在后文中會講 @Transactional(rollbackFor = Exception.class) public void transactionalTest(){ // 只用正常些業(yè)務(wù)代碼就可以了,一切交給 Spring 來處理,這里 @Transactional 注解用到的知識就是 AOP try { User user = new User().setName("張三"); // 數(shù)據(jù)庫操作 userService.insertUser(user); // 手動設(shè)置異常 int i = 1 / 0; } catch (Exception e) { log.error("執(zhí)行事務(wù)異常,需要回滾",e); // 如果異常被 try 、 catch 吞了是不會回滾的,所有手動拋出去 throw e; } } }
- 2、寫到另一個類中使用@Autowired調(diào)用(這個就不細(xì)說了)
- 3、@Autowired本類(沒試過,聽說可以)
@RestController @Slf4j public class TestController { @Autowired UserService userService; @Autowired TestController testController; @RequestMapping("/test") public void Test(){ testController.transactionalTest(); } // 這個注解還是有很多坑需要注意,這在后文中會講 @Transactional(rollbackFor = Exception.class) public void transactionalTest(){ // 只用正常些業(yè)務(wù)代碼就可以了,一切交給 Spring 來處理,這里 @Transactional 注解用到的知識就是 AOP try { User user = new User().setName("張三"); // 數(shù)據(jù)庫操作 userService.insertUser(user); // 手動設(shè)置異常 int i = 1 / 0; } catch (Exception e) { log.error("執(zhí)行事務(wù)異常,需要回滾",e); // 如果異常被 try 、 catch 吞了是不會回滾的,所有手動拋出去 throw e; } } }
- 4、實(shí)現(xiàn)ApplicationContextAware接口,獲取Bean
@RestController @Slf4j public class TestController implements ApplicationContextAware { @Autowired UserService userService; private static ApplicationContext applicationContext; @RequestMapping("/test") public void Test(){ TestController bean = applicationContext.getBean(TestController.class); bean.transactionalTest(); } // 這個注解還是有很多坑需要注意,這在后文中會講 @Transactional(rollbackFor = Exception.class) public void transactionalTest(){ // 只用正常些業(yè)務(wù)代碼就可以了,一切交給 Spring 來處理,這里 @Transactional 注解用到的知識就是 AOP try { User user = new User().setName("張三"); // 數(shù)據(jù)庫操作 userService.insertUser(user); // 手動設(shè)置異常 int i = 1 / 0; } catch (Exception e) { log.error("執(zhí)行事務(wù)異常,需要回滾",e); // 如果異常被 try 、 catch 吞了是不會回滾的,所有手動拋出去 throw e; } } @Override public void setApplicationContext(ApplicationContext applicationContext) throws BeansException { TestController.applicationContext = applicationContext; } }
- 5、一切可以獲取Spring對象的應(yīng)該都可以 ╭(?´^`?)╮
5、異常被你的 catch“吃了”導(dǎo)致@Transactional失效
AOP 可以說是生成一個代理類,可以在這個方法的頭和尾添加代碼,比如代理類使用一個try、catch把這個方法給套起來了,只有這個方法拋出異常之后,調(diào)用了代理類中catch的事務(wù)回滾代碼才能回滾,所以你沒拋出異常的話,@Transactional認(rèn)為你是正常運(yùn)行的代碼所以不回滾
@Transactional(rollbackFor = Exception.class) public void transactionalTest(){ // 只用正常些業(yè)務(wù)代碼就可以了,一切交給 Spring 來處理,這里 @Transactional 注解用到的知識就是 AOP try { User user = new User().setName("張三"); // 數(shù)據(jù)庫操作 userService.insertUser(user); // 手動設(shè)置異常 int i = 1 / 0; } catch (Exception e) { // 為啥寫 catch ,還要寫 throw e 拋出異常呢,因?yàn)橐浫罩景。挥浫罩镜脑捯部梢圆挥?,但哪個不寫報(bào)錯日志,出bug不是給自己挖坑嗎 log.error("執(zhí)行事務(wù)異常,需要回滾",e); // 如果異常被 try 、 catch 吞了是不會回滾的 // throw e; } }
6、數(shù)據(jù)庫引擎不支持事務(wù)
這種情況出現(xiàn)的概率并不高,事務(wù)能否生效數(shù)據(jù)庫引擎是否支持事務(wù)是關(guān)鍵。
常用的MySQL數(shù)據(jù)庫默認(rèn)使用支持事務(wù)的innodb引擎。
一旦數(shù)據(jù)庫引擎切換成不支持事務(wù)的myisam,那事務(wù)就從根本上失效了。
總結(jié)
@Transactional非常的好用,只需要一個注解就可以不用管事務(wù)操作了,只需要注重自己的業(yè)務(wù)代碼就可以了
@Transactional也有缺點(diǎn),比如你要注意上訴的幾種失效情況,他有個局限性,他的最小粒度要作用在方法上,也就是說,如果想要給一部分代碼塊增加事務(wù)的話,那就需要把這個部分代碼塊單獨(dú)獨(dú)立出來作為一個方法。而且AOP要生成一個動態(tài)代理類,所以會慢一點(diǎn)
但是誰會管這些啊,好用就行了,也不是不能忍的問題,這跟他的好處根本不成正比,當(dāng)然如果要使用編程式事務(wù)也可以,看個人愛好,反之小編一直用的是@Transactional,Spring官方也推薦使用@Transactional,所以了解了怎么使用之后,大膽的用就好了
這種情況出現(xiàn)的概率并不高,事務(wù)能否生效數(shù)據(jù)庫引擎是否支持事務(wù)是關(guān)鍵。常用的MySQL數(shù)據(jù)庫默認(rèn)使用支持事務(wù)的innodb引擎。一旦數(shù)據(jù)庫引擎切換成不支持事務(wù)的myisam,那事務(wù)就從根本上失效了。
以上為個人經(jīng)驗(yàn),希望能給大家一個參考,也希望大家多多支持腳本之家。
相關(guān)文章
詳解springboot-mysql-pagehelper分頁插件集成
這篇文章主要介紹了springboot-mysql-pagehelper分頁插件集成,本文通過實(shí)例代碼給大家介紹的非常詳細(xì),對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值,需要的朋友可以參考下2023-07-07java開發(fā)Dubbo負(fù)載均衡與集群容錯示例詳解
這篇文章主要為大家介紹了java開發(fā)Dubbo負(fù)載均衡與集群容錯示例詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步2021-11-11Java基于jeeplus vue實(shí)現(xiàn)簡單工作流過程圖解
這篇文章主要介紹了Java基于jeeplus vue實(shí)現(xiàn)簡單工作流過程圖解,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下2020-04-04Java多線程wait()和notify()方法詳細(xì)圖解
wait()和notify()是直接隸屬于Object類,也就是說所有對象都擁有這一對方法,下面這篇文章主要給大家介紹了關(guān)于Java多線程wait()和notify()方法詳細(xì)圖解的相關(guān)資料,需要的朋友可以參考下2022-10-10java實(shí)現(xiàn)html轉(zhuǎn)pdf方法步驟
這篇文章主要給大家介紹了關(guān)于java實(shí)現(xiàn)html轉(zhuǎn)pdf方法的相關(guān)資料,要將HTML轉(zhuǎn)換成PDF,我們需要借助Java中的第三方庫,文中通過示例代碼介紹的非常詳細(xì),需要的朋友可以參考下2023-08-08