有時候,我們明明在類或者方法上添加了@Transactional註解,卻發現方法並沒有按事務處理。其實,以下場景會導致事務失效。 1、事務方法所在的類沒有載入到Spring IOC容器中。 @Transactional是Spring的註解,未被Spring管理的類中的方法不受@Transaction ...
有時候,我們明明在類或者方法上添加了@Transactional註解,卻發現方法並沒有按事務處理。其實,以下場景會導致事務失效。
1、事務方法所在的類沒有載入到Spring IOC容器中。
@Transactional是Spring的註解,未被Spring管理的類中的方法不受@Transactional註解控制,這個應該很好理解。
2、方法沒有被public修飾。
眾所周知,java的訪問許可權修飾符有:private、default、protected、public四種,但是@Transactional註解只能作用於public修飾的方法上。之所以會失效是因為在Spring AOP 代理時,TransactionInterceptor (事務攔截器)在目標方法執行前後進行攔截,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 註解,雖然事務無效,但不會有任何報錯,這是我們很容犯錯的一點。
3、在同一個類中的方法調用。
假如在同一個類中有A、B兩個方法,如下:
@Service public class UserServiceImpl { @Autowired UserMapper userMapper; public void A() { B(); } @Transactional public void B() { userMapper.deleteById(1); int i = 10 / 0; //模擬發生異常 } }
像上面的代碼,B方法使用@Transactional註解標註,在A方法中調用了B方法,在外部調用A方法時,B方法的事務不會生效。這是由於使用Spring AOP代理造成的,因為只有當事務方法被當前類以外的代碼調用時,才會由Spring生成的代理對象來管理。
那麼如果確實在同一類中調用事務方法怎麼辦呢?有以下3種方法解決:
- 引入自身bean
@Service public class UserServiceImpl { @Autowired UserMapper userMapper; @Autowired UserServiceImpl userServiceImpl; public void A() { userServiceImpl.B(); } @Transactional public void B() { userMapper.deleteById(1); int i = 10 / 0; //模擬發生異常 } }
- 通過 ApplicationContext 引入bean
@Service public class UserServiceImpl { @Autowired UserMapper userMapper; @Autowired ApplicationContext applicationContext; public void A() { ((UserServiceImpl) applicationContext.getBean("userServiceImpl")).B(); } @Transactional public void B() { userMapper.deleteById(1); int i = 10 / 0; //模擬發生異常 } }
- 通過 AopContext 獲取當前代理類
在啟動類上添加註解@EnableAspectJAutoProxy(exposeProxy = true),表示是否對外暴露代理對象,即是否可以獲取AopContext。
@Service public class UserServiceImpl { @Autowired UserMapper userMapper; public void A() { ((UserServiceImpl) AopContext.currentProxy()).B(); } @Transactional public void B() { userMapper.deleteById(1); int i = 10 / 0; //模擬發生異常 } }
4、方法的事務傳播類型不支持事務。
若propagation屬性設置如下三種事務傳播行為,事務將不會發生回滾。
1、SUPPORTS:如果當前存在事務,則加入該事務;如果當前沒有事務,則以非事務的方式繼續運行。
2、NOT_SUPPORTED:以非事務方式運行,如果當前存在事務,則把當前事務掛起。
3、NEVER:以非事務方式運行,如果當前存在事務,則拋出異常。
Spring事務傳播行為可以查閱我之前的一篇文章:Spring事務(一)-事務傳播行為
5、不正確地捕獲異常。
使用了try-catch代碼塊將異常捕捉了,沒有向上拋出異常,事務不會回滾。
@Transactional private void A() throws Exception { @Autowired UserMapper userMapper; try { //A方法插入數據 User u = New User(); u.setId(1); u.setName("張三"); userMapper.insert(u); /** * B方法也插入數據 */ b.insert(); } catch (Exception e) { e.printStackTrace(); } }
上面的代碼,如果B方法內部拋了異常,而A方法此時try catch了B方法的異常,那麼,事務並不會回滾,而且會拋出如下異常:
org.springframework.transaction.UnexpectedRollbackException: Transaction rolled back because it has been marked as rollback-only
因為當ServiceB中拋出了一個異常以後,ServiceB標識當前事務需要rollback。但是ServiceA中由於你手動的捕獲這個異常併進行處理,ServiceA認為當前事務應該正常commit。此時就出現了前後不一致,也就是因為這樣,拋出了前面的UnexpectedRollbackException異常。
6、屬性rollbackFor 設置錯誤。
rollbackFor 可以指定能夠觸發事務回滾的異常類型。Spring預設拋出了未檢查unchecked異常(繼承自 RuntimeException 的異常)或者 Error才回滾事務;其他異常不會觸發回滾事務。如果在事務中拋出其他類型的異常,但卻期望 Spring 能夠回滾事務,就需要指定 rollbackFor 屬性。
7、資料庫不支持事務。
事務本來就是資料庫的功能,如果資料庫本身不支持事務,那任憑代碼上如何設置也是沒用的。以MySQL為例,InnoDB引擎是支持事務的,而像MyISAM、MEMORY等是不支持事務的。 從MySQL5.5.5開始預設的存儲引擎是InnoDB,之前預設都是MyISAM。
8、方法使用final修飾。
如果一個方法不想被子類重寫,那麼我們就可以把他寫成final修飾的方法。如果事務方法使用final修飾,那麼AOP就無法在代理類中重寫該方法,事務就不會生效。同樣的,static修飾的方法也無法通過代理變成事務方法。
9、未開啟事務。
如果是SpringBoot項目,那麼SpringBoot通過DataSourceTransactionManagerAutoConfiguration自動配置類幫我們開啟了事務。如果是傳統的Spring項目,則需要我們自己配置。在Spring配置文件配置如下:
<!--事務管理器配置--> <bean id="transactionManager" class="org.springframework.orm.jpa.JpaTransactionManager"> <property name="entityManagerFactory" ref="entityManagerFactory"/> </bean> <tx:advice id="txAdvice" 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 proxy-target-class="true" expose-proxy="true"> <!-- 只對業務邏輯層實施事務 --> <aop:pointcut id="txPointcut" expression="execution( * com.posun..service.impl..*+.*(..)) || execution(* com.posun..task..*+.*(..)) || execution(* com.posun.report.ReportJdbc.*(..)) "/> <aop:advisor id="txAdvisor" advice-ref="txAdvice" pointcut-ref="txPointcut"/> </aop:config>
或者,使用註解的方式。
<!-- 配置事務管理器--> <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"> <property name="dataSource" ref="dataSource"/> </bean> <!-- 註解式事務聲明配置--> <tx:annotation-driven transaction-manager="transactionManager" />
10、多線程調用
@Service public class UserServiceImpl { @Autowired UserMapper userMapper; @Transactional public void A() { userMapper.deleteById(1); new Thread(()->{ userMapper.deleteById(2); int i = 10/0; //模擬發生異常 }).start(); } }
以上代碼,A方法中,啟動了一個新的線程,併在新的線程中發生了異常,這樣A方法是不會發生回滾的。因為兩個操作不在一個線程中,獲取到的資料庫連接不一樣,從而是兩個不同的事務,所以也不會回滾。