一、課程目標(biāo)
熟悉spring的異步框架，學(xué)會(huì)使用異步@Async注解
二、為什么要用異步框架，它解決什么問題？
在SpringBoot的日常開發(fā)中，一般都是同步調(diào)用的。但經(jīng)常有特殊業(yè)務(wù)需要做異步來處理，例如：注冊(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毫秒，用異步的話，無需等待積分，故耗時(shí)20毫秒。
故，異步能解決2個(gè)問題，性能和容錯(cuò)性。
三、SpringBoot異步調(diào)用
在SpringBoot中使用異步調(diào)用是很簡(jiǎn)單的，只需要使用@Async注解即可實(shí)現(xiàn)方法的異步調(diào)用。
四、@Async異步調(diào)用例子
步驟1：開啟異步任務(wù)
采用@EnableAsync來啟用異步任務(wù)支持,另外需要用@Configuration來把當(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ì)新建一條線程。
可以通過控制臺(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)超過核心線程數(shù)的線程
taskExecutor.setMaxPoolSize(100);
//緩存隊(duì)列
taskExecutor.setQueueCapacity(50);
//許的空閑時(shí)間,當(dāng)超過了核心線程出之外的線程在空閑時(shí)間到達(dá)之后會(huì)被銷毀
taskExecutor.setKeepAliveSeconds(200);
//異步方法內(nèi)部線程名稱
taskExecutor.setThreadNamePrefix("score-");
/**
* 當(dāng)線程池的任務(wù)緩存隊(duì)列已滿并且線程池中的線程數(shù)目達(dá)到maximumPoolSize，如果還有任務(wù)到來就會(huì)采取任務(wù)拒絕策略
* 通常有以下四種策略：
* ThreadPoolExecutor.AbortPolicy:丟棄任務(wù)并拋出RejectedExecutionException異常。
* ThreadPoolExecutor.DiscardPolicy：也是丟棄任務(wù)，但是不拋出異常。
* ThreadPoolExecutor.DiscardOldestPolicy：丟棄隊(duì)列最前面的任務(wù)，然后重新嘗試執(zhí)行任務(wù)（重復(fù)此過程）
* 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
