Spring Boot巧用 @Async 提升API接口并發(fā)能力！NB！

同步調(diào)用

@Component
public?class?Task?{
?
????public?static?Random?random?=new?Random();
?
????public?void?doTaskOne()?throws?Exception?{
????????System.out.println("開始做任務一");
????????long?start?=?System.currentTimeMillis();
????????Thread.sleep(random.nextInt(10000));
????????long?end?=?System.currentTimeMillis();
????????System.out.println("完成任務一，耗時："?+?(end?-?start)?+?"毫秒");
????}
?
????public?void?doTaskTwo()?throws?Exception?{
????????System.out.println("開始做任務二");
????????long?start?=?System.currentTimeMillis();
????????Thread.sleep(random.nextInt(10000));
????????long?end?=?System.currentTimeMillis();
????????System.out.println("完成任務二，耗時："?+?(end?-?start)?+?"毫秒");
????}
?
????public?void?doTaskThree()?throws?Exception?{
????????System.out.println("開始做任務三");
????????long?start?=?System.currentTimeMillis();
????????Thread.sleep(random.nextInt(10000));
????????long?end?=?System.currentTimeMillis();
????????System.out.println("完成任務三，耗時："?+?(end?-?start)?+?"毫秒");
????}
?
}

@RunWith(SpringJUnit4ClassRunner.class)
@SpringApplicationConfiguration(classes?=?Application.class)
public?class?ApplicationTests?{
?
????@Autowired
????private?Task?task;
?
????@Test
????public?void?test()?throws?Exception?{
????????task.doTaskOne();
????????task.doTaskTwo();
????????task.doTaskThree();
????}
?
}

開始做任務一
完成任務一，耗時：4256毫秒
開始做任務二
完成任務二，耗時：4957毫秒
開始做任務三
完成任務三，耗時：7173毫秒

異步調(diào)用

@Component
public?class?Task?{
?
????@Async
????public?void?doTaskOne()?throws?Exception?{
????????//?同上內(nèi)容，省略
????}
?
????@Async
????public?void?doTaskTwo()?throws?Exception?{
????????//?同上內(nèi)容，省略
????}
?
????@Async
????public?void?doTaskThree()?throws?Exception?{
????????//?同上內(nèi)容，省略
????}
?
}

@SpringBootApplication
@EnableAsync
public?class?Application?{
?
????public?static?void?main(String[]?args)?{
????????SpringApplication.run(Application.class,?args);
????}
?
}

• 沒有任何任務相關的輸出
• 有部分任務相關的輸出
• 亂序的任務相關的輸出

注：@Async所修飾的函數(shù)不要定義為static類型，這樣異步調(diào)用不會生效

異步回調(diào)

@Async
public?Future?doTaskOne()?throws?Exception?{
????System.out.println("開始做任務一");
????long?start?=?System.currentTimeMillis();
????Thread.sleep(random.nextInt(10000));
????long?end?=?System.currentTimeMillis();
????System.out.println("完成任務一，耗時："?+?(end?-?start)?+?"毫秒");
????return?new?AsyncResult<>("任務一完成");
}

@Test
public?void?test()?throws?Exception?{
?
????long?start?=?System.currentTimeMillis();
?
????Future?task1?=?task.doTaskOne();
????Future?task2?=?task.doTaskTwo();
????Future?task3?=?task.doTaskThree();
?
????while(true)?{
????????if(task1.isDone()?&&?task2.isDone()?&&?task3.isDone())?{
????????????//?三個任務都調(diào)用完成，退出循環(huán)等待
????????????break;
????????}
????????Thread.sleep(1000);
????}
?
????long?end?=?System.currentTimeMillis();
?
????System.out.println("任務全部完成，總耗時："?+?(end?-?start)?+?"毫秒");
?
}

• 在測試用例一開始記錄開始時間

• 在調(diào)用三個異步函數(shù)的時候，返回Future類型的結果對象

• 在調(diào)用完三個異步函數(shù)之后，開啟一個循環(huán)，根據(jù)返回的Future對象來判斷三個異步函數(shù)是否都結束了。若都結束，就結束循環(huán)；若沒有都結束，就等1秒后再判斷。

開始做任務一
開始做任務二
開始做任務三
完成任務三，耗時：37毫秒
完成任務二，耗時：3661毫秒
完成任務一，耗時：7149毫秒
任務全部完成，總耗時：8025毫秒