SpringBoot中異步調(diào)用時(shí)的注意事項(xiàng)
一,使用方法
1,啟動(dòng)類上加@EnableAsync注解,開啟異步
2,在需要異步執(zhí)行的方法上加@Async(“threadpool”)注解,(threadpool)可以為空
二,注意事項(xiàng)
(1)在默認(rèn)情況下,未設(shè)置TaskExecutor時(shí),默認(rèn)是使用SimpleAsyncTaskExecutor這個(gè)線程池,但此線程不是真正意義上的線程池,因?yàn)榫€程不重用,每次調(diào)用都會(huì)創(chuàng)建一個(gè)新的線程??赏ㄟ^(guò)控制臺(tái)日志輸出可以看出,每次輸出線程名都是遞增的。所以最好我們來(lái)自定義一個(gè)線程池。
(2)調(diào)用的異步方法,不能為同一個(gè)類的方法(包括同一個(gè)類的內(nèi)部類),簡(jiǎn)單來(lái)說(shuō),因?yàn)镾pring在啟動(dòng)掃描時(shí)會(huì)為其創(chuàng)建一個(gè)代理類,而同類調(diào)用時(shí),還是調(diào)用本身的代理類的,所以和平常調(diào)用是一樣的。其他的注解如@Cache等也是一樣的道理,說(shuō)白了,就是Spring的代理機(jī)制造成的。所以在開發(fā)中,最好把異步服務(wù)單獨(dú)抽出一個(gè)類來(lái)管理。
三,什么情況下會(huì)導(dǎo)致@Async異步方法會(huì)失效?
(1)調(diào)用同一個(gè)類下注有@Async異步方法:在spring中像@Async和@Transactional、cache等注解本質(zhì)使用的是動(dòng)態(tài)代理,其實(shí)Spring容器在初始化的時(shí)候Spring容器會(huì)將含有AOP注解的類對(duì)象“替換”為代理對(duì)象(簡(jiǎn)單這么理解),那么注解失效的原因就很明顯了,就是因?yàn)檎{(diào)用方法的是對(duì)象本身而不是代理對(duì)象,因?yàn)闆]有經(jīng)過(guò)Spring容器,那么解決方法也會(huì)沿著這個(gè)思路來(lái)解決。
(2)調(diào)用的是靜態(tài)(static )方法
(3)調(diào)用(private)私有化方法
四,解決3中問(wèn)題1的方式
(其它2,3兩個(gè)問(wèn)題自己注意下就可以了)
將要異步執(zhí)行的方法單獨(dú)抽取成一個(gè)類,原理就是當(dāng)你把執(zhí)行異步的方法單獨(dú)抽取成一個(gè)類的時(shí)候,這個(gè)類肯定是被Spring管理的,其他Spring組件需要調(diào)用的時(shí)候肯定會(huì)注入進(jìn)去,這時(shí)候?qū)嶋H上注入進(jìn)去的就是代理類了。 其實(shí)我們的注入對(duì)象都是從Spring容器中給當(dāng)前Spring組件進(jìn)行成員變量的賦值,由于某些類使用了AOP注解,那么實(shí)際上在Spring容器中實(shí)際存在的是它的代理對(duì)象。那么我們就可以通過(guò)上下文獲取自己的代理對(duì)象調(diào)用異步方法。
@Controller
@RequestMapping("/app")
public class EmailController {
//獲取ApplicationContext對(duì)象方式有多種,這種最簡(jiǎn)單,其它的大家自行了解一下
@Autowired
private ApplicationContext applicationContext;
@RequestMapping(value = "/email/asyncCall", method = GET)
@ResponseBody
public Map<String, Object> asyncCall () {
Map<String, Object> resMap = new HashMap<String, Object>();
try{
//這樣調(diào)用同類下的異步方法是不起作用的
//this.testAsyncTask();
//通過(guò)上下文獲取自己的代理對(duì)象調(diào)用異步方法
EmailController emailController = (EmailController)applicationContext.getBean(EmailController.class);
emailController.testAsyncTask();
resMap.put("code",200);
}catch (Exception e) {
resMap.put("code",400);
logger.error("error!",e);
}
return resMap;
}
//注意一定是public,且是非static方法
@Async
public void testAsyncTask() throws InterruptedException {
Thread.sleep(10000);
System.out.println("異步任務(wù)執(zhí)行完成!");
}
}開啟cglib代理,手動(dòng)獲取Spring代理類,從而調(diào)用同類下的異步方法。
首先,在啟動(dòng)類上加上@EnableAspectJAutoProxy(exposeProxy = true)注解。 代碼實(shí)現(xiàn),如下:
@Service
@Transactional(value = "transactionManager", readOnly = false, propagation = Propagation.REQUIRED, rollbackFor = Throwable.class)
public class EmailService {
@Autowired
private ApplicationContext applicationContext;
@Async
public void testSyncTask() throws InterruptedException {
Thread.sleep(10000);
System.out.println("異步任務(wù)執(zhí)行完成!");
}
public void asyncCallTwo() throws InterruptedException {
//this.testSyncTask();
// EmailService emailService = (EmailService)applicationContext.getBean(EmailService.class);
// emailService.testSyncTask();
boolean isAop = AopUtils.isAopProxy(EmailController.class);//是否是代理對(duì)象;
boolean isCglib = AopUtils.isCglibProxy(EmailController.class); //是否是CGLIB方式的代理對(duì)象;
boolean isJdk = AopUtils.isJdkDynamicProxy(EmailController.class); //是否是JDK動(dòng)態(tài)代理方式的代理對(duì)象;
//以下才是重點(diǎn)!!!
EmailService emailService = (EmailService)applicationContext.getBean(EmailService.class);
EmailService proxy = (EmailService) AopContext.currentProxy();
System.out.println(emailService == proxy ? true : false);
proxy.testSyncTask();
System.out.println("end!!!");
}異步請(qǐng)求與異步調(diào)用的區(qū)別
兩者的使用場(chǎng)景不同,異步請(qǐng)求用來(lái)解決并發(fā)請(qǐng)求對(duì)服務(wù)器造成的壓力,從而提高對(duì)請(qǐng)求的吞吐量;
而異步調(diào)用是用來(lái)做一些非主線流程且不需要實(shí)時(shí)計(jì)算和響應(yīng)的任務(wù),比如同步日志到kafka中做日志分析等。
異步請(qǐng)求是會(huì)一直等待response相應(yīng)的,需要返回結(jié)果給客戶端的;
而異步調(diào)用我們往往會(huì)馬上返回給客戶端響應(yīng),完成這次整個(gè)的請(qǐng)求,至于異步調(diào)用的任務(wù)后臺(tái)自己慢慢跑就行,客戶端不會(huì)關(guān)心。
到此這篇關(guān)于SpringBoot中異步調(diào)用時(shí)的注意事項(xiàng)的文章就介紹到這了,更多相關(guān)SpringBoot異步調(diào)用內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
淺析java修飾符訪問(wèn)權(quán)限(動(dòng)力節(jié)點(diǎn)Java學(xué)院整理)
Java有四種訪問(wèn)權(quán)限,其中三種有訪問(wèn)權(quán)限修飾符,分別為private,public和protected,還有一種不帶任何修飾符,下面通過(guò)本文給大家簡(jiǎn)單介紹下java修飾符訪問(wèn)權(quán)限相關(guān)知識(shí),感興趣的朋友一起學(xué)習(xí)吧2017-04-04
IntelliJ IDEA 安裝及初次使用圖文教程(2020.3.2社區(qū)版)
這篇文章主要介紹了IntelliJ IDEA 安裝及初次使用(2020.3.2社區(qū)版),本文通過(guò)圖文并茂的形式給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2021-03-03
解決@Api注解不展示controller內(nèi)容的問(wèn)題
這篇文章主要介紹了解決@Api注解不展示controller內(nèi)容的問(wèn)題,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教。2022-01-01

