一渣磷、課程目標(biāo)
熟悉spring的異步框架,學(xué)會(huì)使用異步@Async注解
二罢猪、為什么要用異步框架捕虽,它解決什么問(wèn)題?
在SpringBoot的日常開發(fā)中坡脐,一般都是同步調(diào)用的泄私。但經(jīng)常有特殊業(yè)務(wù)需要做異步來(lái)處理,例如:注冊(cè)新用戶备闲,送100個(gè)積分晌端,或下單成功,發(fā)送push消息等等恬砂。
就拿注冊(cè)新用戶為什么要異步處理咧纠?
- 第一個(gè)原因:容錯(cuò)性,如果送積分出現(xiàn)異常泻骤,不能因?yàn)樗头e分而導(dǎo)致用戶注冊(cè)失斊岣帷;
因?yàn)橛脩糇?cè)是主要功能狱掂,送積分是次要功能演痒,即使送積分異常也要提示用戶注冊(cè)成功,然后后面在針對(duì)積分異常做補(bǔ)償處理趋惨。 - 第二個(gè)原因:提升性能鸟顺,例如注冊(cè)用戶花了20毫秒,送積分花費(fèi)50毫秒器虾,如果用同步的話讯嫂,總耗時(shí)70毫秒,用異步的話兆沙,無(wú)需等待積分欧芽,故耗時(shí)20毫秒。
故葛圃,異步能解決2個(gè)問(wèn)題千扔,性能和容錯(cuò)性。
三装悲、SpringBoot異步調(diào)用
在SpringBoot中使用異步調(diào)用是很簡(jiǎn)單的昏鹃,只需要使用@Async注解即可實(shí)現(xiàn)方法的異步調(diào)用尚氛。
四诀诊、@Async異步調(diào)用例子
步驟1:開啟異步任務(wù)
采用@EnableAsync來(lái)啟用異步任務(wù)支持,另外需要用@Configuration來(lái)把當(dāng)前類加入springIOC容器中
@Configuration
@EnableAsync
public class SyncConfiguration {
}
步驟2:在方法標(biāo)記為異步調(diào)用
增加一個(gè)ScoreService類,用于積分處理阅嘶。
@Async添加在方法上属瓣,代表該方法為異步處理载迄。
@Service
public class ScoreService {
private static final Logger logger = LoggerFactory.getLogger(ScoreService.class);
@Async
public void addScore(){
//TODO 模擬睡10秒,用于贈(zèng)送積分處理
try {
Thread.sleep(1000*10);
logger.info("--------------處理積分--------------------");
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
添加一個(gè)測(cè)試類抡蛙,TestController
@RestController
public class TestController {
private static final Logger logger = LoggerFactory.getLogger(TestController.class);
@Autowired
private ScoreService scoreService;
@RequestMapping("/sync")
public String createUser() {
logger.info("--------------注冊(cè)用戶--------------------");
this.scoreService.addScore();
return "OK";
}
}
步驟3:體驗(yàn)效果
在瀏覽器輸入:http://127.0.0.1:9090/sync
從日志的截圖可以看出2點(diǎn):
- 異步日志相隔10s
- 不同的線程护昧,線程[nio-9090-exec-1]代表的是tomcat的線程,線程[task-1]代表的是異步Async的線程
五粗截、為什么要給Async自定義線程池惋耙?
@Async注解,在默認(rèn)情況下用的是SimpleAsyncTaskExecutor線程池熊昌,該線程池不是真正意義上的線程池绽榛,因?yàn)榫€程不重用,每次調(diào)用都會(huì)新建一條線程婿屹。
可以通過(guò)控制臺(tái)日志輸出查看灭美,每次打印的線程名都是[task-1]、[task-2]昂利、[task-3]届腐、[task-4].....遞增的。
@Async注解異步框架提供多種線程
SimpleAsyncTaskExecutor:不是真的線程池蜂奸,這個(gè)類不重用線程犁苏,每次調(diào)用都會(huì)創(chuàng)建一個(gè)新的線程。
SyncTaskExecutor:這個(gè)類沒有實(shí)現(xiàn)異步調(diào)用扩所,只是一個(gè)同步操作傀顾。只適用于不需要多線程的地方
ConcurrentTaskExecutor:Executor的適配類,不推薦使用碌奉。如果ThreadPoolTaskExecutor不滿足要求時(shí)短曾,才用考慮使用這個(gè)類
ThreadPoolTaskScheduler:可以使用cron表達(dá)式
ThreadPoolTaskExecutor :最常使用,推薦赐劣。 其實(shí)質(zhì)是對(duì)java.util.concurrent.ThreadPoolExecutor的包裝
六嫉拐、為@Async實(shí)現(xiàn)一個(gè)自定義線程池
步驟1:配置線程池
@Configuration
@EnableAsync
public class SyncConfiguration {
@Bean(name = "scorePoolTaskExecutor")
public ThreadPoolTaskExecutor getScorePoolTaskExecutor() {
ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();
//核心線程數(shù)
taskExecutor.setCorePoolSize(10);
//線程池維護(hù)線程的最大數(shù)量,只有在緩沖隊(duì)列滿了之后才會(huì)申請(qǐng)超過(guò)核心線程數(shù)的線程
taskExecutor.setMaxPoolSize(100);
//緩存隊(duì)列
taskExecutor.setQueueCapacity(50);
//許的空閑時(shí)間,當(dāng)超過(guò)了核心線程出之外的線程在空閑時(shí)間到達(dá)之后會(huì)被銷毀
taskExecutor.setKeepAliveSeconds(200);
//異步方法內(nèi)部線程名稱
taskExecutor.setThreadNamePrefix("score-");
/**
* 當(dāng)線程池的任務(wù)緩存隊(duì)列已滿并且線程池中的線程數(shù)目達(dá)到maximumPoolSize,如果還有任務(wù)到來(lái)就會(huì)采取任務(wù)拒絕策略
* 通常有以下四種策略:
* ThreadPoolExecutor.AbortPolicy:丟棄任務(wù)并拋出RejectedExecutionException異常魁兼。
* ThreadPoolExecutor.DiscardPolicy:也是丟棄任務(wù)婉徘,但是不拋出異常。
* ThreadPoolExecutor.DiscardOldestPolicy:丟棄隊(duì)列最前面的任務(wù)咐汞,然后重新嘗試執(zhí)行任務(wù)(重復(fù)此過(guò)程)
* ThreadPoolExecutor.CallerRunsPolicy:重試添加當(dāng)前的任務(wù)盖呼,自動(dòng)重復(fù)調(diào)用 execute() 方法,直到成功
*/
taskExecutor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
taskExecutor.initialize();
return taskExecutor;
}
}
步驟2:為@Async指定線程池
@Async("scorePoolTaskExecutor")
public void addScore2(){
//TODO 模擬睡5秒化撕,用于贈(zèng)送積分處理
try {
Thread.sleep(1000*5);
logger.info("--------------處理積分--------------------");
} catch (InterruptedException e) {
e.printStackTrace();
}
}
以上代碼挺簡(jiǎn)單的几晤,就是給@Async("scorePoolTaskExecutor")加個(gè)參數(shù)即可。
@RequestMapping("/sync2")
public String createUser2() {
logger.info("--------------注冊(cè)用戶2--------------------");
this.scoreService.addScore2();
return "OK";
}
步驟3:體驗(yàn)效果
在瀏覽器輸入:http://127.0.0.1:9090/sync2
2019-09-17 16:25:06.128 INFO 47776 --- [nio-9090-exec-1] com.agan.boot.controller.TestController : --------------注冊(cè)用戶2--------------------
2019-09-17 16:25:11.136 INFO 47776 --- [ score-1] com.agan.boot.service.ScoreService : --------------處理積分--------------------
從日志的可以看出:
線程[score-1]代表的是我們自定義的線程池score線程
七植阴、課后練習(xí)
在現(xiàn)實(shí)的互聯(lián)網(wǎng)項(xiàng)目開發(fā)中蟹瘾,針對(duì)高并發(fā)的請(qǐng)求圾浅,一般的做法是高并發(fā)接口單獨(dú)線程池隔離處理。
假設(shè)現(xiàn)在2個(gè)高并發(fā)接口:
一個(gè)是修改用戶信息接口憾朴,刷新用戶redis緩存.
一個(gè)是下訂單接口狸捕,發(fā)送app push信息.
請(qǐng)參考本課程內(nèi)容,設(shè)計(jì)2個(gè)線程池众雷,分別用于[刷新用戶redis緩存]和[發(fā)送app push信息]
-----------------------------配套學(xué)習(xí)資料-----------------------------
- 課后練習(xí)作業(yè)請(qǐng)?zhí)峤坏絈Q群(1號(hào)QQ群3000人已滿灸拍,請(qǐng)加2號(hào)群:985378659[群名:SpringBoot架構(gòu)師])
- 本課程配套免費(fèi)視頻教程
https://study.163.com/course/introduction/1004576013.htm?share=1&shareId=1016481220 - 本課程配套源碼地址:https://github.com/agan-java/agan-boot