Java的@Transactional、@Aysnc、事務(wù)同步問題詳解
場景
我們要做的事情很簡單：
- 現(xiàn)在我們需要在一個(gè)業(yè)務(wù)方法中插入一個(gè)用戶，
- 這個(gè)業(yè)務(wù)方法我們需要加上事務(wù)，
- 然后插入用戶后，我們要異步的方式打印出數(shù)據(jù)庫中所有存在的用戶。
最初版本
我們的代碼在最開始，可能是如下：
TestController
@RestController
@RequestMapping("test")
public class TestController {
@Autowired
private TestService testService;
@GetMapping("testTx")
public String testTx() {
testService.doTx();
return "ok";
}
}TestService
@Slf4j
@Service
@EnableAsync // 開啟異步
@EnableTransactionManagement // 開啟事務(wù)
public class TestService {
@Autowired
private UserService userService;
@Transactional
public void doTx(){
log.info("-----------------doTx-----------------" + this.getClass());
User user = new User();
user.setNickname(RandomStringUtils.randomAlphabetic(5));
userService.save(user); // 插入用戶
log.info("插入用戶：{}" , user);
printUserList(); // 我們希望的是異步打印所有的用戶
log.info("-----------------doTx-----------------");
try {
Thread.sleep(3000); // 這里還需要干其它的活,反正就是這里不確定,萬一它就卡在這里了呢, 就模擬這個(gè)情況
} catch (InterruptedException e) {
e.printStackTrace();
}
}
@Async
public void printUserList() {
log.info("-----------------printUserList-----------------" + this.getClass());
List<User> list = userService.list(new QueryWrapper<User>());
for (User user1 : list) {
log.info("printUser: {}",user1);
}
log.info("-----------------printUserList-----------------");
}
}
問題
我們訪問上面的這個(gè)接口：//localhost:8085/web-api/test/testTx，輸出如下的日志。
發(fā)現(xiàn)問題：可以看到 保存用戶 和 異步打印所有用戶 用的是同一個(gè)線程，說好的異步?jīng)]有了，為什么沒有異步了呢？可以看到我們使用的仍然是TestService而不是代理對象，所以直接就是調(diào)用的就是TestService類的方法，而異步注解是基于代理的（但不是基于自動(dòng)代理創(chuàng)建器的），所以就有問題了。
@Lazy版本 + 事務(wù)同步
既然，上面我們知道了，是由于沒有調(diào)用代理，所以異步打印所有用戶仍然用的是原來的線程。那么再問一句：TestService沒有被代理嗎？它的的確確被代理了，是因?yàn)锧Transactional讓它做了事務(wù)代理，但是事務(wù)代理基于的就是aop，aop責(zé)任鏈調(diào)用的最終節(jié)點(diǎn)，調(diào)用的是真實(shí)對象，所以那里就用的是真實(shí)對象去打印，那可不就沒代理了嘛！
原因，我們也知道了，那我們可以讓它自己注入自己，發(fā)現(xiàn)啟動(dòng)報(bào)錯(cuò)，啟動(dòng)報(bào)錯(cuò)的原因在于@Async實(shí)現(xiàn)代理的方式 和 aop的自動(dòng)代理方式 用的不是同一個(gè)代理創(chuàng)建器。在一般情況下，自己注入自己的確是可以解決這種循環(huán)依賴 + 自動(dòng)代理的問題的（或者用AopContxt.currentProxy()獲取到綁定到當(dāng)前線程的代理對象），但是一旦碰到這種@Async 和 aop自動(dòng)代理的情況，由于有2個(gè)代理創(chuàng)建器存在，且它們都要對這個(gè)對象進(jìn)行代理，那就有問題了。會(huì)報(bào)如下的錯(cuò)誤：
Caused by: org.springframework.beans.factory.BeanCurrentlyInCreationException: Error creating bean with name 'testService': Bean with name 'testService' has been injected into other beans [testService] in its raw version as part of a circular reference, but has eventually been wrapped. This means that said other beans do not use the final version of the bean. This is often the result of over-eager type matching - consider using 'getBeanNamesOfType' with the 'allowEagerInit' flag turned off, for example.
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:622)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:515)
at org.springframework.beans.factory.support.AbstractBeanFactory.lambda$doGetBean$0(AbstractBeanFactory.java:320)
at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:222)
at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:318)
at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:199)
at org.springframework.beans.factory.config.DependencyDescriptor.resolveCandidate(DependencyDescriptor.java:277)
at org.springframework.beans.factory.support.DefaultListableBeanFactory.doResolveDependency(DefaultListableBeanFactory.java:1251)
at org.springframework.beans.factory.support.DefaultListableBeanFactory.resolveDependency(DefaultListableBeanFactory.java:1171)
at org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor$AutowiredFieldElement.inject(AutowiredAnnotationBeanPostProcessor.java:593)
... 19 common frames omitted
報(bào)錯(cuò)版本：TestService
@Slf4j
@Service
@EnableAsync // 開啟異步
@EnableTransactionManagement // 開啟事務(wù)
public class TestService {
@Autowired
private UserService userService;
@Autowired
private TestService testService;
@Transactional
public void doTx(){
log.info("-----------------doTx-----------------" + this.getClass());
User user = new User();
user.setNickname(RandomStringUtils.randomAlphabetic(5));
userService.save(user); // 插入用戶
log.info("插入用戶：{}" , user);
testService.printUserList(); // 我們希望的是異步打印所有的用戶
log.info("-----------------doTx-----------------");
try {
Thread.sleep(3000); // 這里還需要干其它的活,反正就是這里不確定,萬一它就卡在這里了呢, 就模擬這個(gè)情況
} catch (InterruptedException e) {
e.printStackTrace();
}
}
@Async
public void printUserList() {
log.info("-----------------printUserList-----------------" + this.getClass());
List<User> list = userService.list(new QueryWrapper<User>());
for (User user1 : list) {
log.info("printUser: {}",user1);
}
log.info("-----------------printUserList-----------------");
}
}
@Lazy正常啟動(dòng)版本（有問題）
給TestService加個(gè)@Lazy注解，就可以解決這個(gè)問題，解決的方式是因?yàn)樵诮馕龊蠤Lazy注解的依賴時(shí)，會(huì)創(chuàng)建一個(gè)代理對象，這個(gè)代理把從spring容器中獲取目標(biāo)bean的時(shí)機(jī)，調(diào)整到了使用它的時(shí)候，也就是說，往TestService中注入的testService，在解析依賴的解決，不去容器中去找或者創(chuàng)建，而是直接構(gòu)建了個(gè)代理對象，放入到里面。這樣就相當(dāng)于沒有發(fā)生循環(huán)發(fā)生一樣，因?yàn)檠h(huán)依賴產(chǎn)生的的時(shí)機(jī)就是在解析bean的依賴的時(shí)候，通過@Lazy創(chuàng)建代理的方式處理了依賴，也就不存在這個(gè)循環(huán)依賴的問題了。
也好比說：我在TestService中注入一個(gè)容器中壓根就沒有定義的bean，但是我給這個(gè)這個(gè)字段上的bean加了@Lazy注解，它依然可以正常啟動(dòng)，當(dāng)然，在用的時(shí)候，它仍然會(huì)報(bào)錯(cuò)。但在這里沒關(guān)系，在啟動(dòng)階段已經(jīng)不報(bào)錯(cuò)了，在運(yùn)行階段，會(huì)去容器中尋找testService，而在運(yùn)行階段，spring容器已經(jīng)初始化好了，也就沒問題了。
@Slf4j
@Service
@EnableAsync // 開啟異步
@EnableTransactionManagement // 開啟事務(wù)
public class TestService {
@Autowired
private UserService userService;
@Autowired
@Lazy
private TestService testService;
@Transactional
public void doTx(){
log.info("-----------------doTx-----------------" + this.getClass());
User user = new User();
user.setNickname(RandomStringUtils.randomAlphabetic(5));
userService.save(user); // 插入用戶
log.info("插入用戶：{}" , user);
testService.printUserList(); // 我們希望的是異步打印所有的用戶
log.info("-----------------doTx-----------------");
try {
Thread.sleep(3000); // 這里還需要干其它的活,反正就是這里不確定,萬一它就卡在這里了呢, 就模擬這個(gè)情況
} catch (InterruptedException e) {
e.printStackTrace();
}
}
@Async
public void printUserList() {
log.info("-----------------printUserList-----------------" + this.getClass());
List<User> list = userService.list(new QueryWrapper<User>());
for (User user1 : list) {
log.info("printUser: {}",user1);
}
log.info("-----------------printUserList-----------------");
}
}我們繼續(xù)訪問上面的這個(gè)接口：//localhost:8085/web-api/test/testTx，輸出如下的日志。
異步打印的問題是解決了，但是，又有個(gè)問題了，查出來怎么只會(huì)有1個(gè)用戶呢？這個(gè)接口調(diào)用了2次，肯定會(huì)有2個(gè)用戶的，現(xiàn)在卻只有一個(gè)用戶，原因就在于是異步打印的，當(dāng)前事務(wù)還有提交，然后就去查詢，肯定就只會(huì)查詢1個(gè)出來。
@Lazy + 注冊事務(wù)同步
上面代碼中，調(diào)用@Aysnc注解修飾的異步方法應(yīng)該是要在事務(wù)提交了之后，再去調(diào)用，而不是插入數(shù)據(jù)之后調(diào)用！
所以需要注冊事務(wù)同步到事務(wù)同步管理器中，在事務(wù)提交之后，再去作異步任務(wù)，這樣異步任務(wù)才能在數(shù)據(jù)庫中查到剛剛插入的數(shù)據(jù)。感覺有點(diǎn)像vue里面的nextTick了。
@Slf4j
@Service
@EnableAsync // 開啟異步
@EnableTransactionManagement // 開啟事務(wù)
public class TestService {
@Autowired
private UserService userService;
@Autowired
@Lazy
private TestService testService;
@Transactional
public void doTx(){
log.info("-----------------doTx-----------------" + this.getClass());
User user = new User();
user.setNickname(RandomStringUtils.randomAlphabetic(5));
userService.save(user); // 插入用戶
log.info("插入用戶：{}" , user);
TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization() {
@Override
public void afterCommit() {
testService.printUserList();// 我們希望的是異步打印所有的用戶
}
});
log.info("-----------------doTx-----------------");
try {
Thread.sleep(3000); // 這里還需要干其它的活,反正就是這里不確定,萬一它就卡在這里了呢, 就模擬這個(gè)情況
} catch (InterruptedException e) {
e.printStackTrace();
}
}
@Async
public void printUserList() {
log.info("-----------------printUserList-----------------" + this.getClass());
List<User> list = userService.list(new QueryWrapper<User>());
for (User user1 : list) {
log.info("printUser: {}",user1);
}
log.info("-----------------printUserList-----------------");
}
}可以看到，剛剛插入的時(shí)id為4用戶，現(xiàn)在能夠把剛剛插入的查詢出來了
到此這篇關(guān)于Java的@Transactional、@Aysnc、事務(wù)同步問題詳解的文章就介紹到這了,更多相關(guān)@Transactional、@Aysnc、事務(wù)同步問題內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
Sentinel實(shí)現(xiàn)動(dòng)態(tài)配置的集群流控的方法
這篇文章主要介紹了Sentinel實(shí)現(xiàn)動(dòng)態(tài)配置的集群流控,本文給大家介紹的非常詳細(xì)，對大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下2021-04-04
本文介紹了QueryWrapper的高級使用方法,包括查詢指定字段、使用MySQL函數(shù)處理字段、設(shè)置查詢限制等,通過select()可查詢指定字段并處理,last()方法實(shí)現(xiàn)limit效果,apply()可在查詢條件中使用函數(shù),這些技巧有助于提升數(shù)據(jù)庫操作的靈活性和效率2024-09-09
eclipse修改jvm參數(shù)調(diào)優(yōu)方法(2種)
本篇文章主要介紹了eclipse修改jvm參數(shù)調(diào)優(yōu)方法(2種)，小編覺得挺不錯(cuò)的，現(xiàn)在分享給大家，也給大家做個(gè)參考。一起跟隨小編過來看看吧2018-02-02
解決Shiro 處理ajax請求攔截登錄超時(shí)的問題
這篇文章主要介紹了解決Shiro 處理ajax請求攔截登錄超時(shí)的問題，具有很好的參考價(jià)值，希望對大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2021-09-09
這篇文章主要為大家詳細(xì)介紹了java實(shí)現(xiàn)一個(gè)桌球小游戲，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2019-07-07
在實(shí)際項(xiàng)目使用中,必須要考慮服務(wù)的安全性,當(dāng)服務(wù)部署到互聯(lián)網(wǎng)以后,就要考慮服務(wù)被惡意請求和暴力攻擊的情況,所以本文給大家介紹了SpringBoot接口惡意刷新和暴力請求的解決方法,需要的朋友可以參考下2024-11-11
從零搭建腳手架之集成Spring?Retry實(shí)現(xiàn)失敗重試和熔斷器模式(實(shí)戰(zhàn)教程)
在我們的大多數(shù)項(xiàng)目中，會(huì)有一些場景需要重試操作，而不是立即失敗，讓系統(tǒng)更加健壯且不易發(fā)生故障，這篇文章主要介紹了從零搭建開發(fā)腳手架之集成Spring?Retry實(shí)現(xiàn)失敗重試和熔斷器模式,需要的朋友可以參考下2022-07-07
對SpringBoot項(xiàng)目Jar包進(jìn)行加密防止反編譯的方案
最近項(xiàng)目要求部署到其他公司的服務(wù)器上,但是又不想將源碼泄露出去,要求對正式環(huán)境的啟動(dòng)包進(jìn)行安全性處理,防止客戶直接通過反編譯工具將代碼反編譯出來,本文介紹了如何對SpringBoot項(xiàng)目Jar包進(jìn)行加密防止反編譯,需要的朋友可以參考下2024-08-08
Java實(shí)現(xiàn)PDF轉(zhuǎn)圖片的三種方法
有些時(shí)候我們需要在項(xiàng)目中展示PDF,所以我們可以將PDF轉(zhuǎn)為圖片,然后已圖片的方式展示,效果很好,Java使用各種技術(shù)將pdf轉(zhuǎn)換成圖片格式,并且內(nèi)容不失幀,本文給大家介紹了三種方法實(shí)現(xiàn)PDF轉(zhuǎn)圖片的案例,需要的朋友可以參考下2023-10-10
SpringBoot2.0集成MQTT消息推送功能實(shí)現(xiàn)
這篇文章主要介紹了SpringBoot2.0集成MQTT消息推送功能實(shí)現(xiàn)，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2021-04-04