java同一個類中,一個無事務(wù)方法調(diào)用一個有事務(wù)方法時,事務(wù)失效問題
事務(wù)的使用
在spring項目的開發(fā)中,通過在方法上添加Transactional注解,實現(xiàn)事務(wù)的管理,在方法開始開啟事務(wù),出現(xiàn)異常進行事務(wù)的回滾,方法結(jié)束前提交事務(wù)。
事務(wù)的實現(xiàn)原理
Transactional
注解是 Spring 框架用來實現(xiàn)聲明式事務(wù)管理的重要工具。其原理主要基于 AOP(面向切面編程),通過動態(tài)代理在方法執(zhí)行前、后以及異常情況下進行事務(wù)的處理。
當你在一個方法上使用 @Transactional
注解時,Spring 會在運行時生成一個代理對象,該對象會攔截對該方法的調(diào)用。
在調(diào)用之前,代理會開始一個新的事務(wù);在方法執(zhí)行完成后,代理會提交或回滾事務(wù),具體取決于方法是否拋出了未處理的異常。
具體流程如下:
- spring使用jdk動態(tài)代理技術(shù)或者cglib代理來創(chuàng)建目標類的代理對象
- 當方法被調(diào)用時,實際上調(diào)用的是代理類中的增強方法,而不是直接調(diào)用目標類中的方法
- 在調(diào)用方法之前,代理會根據(jù)注解的屬性(傳播行為和隔離級別)從
PlatformTransactionManager
中獲取一個事務(wù),在調(diào)用目標方法前開啟事務(wù) - 執(zhí)行目標方法
- 目標方法執(zhí)行成功,則提交事務(wù),執(zhí)行失敗,則回滾事務(wù)
代理的兩種方式:
- JDK 動態(tài)代理:當目標類實現(xiàn)至少一個接口時,Spring會使用JDK動態(tài)代理。這種代理僅適用于基于接口的代理。原理是通過Java反射機制,在運行時生成一個實現(xiàn)了目標類接口的代理類。
- CGLIB 代理:如果目標類沒有實現(xiàn)任何接口,或者您強制配置為使用CGLIB,那么Spring會使用CGLIB庫生成一個目標類的子類作為代理。原理是使用CGLIB庫,通過繼承目標類并重寫其方法來實現(xiàn)代理。
原因
在同一個類中,一個無事務(wù)方法直接調(diào)用有事務(wù)的方法時,是通過this.方法名的方式調(diào)用。
this方式:它直接訪問的是當前對象的實現(xiàn),如果當前類被Spring AOP代理,那么使用this
調(diào)用的方法將不會觸發(fā)AOP切面。也就是說,切面(如事務(wù)管理、日志記錄等)不會生效,因為你直接調(diào)用了目標對象的方法,而不是代理對象的方法。
通過Autowired注解注入的bean進行調(diào)用的方式:是通過spring容器管理的代理對象進行調(diào)用,這種情況下AOP特性可以正常工作,例如事務(wù)、日志等會生效。
Spring容器管理的代理對象的生成條件和時機
在Spring中,代理對象的生成通常與AOP(面向切面編程)相關(guān),當類上使用@Component
、@Service
、@Repository
或@Controller
等注解,并且方法上使用AOP相關(guān)的注解時,Spring會創(chuàng)建代理對象,以便能夠在調(diào)用這些方法時執(zhí)行切面邏輯。
常見的AOP注解包括:
@Transactional
@Cacheable
@Async
@Scheduled
事務(wù)失效代碼
package com.ruoyi.system.service.impl; import com.ruoyi.common.core.domain.entity.SysDept; import com.ruoyi.system.domain.SysConfig; import com.ruoyi.system.mapper.SysConfigMapper; import com.ruoyi.system.mapper.SysDeptMapper; import com.ruoyi.system.service.TestTransactionalService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; /** * @Author linaibo * @Date 2024/8/3 15:36 * @Version 1.0 */ @Service public class TestTransactionalServiceImpl implements TestTransactionalService { @Autowired private SysDeptMapper deptMapper; @Autowired private SysConfigMapper configMapper; @Override public int insertDept(SysDept dept) { dept.setAncestors("123123"); deptMapper.insertDept(dept); insertConfig(); return 1; } @Override @Transactional(rollbackFor = Exception.class) public int insertConfig() { SysConfig config; for (int i = 0; i < 5; i++) { config = new SysConfig(); config.setConfigName("配置" + i); configMapper.insertConfig(config); if (i == 2) { throw new RuntimeException(); } } return 1; } }
解決方法
①自己autowire自己(也可以將方法放到另外一個service中,然后注入該service進行調(diào)用)
package com.ruoyi.system.service.impl; import com.ruoyi.common.core.domain.entity.SysDept; import com.ruoyi.system.domain.SysConfig; import com.ruoyi.system.mapper.SysConfigMapper; import com.ruoyi.system.mapper.SysDeptMapper; import com.ruoyi.system.service.TestTransactionalService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; /** * @Author linaibo * @Date 2024/8/3 15:36 * @Version 1.0 */ @Service public class TestTransactionalServiceImpl implements TestTransactionalService { @Autowired private SysDeptMapper deptMapper; @Autowired private SysConfigMapper configMapper; @Autowired private TestTransactionalService testTransactionalService; @Override public int insertDept(SysDept dept) { dept.setAncestors("123123"); deptMapper.insertDept(dept); testTransactionalService.insertConfig(); return 1; } @Override @Transactional(rollbackFor = Exception.class) public int insertConfig() { SysConfig config; for (int i = 0; i < 5; i++) { config = new SysConfig(); config.setConfigName("配置" + i); configMapper.insertConfig(config); if (i == 2) { throw new RuntimeException(); } } return 1; } }
②通過spring上下文獲取到當前代理類
package com.ruoyi.system.service.impl; import com.ruoyi.common.core.domain.entity.SysDept; import com.ruoyi.system.domain.SysConfig; import com.ruoyi.system.mapper.SysConfigMapper; import com.ruoyi.system.mapper.SysDeptMapper; import com.ruoyi.system.service.TestTransactionalService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.context.ApplicationContext; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; /** * @Author linaibo * @Date 2024/8/3 15:36 * @Version 1.0 */ @Service public class TestTransactionalServiceImpl implements TestTransactionalService { @Autowired private SysDeptMapper deptMapper; @Autowired private SysConfigMapper configMapper; @Autowired private TestTransactionalService testTransactionalService; @Autowired private ApplicationContext applicationContext; @Override public int insertDept(SysDept dept) { dept.setAncestors("123123"); deptMapper.insertDept(dept); TestTransactionalService service = applicationContext.getBean(TestTransactionalService.class); service.insertConfig(); return 1; } @Override @Transactional(rollbackFor = Exception.class) public int insertConfig() { SysConfig config; for (int i = 0; i < 5; i++) { config = new SysConfig(); config.setConfigName("配置" + i); configMapper.insertConfig(config); if (i == 2) { throw new RuntimeException(); } } return 1; } }
③使用AopContext獲取到當前代理類,需要在啟動類加上EnableAspectJAutoProxy(exposeProxy = true),exposeProxy = true用于控制AOP框架公開代理,公開后才可以通過AopContext獲取到當前代理類。
package com.ruoyi.system.service.impl; import com.ruoyi.common.core.domain.entity.SysDept; import com.ruoyi.system.domain.SysConfig; import com.ruoyi.system.mapper.SysConfigMapper; import com.ruoyi.system.mapper.SysDeptMapper; import com.ruoyi.system.service.TestTransactionalService; import org.springframework.aop.framework.AopContext; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.context.ApplicationContext; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import java.util.Objects; /** * @Author linaibo * @Date 2024/8/3 15:36 * @Version 1.0 */ @Service public class TestTransactionalServiceImpl implements TestTransactionalService { @Autowired private SysDeptMapper deptMapper; @Autowired private SysConfigMapper configMapper; @Override public int insertDept(SysDept dept) { dept.setAncestors("123123"); deptMapper.insertDept(dept); TestTransactionalService service = Objects.nonNull(AopContext.currentProxy()) ? (TestTransactionalService)AopContext.currentProxy() : this; service.insertConfig(); return 1; } @Override @Transactional(rollbackFor = Exception.class) public int insertConfig() { SysConfig config; for (int i = 0; i < 5; i++) { config = new SysConfig(); config.setConfigName("配置" + i); configMapper.insertConfig(config); if (i == 2) { throw new RuntimeException(); } } return 1; } }
總結(jié)
使用 AOP 注解:
- 如果
TestTransactionalService
類上使用了 AOP 相關(guān)的注解(如@Transactional
,@Aspect
,@Around
等) - 通過
applicationContext.getBean(TestTransactionalService.class)
獲取的對象將是一個代理對象
代理對象的創(chuàng)建是為了在方法調(diào)用前后加入額外的行為,比如事務(wù)管理、日志記錄等。
未使用 AOP 注解:
- 如果該類沒有任何 AOP 相關(guān)的注解
- 獲取的對象就是普通的 Bean
- 沒有經(jīng)過 AOP 的增強
以上為個人經(jīng)驗,希望能給大家一個參考,也希望大家多多支持腳本之家。
相關(guān)文章
SpringBoot 整合 Shiro 密碼登錄與郵件驗證碼登錄功能(多 Realm 認證)
這篇文章主要介紹了SpringBoot 整合 Shiro 密碼登錄與郵件驗證碼登錄(多 Realm 認證),本文通過實例代碼給大家介紹的非常詳細,對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值,需要的朋友可以參考下2021-02-02Java中使用StackWalker和Stream API進行堆棧遍歷
StackWalking API是添加到Java中最酷的(并且對大多數(shù)開發(fā)人員來說完全不切實際,一般不會用,除非深層跟蹤調(diào)優(yōu))的功能之一。在這篇簡短的文章中,我們將看到它是什么以及使用它有多么容易,很快的認識它2018-09-09SpringBoot多線程與任務(wù)調(diào)度總結(jié)
多線程與任務(wù)調(diào)度是java開發(fā)中必須掌握的技能,本文主要介紹了SpringBoot多線程與任務(wù)調(diào)度總結(jié),具有一定的參考價值,感興趣的可以了解一下2023-12-12Java網(wǎng)絡(luò)編程之簡易聊天室的實現(xiàn)
這篇文章主要為大家詳細介紹了如何利用Java語言實現(xiàn)一個簡易聊天室功能,可以實現(xiàn)運行客戶端和連接服務(wù)器,文中的示例代碼講解詳細,需要的可以了解一下2022-10-10