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