springboot中實現(xiàn)異步調用任務的方法?針對這個問題,這篇文章詳細介紹了相對應的分析和解答,希望可以幫助更多想解決這個問題的小伙伴找到更簡單易行的方法。

創(chuàng)新互聯(lián)公司成都網站建設按需定制,是成都網站營銷公司,為護欄打樁機提供網站建設服務,有成熟的網站定制合作流程,提供網站定制設計服務:原型圖制作、網站創(chuàng)意設計、前端HTML5制作、后臺程序開發(fā)等。成都網站營銷推廣熱線:13518219792
什么是“異步調用”?
“異步調用”對應的是“同步調用”,同步調用指程序按照定義順序依次執(zhí)行,每一行程序都必須等待上一行程序執(zhí)行完成之后才能執(zhí)行;異步調用指程序在順序執(zhí)行時,不等待異步調用的語句返回結果就執(zhí)行后面的程序。
同步調用
下面通過一個簡單示例來直觀的理解什么是同步調用:
定義Task類,創(chuàng)建三個處理函數(shù)分別模擬三個執(zhí)行任務的操作,操作消耗時間隨機取(10秒內)
package com.kfit.task;
import java.util.Random;
import org.springframework.stereotype.Component;
/**
* 定義3個任務
* @author Angel(QQ:412887952)
* @version v.0.1
*/
@Component
publicclass Task1 {
//定義一個隨機對象.
publicstatic Random random =new Random();
//任務一;
publicvoid doTaskOne() throws Exception {
System.out.println("開始做任務一");
longstart = System.currentTimeMillis();
Thread.sleep(random.nextInt(10000));
longend = System.currentTimeMillis();
System.out.println("完成任務一,耗時:" + (end - start) + "毫秒");
}
//任務二;
publicvoid doTaskTwo() throws Exception {
System.out.println("開始做任務二");
longstart = System.currentTimeMillis();
Thread.sleep(random.nextInt(10000));
longend = System.currentTimeMillis();
System.out.println("完成任務二,耗時:" + (end - start) + "毫秒");
}
//任務3;
publicvoid doTaskThree() throws Exception {
System.out.println("開始做任務三");
longstart = System.currentTimeMillis();
Thread.sleep(random.nextInt(10000));
longend = System.currentTimeMillis();
System.out.println("完成任務三,耗時:" + (end - start) + "毫秒");
}
}編寫一個訪問方法:
//測試task1.
@RequestMapping("/task1")
public String task1() throws Exception{
task1.doTaskOne();
task1.doTaskTwo();
task1.doTaskThree();
return"task1";
}運行可以看到類似如下輸出:
開始做任務一
完成任務一,耗時:4156毫秒
開始做任務二
完成任務二,耗時:557毫秒
開始做任務三
完成任務三,耗時:6171毫秒
異步調用
上述的同步調用雖然順利的執(zhí)行完了三個任務,但是可以看到執(zhí)行時間比較長,若這三個任務本身之間不存在依賴關系,可以并發(fā)執(zhí)行的話,同步調用在執(zhí)行效率方面就比較差,可以考慮通過異步調用的方式來并發(fā)執(zhí)行。
在Spring Boot中,我們只需要通過使用@Async注解就能簡單的將原來的同步函數(shù)變?yōu)楫惒胶瘮?shù),Task類改在為如下模式:
package com.kfit.task;
import java.util.Random;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;
/**
* 定義3個任務
* @author Angel(QQ:412887952)
* @version v.0.1
*/
@Component
publicclass Task2 {
//定義一個隨機對象.
publicstatic Random random =new Random();
//任務一;
@Async
publicvoid doTaskOne() throws Exception {
System.out.println("開始做任務一");
longstart = System.currentTimeMillis();
Thread.sleep(random.nextInt(10000));
longend = System.currentTimeMillis();
System.out.println("完成任務一,耗時:" + (end - start) + "毫秒");
}
//任務二;
@Async
publicvoid doTaskTwo() throws Exception {
System.out.println("開始做任務二");
longstart = System.currentTimeMillis();
Thread.sleep(random.nextInt(10000));
longend = System.currentTimeMillis();
System.out.println("完成任務二,耗時:" + (end - start) + "毫秒");
}
//任務3;
@Async
publicvoid doTaskThree() throws Exception {
System.out.println("開始做任務三");
longstart = System.currentTimeMillis();
Thread.sleep(random.nextInt(10000));
longend = System.currentTimeMillis();
System.out.println("完成任務三,耗時:" + (end - start) + "毫秒");
}
}為了讓@Async注解能夠生效,還需要在Spring Boot的主程序中配置@EnableAsync,如下所示:
@SpringBootApplication
@EnableAsync
publicclass App {
//省略其它代碼…
}編寫測試方法:
//測試task2.
@RequestMapping("/task2")
public String task2() throws Exception{
task2.doTaskOne();
task2.doTaskTwo();
task2.doTaskThree();
return"task2";
}此時可以反復執(zhí)行單元測試,您可能會遇到各種不同的結果,比如:
開始做任務一
開始做任務二
開始做任務三
完成任務三,耗時:57毫秒
完成任務二,耗時:3621毫秒
完成任務一,耗時:7419毫秒
關于springboot中實現(xiàn)異步調用任務的方法問題的解答就分享到這里了,希望以上內容可以對大家有一定的幫助,如果你還有很多疑惑沒有解開,可以關注創(chuàng)新互聯(lián)行業(yè)資訊頻道了解更多相關知識。
本文名稱:springboot中實現(xiàn)異步調用任務的方法
鏈接地址:http://chinadenli.net/article34/gspise.html
成都網站建設公司_創(chuàng)新互聯(lián),為您提供企業(yè)網站制作、網站導航、網站設計、用戶體驗、虛擬主機、品牌網站設計
聲明:本網站發(fā)布的內容(圖片、視頻和文字)以用戶投稿、用戶轉載內容為主,如果涉及侵權請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內容未經允許不得轉載,或轉載時需注明來源: 創(chuàng)新互聯(lián)