@Transactional解讀(作用、失效場景與解決方式)
一、了解@Transactional注解
先要知道事務(wù)是什么,但既然知道了這個注解,不知道事務(wù)是什么,那就重新再去學(xué)習(xí)一遍數(shù)據(jù)庫吧,這里講解開發(fā)中代碼實現(xiàn)事務(wù)的方式
1、編程式事務(wù)(開發(fā)用的很少了)
基于底層的API,如PlatformTransactionManager、TransactionDefinition 和 TransactionTemplate 等核心接口,開發(fā)者完全可以通過編程的方式來進行事務(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è)置傳播行為屬性, 默認事務(wù)級別。 當前無事務(wù)則新建事務(wù),已有事務(wù)則加入事務(wù)。
def.setPropagationBehavior(DefaultTransactionDefinition.PROPAGATION_REQUIRED);
// 獲得事務(wù)狀態(tài)
TransactionStatus status = transactionManager.getTransaction(def);
try {
log.info("執(zhí)行事務(wù)方法");
// 這里用到 lombok 的鏈式編程,很簡單的原理,set一般不是返回void嗎,只需要改為返回當前對象,就是this,就可以實現(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ù)運行狀態(tài)信息 是否是新事務(wù)、是否已被標記為回滾等
* @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進行硬編碼。
開發(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 可以作用在接口、類、類方法
- 作用于類:當把@Transactional 注解放在類上時,表示所有該類的public方法都配置相同的事務(wù)屬性信息。
- 作用于方法:當類配置了@Transactional,方法也配置了@Transactional,方法的事務(wù)會覆蓋類的事務(wù)配置信息。
- 作用于接口:不推薦這種使用方法,因為一旦標注在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ù)的傳播行為,默認值為 Propagation.REQUIRED,其他的屬性信息如下:
Propagation.REQUIRED:如果當前存在事務(wù),則加入該事務(wù),如果當前不存在事務(wù),則創(chuàng)建一個新的事務(wù)。( 也就是說如果A方法和B方法都添加了注解,在默認傳播模式下,A方法內(nèi)部調(diào)用B方法,會把兩個方法的事務(wù)合并為一個事務(wù) )Propagation.SUPPORTS:如果當前存在事務(wù),則加入該事務(wù);如果當前不存在事務(wù),則以非事務(wù)的方式繼續(xù)運行。Propagation.MANDATORY:如果當前存在事務(wù),則加入該事務(wù);如果當前不存在事務(wù),則拋出異常。Propagation.REQUIRES_NEW:重新創(chuàng)建一個新的事務(wù),如果當前存在事務(wù),暫停當前的事務(wù)。( 當類A中的 a 方法用默認Propagation.REQUIRED模式,類B中的 b方法加上采用 Propagation.REQUIRES_NEW模式,然后在 a 方法中調(diào)用 b方法操作數(shù)據(jù)庫,然而 a方法拋出異常后,b方法并沒有進行回滾,因為Propagation.REQUIRES_NEW會暫停 a方法的事務(wù) )Propagation.NOT_SUPPORTED:以非事務(wù)的方式運行,如果當前存在事務(wù),暫停當前的事務(wù)。Propagation.NEVER:以非事務(wù)的方式運行,如果當前存在事務(wù),則拋出異常。Propagation.NESTED:和 Propagation.REQUIRED 效果一樣。
isolation 屬性
isolation :事務(wù)的隔離級別,默認值為Isolation.DEFAULT
Isolation.DEFAULT:使用底層數(shù)據(jù)庫默認的隔離級別。Isolation.READ_UNCOMMITTED:讀未提交Isolation.READ_COMMITTED:讀已提交Isolation.REPEATABLE_READ:可重復(fù)讀Isolation.SERIALIZABLE:串行化
timeout 屬性
- timeout :事務(wù)的超時時間,默認值為 -1。
- 如果超過該時間限制但事務(wù)還沒有完成,則自動回滾事務(wù)。
readOnly 屬性
- readOnly :指定事務(wù)是否為只讀事務(wù),默認值為 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,因為接口的權(quán)限修飾符只能是public,所以其他的修飾符不可以使用,cglib代理的方式是可以代理protected方法的如果支持protected,大概率會造成當切換代理的實現(xiàn)方式時表現(xiàn)不同,所以會出現(xiàn)很多的bug,然后造成一系列的問題

之所以會失效是因為在Spring AOP 代理時,如上圖所示 TransactionInterceptor (事務(wù)攔截器)在目標方法執(zhí)行前后進行攔截,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;
}這個方法會檢查目標方法的修飾符是不是 public,若不是 public,就不會獲取@Transactional 的屬性配置信息,最終會造成不會用 TransactionInterceptor 來攔截該目標方法進行事務(wù)管理。
2、@Transactional 注解屬性 propagation 設(shè)置錯誤
這種失效是由于配置錯誤,若是錯誤的配置以下三種 propagation,事務(wù)將不會發(fā)生回滾。
TransactionDefinition.PROPAGATION_SUPPORTS:如果當前存在事務(wù),則加入該事務(wù);如果當前沒有事務(wù),則以非事務(wù)的方式繼續(xù)運行。TransactionDefinition.PROPAGATION_NOT_SUPPORTED:以非事務(wù)方式運行,如果當前存在事務(wù),則把當前事務(wù)掛起。TransactionDefinition.PROPAGATION_NEVER:以非事務(wù)方式運行,如果當前存在事務(wù),則拋出異常。
3、@Transactional 注解屬性 rollbackFor 設(shè)置錯誤
rollbackFor 可以指定能夠觸發(fā)事務(wù)回滾的異常類型。
Spring默認拋出了未檢查unchecked異常(繼承自 RuntimeException 的異常)或者 Error才回滾事務(wù);其他異常不會觸發(fā)回滾事務(wù)。
如果在事務(wù)中拋出其他類型的異常,但卻期望 Spring 能夠回滾事務(wù),就需要指定 rollbackFor屬性。

若在目標方法中拋出的異常是 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)這種情況?其實這還是由于使用Spring AOP代理造成的,因為只有當事務(wù)方法被當前類以外的代碼調(diào)用時,才會由Spring生成的代理對象來管理。
錯誤入下:(但反過來(transactionalTest方法(@Transactional在transactionalTest方法上)調(diào)用Test方法)可以讓@Transactional生效)
@RestController
@Slf4j
public class TestController {
@Autowired
UserService userService;
@RequestMapping("/test")
public void Test(){
// 這里就相當于使用了 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()獲得當前代理對象,注意:類上也需要加@EnableAspectJAutoProxy注解(推薦)
@RestController
@Slf4j
@EnableAspectJAutoProxy(proxyTargetClass = true,exposeProxy = true)
public class TestController {
@Autowired
UserService userService;
@RequestMapping("/test")
public void Test(){
// 這里就相當于使用了 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)用(這個就不細說了)
- 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、實現(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認為你是正常運行的代碼所以不回滾
@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 拋出異常呢,因為要記日志啊,不記日志的話也可以不用,但哪個不寫報錯日志,出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ù)庫默認使用支持事務(wù)的innodb引擎。
一旦數(shù)據(jù)庫引擎切換成不支持事務(wù)的myisam,那事務(wù)就從根本上失效了。
總結(jié)
@Transactional非常的好用,只需要一個注解就可以不用管事務(wù)操作了,只需要注重自己的業(yè)務(wù)代碼就可以了
@Transactional也有缺點,比如你要注意上訴的幾種失效情況,他有個局限性,他的最小粒度要作用在方法上,也就是說,如果想要給一部分代碼塊增加事務(wù)的話,那就需要把這個部分代碼塊單獨獨立出來作為一個方法。而且AOP要生成一個動態(tài)代理類,所以會慢一點
但是誰會管這些啊,好用就行了,也不是不能忍的問題,這跟他的好處根本不成正比,當然如果要使用編程式事務(wù)也可以,看個人愛好,反之小編一直用的是@Transactional,Spring官方也推薦使用@Transactional,所以了解了怎么使用之后,大膽的用就好了
這種情況出現(xiàn)的概率并不高,事務(wù)能否生效數(shù)據(jù)庫引擎是否支持事務(wù)是關(guān)鍵。常用的MySQL數(shù)據(jù)庫默認使用支持事務(wù)的innodb引擎。一旦數(shù)據(jù)庫引擎切換成不支持事務(wù)的myisam,那事務(wù)就從根本上失效了。
以上為個人經(jīng)驗,希望能給大家一個參考,也希望大家多多支持腳本之家。
相關(guān)文章
詳解springboot-mysql-pagehelper分頁插件集成
這篇文章主要介紹了springboot-mysql-pagehelper分頁插件集成,本文通過實例代碼給大家介紹的非常詳細,對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值,需要的朋友可以參考下2023-07-07
Java基于jeeplus vue實現(xiàn)簡單工作流過程圖解
這篇文章主要介紹了Java基于jeeplus vue實現(xiàn)簡單工作流過程圖解,文中通過示例代碼介紹的非常詳細,對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下2020-04-04
java實現(xiàn)html轉(zhuǎn)pdf方法步驟
這篇文章主要給大家介紹了關(guān)于java實現(xiàn)html轉(zhuǎn)pdf方法的相關(guān)資料,要將HTML轉(zhuǎn)換成PDF,我們需要借助Java中的第三方庫,文中通過示例代碼介紹的非常詳細,需要的朋友可以參考下2023-08-08

