第06課:Spring Boot 異步框架

一渣磷、課程目標(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

image

從日志的截圖可以看出2點(diǎn):

  1. 異步日志相隔10s
  2. 不同的線程护昧,線程[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í)資料-----------------------------

  1. 課后練習(xí)作業(yè)請(qǐng)?zhí)峤坏絈Q群(1號(hào)QQ群3000人已滿灸拍,請(qǐng)加2號(hào)群:985378659[群名:SpringBoot架構(gòu)師])
  2. 本課程配套免費(fèi)視頻教程
    https://study.163.com/course/introduction/1004576013.htm?share=1&shareId=1016481220
  3. 本課程配套源碼地址:https://github.com/agan-java/agan-boot
image
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
  • 序言:七十年代末,一起剝皮案震驚了整個(gè)濱河市砾省,隨后出現(xiàn)的幾起案子株搔,更是在濱河造成了極大的恐慌,老刑警劉巖纯蛾,帶你破解...
    沈念sama閱讀 216,496評(píng)論 6 501
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件纤房,死亡現(xiàn)場(chǎng)離奇詭異,居然都是意外死亡翻诉,警方通過(guò)查閱死者的電腦和手機(jī)炮姨,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 92,407評(píng)論 3 392
  • 文/潘曉璐 我一進(jìn)店門,熙熙樓的掌柜王于貴愁眉苦臉地迎上來(lái)碰煌,“玉大人舒岸,你說(shuō)我怎么就攤上這事÷” “怎么了蛾派?”我有些...
    開封第一講書人閱讀 162,632評(píng)論 0 353
  • 文/不壞的土叔 我叫張陵,是天一觀的道長(zhǎng)个少。 經(jīng)常有香客問(wèn)我洪乍,道長(zhǎng),這世上最難降的妖魔是什么夜焦? 我笑而不...
    開封第一講書人閱讀 58,180評(píng)論 1 292
  • 正文 為了忘掉前任壳澳,我火速辦了婚禮,結(jié)果婚禮上茫经,老公的妹妹穿的比我還像新娘巷波。我一直安慰自己,他們只是感情好卸伞,可當(dāng)我...
    茶點(diǎn)故事閱讀 67,198評(píng)論 6 388
  • 文/花漫 我一把揭開白布抹镊。 她就那樣靜靜地躺著,像睡著了一般荤傲。 火紅的嫁衣襯著肌膚如雪垮耳。 梳的紋絲不亂的頭發(fā)上,一...
    開封第一講書人閱讀 51,165評(píng)論 1 299
  • 那天弃酌,我揣著相機(jī)與錄音氨菇,去河邊找鬼。 笑死妓湘,一個(gè)胖子當(dāng)著我的面吹牛查蓉,可吹牛的內(nèi)容都是我干的。 我是一名探鬼主播榜贴,決...
    沈念sama閱讀 40,052評(píng)論 3 418
  • 文/蒼蘭香墨 我猛地睜開眼豌研,長(zhǎng)吁一口氣:“原來(lái)是場(chǎng)噩夢(mèng)啊……” “哼!你這毒婦竟也來(lái)了唬党?” 一聲冷哼從身側(cè)響起鹃共,我...
    開封第一講書人閱讀 38,910評(píng)論 0 274
  • 序言:老撾萬(wàn)榮一對(duì)情侶失蹤,失蹤者是張志新(化名)和其女友劉穎驶拱,沒想到半個(gè)月后霜浴,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體,經(jīng)...
    沈念sama閱讀 45,324評(píng)論 1 310
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡蓝纲,尸身上長(zhǎng)有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 37,542評(píng)論 2 332
  • 正文 我和宋清朗相戀三年阴孟,在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片税迷。...
    茶點(diǎn)故事閱讀 39,711評(píng)論 1 348
  • 序言:一個(gè)原本活蹦亂跳的男人離奇死亡永丝,死狀恐怖,靈堂內(nèi)的尸體忽然破棺而出箭养,到底是詐尸還是另有隱情慕嚷,我是刑警寧澤,帶...
    沈念sama閱讀 35,424評(píng)論 5 343
  • 正文 年R本政府宣布毕泌,位于F島的核電站喝检,受9級(jí)特大地震影響,放射性物質(zhì)發(fā)生泄漏撼泛。R本人自食惡果不足惜蛇耀,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 41,017評(píng)論 3 326
  • 文/蒙蒙 一、第九天 我趴在偏房一處隱蔽的房頂上張望坎弯。 院中可真熱鬧纺涤,春花似錦、人聲如沸抠忘。這莊子的主人今日做“春日...
    開封第一講書人閱讀 31,668評(píng)論 0 22
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽(yáng)崎脉。三九已至拧咳,卻和暖如春,著一層夾襖步出監(jiān)牢的瞬間囚灼,已是汗流浹背骆膝。 一陣腳步聲響...
    開封第一講書人閱讀 32,823評(píng)論 1 269
  • 我被黑心中介騙來(lái)泰國(guó)打工祭衩, 沒想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留,地道東北人阅签。 一個(gè)月前我還...
    沈念sama閱讀 47,722評(píng)論 2 368
  • 正文 我出身青樓掐暮,卻偏偏與公主長(zhǎng)得像,于是被迫代替她去往敵國(guó)和親政钟。 傳聞我的和親對(duì)象是個(gè)殘疾皇子路克,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 44,611評(píng)論 2 353

推薦閱讀更多精彩內(nèi)容