什么是異步調(diào)用？

異步調(diào)用是相對(duì)于同步調(diào)用而言的，同步調(diào)用是指程序按預(yù)定順序一步步執(zhí)行，每一步必須等到上一步執(zhí)行完后才能執(zhí)行，異步調(diào)用則無需等待上一步程序執(zhí)行完即可執(zhí)行。

如何實(shí)現(xiàn)異步調(diào)用？

多線程，這是很多人第一眼想到的關(guān)鍵詞，沒錯(cuò)，多線程就是一種實(shí)現(xiàn)異步調(diào)用的方式。

在非spring目項(xiàng)目中我們要實(shí)現(xiàn)異步調(diào)用的就是使用多線程方式，可以自己實(shí)現(xiàn)Runable接口或者集成Thread類，或者使用jdk1.5以上提供了的Executors線程池。

StrngBoot中則提供了很方便的方式執(zhí)行異步調(diào)用。

異步接口的使用場景

耗時(shí)比較長，任務(wù)比較多的接口。比方說，文件下載，大文件下載比較耗時(shí)，這個(gè)時(shí)候就可以使用異步接口。

項(xiàng)目示例已上傳至GitHub，可見github項(xiàng)目地址。

   在解釋異步調(diào)用之前，我們先來看同步調(diào)用的定義；同步就是整個(gè)處理過程順序執(zhí)行，當(dāng)各個(gè)過程都執(zhí)行完畢，并返回結(jié)果。 異步調(diào)用則是只是發(fā)送了調(diào)用的指令，調(diào)用者無需等待被調(diào)用的方法完全執(zhí)行完畢；而是繼續(xù)執(zhí)行下面的流程。

   例如， 在某個(gè)調(diào)用中，需要順序調(diào)用 A, B, C三個(gè)過程方法；如他們都是同步調(diào)用，則需要將他們都順序執(zhí)行完畢之后，方算作過程執(zhí)行完畢； 如B為一個(gè)異步的調(diào)用方法，則在執(zhí)行完A之后，調(diào)用B，并不等待B完成，而是執(zhí)行開始調(diào)用C，待C執(zhí)行完畢之后，就意味著這個(gè)過程執(zhí)行完畢了。

@Async介紹

基于@Async標(biāo)注的方法稱為異步方法，方法在執(zhí)行的時(shí)候，將會(huì)在獨(dú)立的線程中被執(zhí)行，調(diào)用者無需等待它的完成，即可繼續(xù)其他的操作。使用時(shí)在SpringBoot主配置類中開啟異步即可。

@EnableAsync
@SpringBootApplication
public class SpringBootAsyncTestApplication {

無返回值異步方法

@Async
public void asyncMethodWithNoReturnType() {
  try {
    Thread.sleep(3000);
  } catch (InterruptedException e) {
    e.printStackTrace();
  }
  System.out.println("asyncMethodWithNoReturnType...");
}

使用方法比較簡單，編寫一個(gè)測試方法并加上@Async注解即可。

含返回值異步方法

@Async
public Future<String> asyncMethodWithReturnType() {
  try {
  		Thread.sleep(3000);
  		return new AsyncResult<String>("success");
  } catch (InterruptedException e) {
  		e.printStackTrace();
  }
  System.out.println("asyncMethodWithReturnType...");
  return null;
}

返回值利用Future泛型接口實(shí)現(xiàn)。

Future是對(duì)于具體的 Runnable 或者 Callable 任務(wù)的執(zhí)行結(jié)果進(jìn)行取消、查詢是否完成、獲取結(jié)果的接口，必要時(shí)可以通過get方法獲取執(zhí)行結(jié)果，該方法會(huì)阻塞直到任務(wù)返回結(jié)果，包含了以下幾個(gè)方法。

public interface Future<V> {
  boolean cancel(boolean mayInterruptIfRunning);
  
  boolean isCancelled();
  
  boolean isDone();

  V get() throws InterruptedException, ExecutionException;
  
  V get(long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException;
}

1.cancel方法的作用是取消任務(wù)，取消任務(wù)成功則返回true，反之返回false。參數(shù) mayInterruptIfRunning 表示是否允許取消正在執(zhí)行卻沒有執(zhí)行完畢的任務(wù)。

運(yùn)行cancel方法取消任務(wù)時(shí)：

i.若任務(wù)已完成：則無論 mayInterruptIfRunning 為 true 或 false，此方法都返回 false，即取消已經(jīng)完成的任務(wù)都會(huì)返回false。

i.若任務(wù)正在執(zhí)行：

•  mayInterruptIfRunning 設(shè)置為 true，則返回true。
• mayInterruptIfRunning 設(shè)置為false，則返回false。

iii.如果任務(wù)未執(zhí)行，則無論mayInterruptIfRunning為true還是false，都返回true。

2.isCancelled方法的作用是判斷任務(wù)是否被取消成功，若在任務(wù)正常完成前被取消，則返回 true。

3.isDone方法的作用是判斷任務(wù)是否已經(jīng)完成，若任務(wù)已完成，則返回true。

4.get()方法的作用是獲取執(zhí)行結(jié)果，注意此方法會(huì)產(chǎn)生阻塞，等到任務(wù)執(zhí)行完畢后才能獲得執(zhí)行結(jié)果。

5.get(long timeout, TimeUnit unit)方法的作用同樣是獲取執(zhí)行結(jié)果，若在指定時(shí)間內(nèi)還未獲取到執(zhí)行結(jié)果，則返回null。

編寫測試接口

編寫/callWithNoReturnType和/callWithReturnType接口用于查看異步任務(wù)的執(zhí)行過程。

@RestController
public class AsyncController {
  @Autowired
  AsyncService asynSerivce;

  @GetMapping("/callWithNoReturnType")
  public String callWithNoReturnType() {
    asynSerivce.asyncMethodWithNoReturnType();
    return "success";
  }

  @GetMapping("/callWithReturnType")
  public String callWithReturnType() {
    Future<String> future=asynSerivce.asyncMethodWithReturnType();
    try {
      return future.get();
    } catch (InterruptedException e) {
      e.printStackTrace();
    } catch (ExecutionException e) {
      e.printStackTrace();
    }
    return "fail";
  }

運(yùn)行項(xiàng)目后使用Postman進(jìn)行接口測試，分別給/callWithNoReturnType和/callWithReturnType接口發(fā)送Get請(qǐng)求，調(diào)用無返回值的異步方法asyncWithNoReturnType時(shí)，會(huì)立即返回返回值。但調(diào)用含返回值異步方法asyncWithReturnType時(shí)，由于我們調(diào)用了get()方法，會(huì)在等待3000毫秒后，才返回返回值。

到此這篇關(guān)于SpringBoot用@Async注解實(shí)現(xiàn)異步任務(wù)的文章就介紹到這了,更多相關(guān)SpringBoot @Async異步內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評(píng)論