您好,登錄后才能下訂單哦!
這篇文章主要介紹“Spring事務(wù)失效的場(chǎng)景分析”的相關(guān)知識(shí),小編通過實(shí)際案例向大家展示操作過程,操作方法簡(jiǎn)單快捷,實(shí)用性強(qiáng),希望這篇“Spring事務(wù)失效的場(chǎng)景分析”文章能幫助大家解決問題。
使用Spring事務(wù)的前提是:對(duì)象要被Spring管理,事務(wù)方法所在的類要被加載為bean對(duì)象
如果事務(wù)方法所在的類沒有被加載為一個(gè)bean,那么事務(wù)自然就失效了,示例:
//@Service public class UserServiceImpl { @Transactional public void doTest() { // 業(yè)務(wù)代碼 } }
以MySQL為例,InnoDB
引擎是支持事務(wù)的,而像MyISAM
、MEMORY
等是不支持事務(wù)的。
從MySQL5.5.5開始默認(rèn)的存儲(chǔ)引擎是InnoDB
,之前默認(rèn)都是MyISAM
。所以在開發(fā)過程中發(fā)現(xiàn)事務(wù)失效,不一定是Spring的鍋,最好確認(rèn)一下數(shù)據(jù)庫表是否支持事務(wù)。
眾所周知,java的訪問權(quán)限修飾符有:private
、default
、protected
、public
四種,
但是@Transactional
注解只能作用于public
修飾的方法上,
在AbstractFallbackTransactionAttributeSource
類(Spring通過這個(gè)類獲取@Transactional注解的配置屬性信息)的computeTransactionAttribute
方法中有個(gè)判斷,如果目標(biāo)方法不是public
,則TransactionAttribute
返回null
,即不支持事務(wù)。
@Nullable protected TransactionAttribute computeTransactionAttribute(Method method, @Nullable Class<?> targetClass) { // Don't allow no-public methods as required. if (allowPublicMethodsOnly() && !Modifier.isPublic(method.getModifiers())) { return null; } //……………… }
其實(shí)想想動(dòng)態(tài)代理的原理就很好理解了,動(dòng)態(tài)代理是通過實(shí)現(xiàn)接口或者繼承來實(shí)現(xiàn)的,所以目標(biāo)方法必須是public修飾,并且不能是final修飾。
如果一個(gè)方法不想被子類重寫,那么我們就可以把他寫成final
修飾的方法
如果事務(wù)方法使用final
修飾,那么aop就無法在代理類中重寫該方法,事務(wù)就不會(huì)生效
同樣的,static
修飾的方法也無法通過代理變成事務(wù)方法
假如在某個(gè)Service的方法中,調(diào)用了另外一個(gè)事務(wù)方法:
@Service public class UserServiceImpl { @Autowired UserMapper userMapper; public void del(){ doTest(); } @Transactional public void doTest() { userMapper.deleteById(200108); int i = 10/0; //模擬發(fā)生異常 } }
像上面的代碼,doTest
方法使用@Transactional
注解標(biāo)注,在del()
方法中調(diào)用了doTest()
方法,在外部調(diào)用del()
方法時(shí),事務(wù)也不會(huì)生效,因?yàn)檫@里del()
方法中調(diào)用的是類本身的方法,而不是代理對(duì)象的方法。
那么如果確實(shí)有這樣的需求怎么辦呢?
引入自身bean
@Service public class UserServiceImpl { @Autowired UserMapper userMapper; @Autowired UserServiceImpl userServiceImpl; public void del(){ userServiceImpl.doTest(); } @Transactional public void doTest() { userMapper.deleteById(200112); int i = 10/0; //模擬發(fā)生異常 } }
通過ApplicationContext
引入bean
@Service public class UserServiceImpl { @Autowired UserMapper userMapper; @Autowired ApplicationContext applicationContext; public void del(){ ((UserServiceImpl)applicationContext.getBean("userServiceImpl")).doTest(); } @Transactional public void doTest() { userMapper.deleteById(200112); int i = 10/0; //模擬發(fā)生異常 } }
通過AopContext獲取當(dāng)前代理類
在啟動(dòng)類上添加注解@EnableAspectJAutoProxy(exposeProxy = true)
,表示是否對(duì)外暴露代理對(duì)象,即是否可以獲取AopContext
@Service public class UserServiceImpl { @Autowired UserMapper userMapper; @Autowired ApplicationContext applicationContext; public void del(){ ((UserServiceImpl)AopContext.currentProxy()).doTest(); } @Transactional public void doTest() { userMapper.deleteById(200112); int i = 10/0; //模擬發(fā)生異常 } }
如果是SpringBoot
項(xiàng)目,那么SpringBoot
通過DataSourceTransactionManagerAutoConfiguration
自動(dòng)配置類幫我們開啟了事務(wù)。
如果是傳統(tǒng)的Spring
項(xiàng)目,則需要我們自己配置
<!-- 配置事務(wù)管理器--> <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"> <property name="dataSource" ref="dataSource"/> </bean> <!-- 配置事務(wù)通知--> <tx:advice id="Advice" transaction-manager="transactionManager"> <!-- 配置事務(wù)屬性,即哪些方法要執(zhí)行事務(wù)--> <tx:attributes> <tx:method name="insert*" propagation="REQUIRED"/> <!-- 所有insert開頭的方法,以下同理 --> <tx:method name="update*" propagation="REQUIRED"/> <tx:method name="delete*" propagation="REQUIRED"/> </tx:attributes> </tx:advice> <!-- 配置事務(wù)切面--> <aop:config> <aop:pointcut id="AdviceAop" expression="execution(* com.yy.service..*(..))"/> <!--要執(zhí)行的方法在哪個(gè)包,意思為:com.yy.service下的所有包里面的包含任意參數(shù)的所有方法--> <aop:advisor advice-ref="Advice" pointcut-ref="AdviceAop"/> <!-- 配置為AdviceAop執(zhí)行哪個(gè)事務(wù)通知 --> </aop:config>
這樣在執(zhí)行service包下的增刪改操作的方法時(shí),就開啟事務(wù)了,或者使用注解的方式
<!-- 配置事務(wù)管理器--> <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"> <property name="dataSource" ref="dataSource"/> </bean> <!-- 注解式事務(wù)聲明配置--> <tx:annotation-driven transaction-manager="transactionManager" />
@Service public class UserServiceImpl { @Autowired UserMapper userMapper; @Transactional public void doTest() throws InterruptedException { userMapper.deleteById(200110); new Thread(()->{ userMapper.deleteById(200112); int i = 10/0; //模擬發(fā)生異常 }).start(); } }
在事務(wù)方法doTest
中,啟動(dòng)了一個(gè)新的線程,并在新的線程中發(fā)生了異常,這樣doTest
是不會(huì)回滾的。
因?yàn)閮蓚€(gè)操作不在一個(gè)線程中,獲取到的數(shù)據(jù)庫連接不一樣,從而是兩個(gè)不同的事務(wù),所以也不會(huì)回滾。
Spring定義了7種傳播行為,我們可以通propagation
屬性來指定傳播行為參數(shù),目前只有REQUIRED
、REQUIRES_NEW
、NESTED
會(huì)創(chuàng)建新的事務(wù),其他的則會(huì)以非事務(wù)的方式運(yùn)行或者拋出異常
@Service public class UserServiceImpl { @Autowired UserMapper userMapper; @Transactional(propagation = Propagation.NEVER) public void doTest() throws InterruptedException { userMapper.deleteById(200114); int i = 10/0; //模擬發(fā)生異常 } }
如果沒有異常拋出,則Spring認(rèn)為程序是正常的,就不會(huì)回滾
@Service public class UserServiceImpl { @Autowired UserMapper userMapper; @Transactional public void doTest() { try{ userMapper.deleteById(200115); int i = 10/0; //模擬發(fā)生異常 }catch (Exception e){ // 異常操作 } } }
Spring默認(rèn)只會(huì)回滾RuntimeException
和Error
對(duì)于普通的Exception
,不會(huì)回滾
如果你想觸發(fā)其他異常的回滾,需要在注解上配置一下,如:@Transactional(rollbackFor = Exception.class)
@Service public class UserServiceImpl { @Autowired UserMapper userMapper; @Transactional public void doTest() throws Exception { try{ userMapper.deleteById(200116); int i = 10/0; //模擬發(fā)生異常 }catch (Exception e){ // 異常操作 throw new Exception(); } } }
rollbackFor 用于指定能夠觸發(fā)事務(wù)回滾的異常類型,可以指定多個(gè)異常類型。
默認(rèn)是在RuntimeException和Error上回滾。
若異常非配置指定的異常類,則事務(wù)失效
@Service public class UserServiceImpl { @Autowired UserMapper userMapper; @Transactional(rollbackFor = NullPointerException.class) public void doTest() throws MyException { userMapper.deleteById(200118); throw new MyException(); } }
即使rollbackFor有默認(rèn)值,但阿里巴巴開發(fā)者規(guī)范中,還是要求開發(fā)者重新指定該參數(shù)。
因?yàn)槿绻褂媚J(rèn)值,一旦程序拋出了Exception,事務(wù)不會(huì)回滾,這會(huì)出現(xiàn)很大的bug。所以,建議一般情況下,將該參數(shù)設(shè)置成:Exception或Throwable。
@Service public class UserServiceImpl { @Autowired UserMapper userMapper; @Transactional public void doTest() { userMapper.deleteById(200118); ((UserServiceImpl)AopContext.currentProxy()).test02(); } @Transactional(propagation = Propagation.NESTED) public void test02(){ userMapper.deleteById(200119); int i = 10 / 0; //模擬發(fā)生異常 } }
test02()
方法出現(xiàn)了異常,沒有手動(dòng)捕獲,會(huì)繼續(xù)往上拋,到外層doTest()
方法的代理方法中捕獲了異常。所以,這種情況是直接回滾了整個(gè)事務(wù),不只回滾單個(gè)保存點(diǎn)。
如果只回滾單個(gè)保存點(diǎn),可以將內(nèi)部嵌套事務(wù)放在try/catch中,類似于上面的自己try…catch…掉異常,并且不繼續(xù)往上拋異常。這樣就能保證,如果內(nèi)部嵌套事務(wù)中出現(xiàn)異常,只回滾內(nèi)部事務(wù),而不影響外部事務(wù)。
@Service public class UserServiceImpl { @Autowired UserMapper userMapper; @Transactional public void doTest() { userMapper.deleteById(200118); try{ ((UserServiceImpl)AopContext.currentProxy()).test02(); }catch (Exception e){ } } @Transactional(propagation = Propagation.NESTED) public void test02(){ userMapper.deleteById(200119); int i = 10 / 0; //模擬發(fā)生異常 } }
關(guān)于“Spring事務(wù)失效的場(chǎng)景分析”的內(nèi)容就介紹到這里了,感謝大家的閱讀。如果想了解更多行業(yè)相關(guān)的知識(shí),可以關(guān)注億速云行業(yè)資訊頻道,小編每天都會(huì)為大家更新不同的知識(shí)點(diǎn)。
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。