快捷導航

spring boot 使用@Async實現(xiàn)異步調(diào)用方法

更新時間：2017年04月26日 14:43:55 作者：陽光早已褪色

本篇文章主要介紹了spring boot 使用@Async實現(xiàn)異步調(diào)用方法，具有一定的參考價值，有興趣的可以了解一下。

使用@Async實現(xiàn)異步調(diào)用

什么是”異步調(diào)用”與”同步調(diào)用”

“同步調(diào)用”就是程序按照一定的順序依次執(zhí)行，，每一行程序代碼必須等上一行代碼執(zhí)行完畢才能執(zhí)行；”異步調(diào)用”則是只要上一行代碼執(zhí)行，無需等待結(jié)果的返回就開始執(zhí)行本身任務(wù)。
通常情況下，”同步調(diào)用”執(zhí)行程序所花費的時間比較多，執(zhí)行效率比較差。所以，在代碼本身不存在依賴關(guān)系的話，我們可以考慮通過”異步調(diào)用”的方式來并發(fā)執(zhí)行。

“異步調(diào)用”

在 spring boot 框架中，只要提過@Async注解就能獎普通的同步任務(wù)改為異步調(diào)用任務(wù)。
注意： @Async所修飾的函數(shù)不要定義為static類型，這樣異步調(diào)用不會生效

1. 開啟@Async注解

在Spring Boot主類添加@EnableAsync注解

2. 定義異步任務(wù)

定義Task類，創(chuàng)建三個處理函數(shù)分別模擬三個執(zhí)行任務(wù)的操作，操作消耗時間隨機取（10秒內(nèi)）。

@Component
public class Task {

  //定義一個隨機對象.
  public static Random random =new Random();

  @Async //加入"異步調(diào)用"注解
  public void doTaskOne() throws InterruptedException {
    System.out.println("開始執(zhí)行任務(wù)一");
    long start = System.currentTimeMillis();
    Thread.sleep(random.nextInt(10000));
    long end = System.currentTimeMillis();
    System.out.println("完成任務(wù)一，耗時：" + (end - start) + "毫秒");
  }

  @Async
  public void doTaskTwo() throws InterruptedException {
    System.out.println("開始執(zhí)行任務(wù)二");
    long start = System.currentTimeMillis();
    Thread.sleep(random.nextInt(10000));
    long end = System.currentTimeMillis();
    System.out.println("完成任務(wù)二，耗時：" + (end - start) + "毫秒");
  }

  @Async
  public void doTaaskThree() throws InterruptedException {
    System.out.println("開始執(zhí)行任務(wù)三");
    long start = System.currentTimeMillis();
    Thread.sleep(random.nextInt(10000));
    long end = System.currentTimeMillis();
    System.out.println("完成任務(wù)三，耗時：" + (end - start) + "毫秒");
  }
}

3. 創(chuàng)建Controller進行測試

注意@Autowired注入類，因為這個類已經(jīng)被 Spring 管理了。如果使用 new 來獲得線程類將不會執(zhí)行異步效果，這里涉及到在 Spring 中使用多線程。

@Controller
public class TaskController {

  @Autowired
  private Task TASK;

  @ResponseBody
  @RequestMapping("/task")
  public String task() throws Exception {
    System.out.println("開始執(zhí)行Controller任務(wù)");
    long start = System.currentTimeMillis();
    TASK.doTaskOne();
    TASK.doTaskTwo();
    TASK.doTaaskThree();
    long end = System.currentTimeMillis();
    System.out.println("完成Controller任務(wù)，耗時：" + (end - start) + "毫秒");
    return "success";
  }
}

4. 多次調(diào)用

訪問 http://localhost:8080/task 截圖: