亚洲视频二区_亚洲欧洲日本天天堂在线观看_日韩一区二区在线观看_中文字幕不卡一区

環境：springboot2.5.12

經常會遇到在項目中調用第三方接口的情景，你是如何調用的呢？同步？異步？

場景：

假設下單業務流程如下步驟：

1、查詢用戶信息。

2、查詢庫存信息。

3、查詢活動信息（折扣）。

1、同步順序調用

public boolean createOrder() {
  long start = System.currentTimeMillis() ;
  String userResult = restTemplate.getForObject("http://localhost:8080/users/{1}", String.class, new Object[] {1}) ;
  String storageResult = restTemplate.getForObject("http://localhost:8080/storage/{1}", String.class, new Object[] {1}) ;
  String discountResult = restTemplate.getForObject("http://localhost:8080/discount/{1}", String.class, new Object[] {1}) ;
  // 這里合并請求結果處理
  System.out.println(Arrays.toString(new String[] {userResult, storageResult, discountResult})) ;
  System.out.println("傳統方式耗時：" + (System.currentTimeMillis() - start) + "毫秒") ;
  return true ;
}
@GetMApping("/create")
public Object create() {
  return os.createOrder() ;
}

調用結果：

圖片

接口一個一個調用，非常耗時。

2、多線程（Callable+Future）

public boolean createOrder2() {
  long start = System.currentTimeMillis() ;
  Callable<String> userCallable = () -> {
    return restTemplate.getForObject("http://localhost:8080/users/{1}", String.class, new Object[] {1}) ;
  } ;
  Callable<String> storageCallable = () -> {
    return restTemplate.getForObject("http://localhost:8080/storage/{1}", String.class, new Object[] {1}) ;
  } ;
  Callable<String> discountCallable = () -> {
    return restTemplate.getForObject("http://localhost:8080/discount/{1}", String.class, new Object[] {1}) ;
  } ;
  FutureTask<String> userTask = new FutureTask<>(userCallable) ;
  FutureTask<String> storageTask = new FutureTask<>(storageCallable) ;
  FutureTask<String> discountTask = new FutureTask<>(discountCallable) ;
  new Thread(userTask).start() ;
  new Thread(storageTask).start() ;
  new Thread(discountTask).start() ;
  try {
    String userResult = userTask.get() ;
    String storageResult = storageTask.get() ;
    String discountResult = discountTask.get() ;
    // 這里合并請求結果處理
    System.out.println(Arrays.toString(new String[] {userResult, storageResult, discountResult})) ;
  } catch (InterruptedException | ExecutionException e) {
    e.printStackTrace();
  }
  System.out.println("多線程方式耗時：" + (System.currentTimeMillis() - start) + "毫秒") ;
  return true ;
}

調用結果：

圖片

這次耗時少了，性能明顯提升了。但在項目中我們一般是禁止直接創建線程的，如果這是個高并發的接口，那么我們的程序很可能出現OOM的錯誤。

3、線程池（Callable+Future）防止內存溢出風險

ThreadPoolExecutor pool = new ThreadPoolExecutor(5, 5, 60, TimeUnit.SECONDS, new ArrayBlockingQueue<Runnable>(1000)) ;
  public boolean createOrder3() {
  long start = System.currentTimeMillis() ;
  List<Future<String>> results = new ArrayList<>(3) ;
  results.add(pool.submit(() -> {
      return restTemplate.getForObject("http://localhost:8080/users/{1}", String.class, new Object[] {1}) ;
  })) ;
  results.add(pool.submit(() -> {
      return restTemplate.getForObject("http://localhost:8080/storage/{1}", String.class, new Object[] {1}) ;
  })) ;
  results.add(pool.submit(() -> {
    return restTemplate.getForObject("http://localhost:8080/discount/{1}", String.class, new Object[] {1}) ;
  })) ;
  for (int i = 0, size = results.size(); i < size; i++) {
    try {
      System.out.println(results.get(i).get()) ;
    } catch (InterruptedException | ExecutionException e) {
      e.printStackTrace();
    }
  }
  System.out.println("線程池方式耗時：" + (System.currentTimeMillis() - start) + "毫秒") ;
  return true ;
}

調用結果：

圖片

耗時和上一個基本一致，通過Future的方式有一個問題就是只能一個一個的取值，只有當前的返回數據了后才會繼續往下執行。如果有其它的任務執行完，那沒有輪到它也必須等待。

4、CompletionService（異步任務與使用已完成任務的結果分離），submit提交任務，take獲取已經完成的任務，不用按照submit的順序獲取結果。

public boolean createOrder4() {
  long start = System.currentTimeMillis() ;
  CompletionService<String> cs = new ExecutorCompletionService<>(pool) ;
  cs.submit(() -> {
    return restTemplate.getForObject("http://localhost:8080/users/{1}", String.class, new Object[] {1}) ;
  }) ;
  cs.submit(() -> {
    return restTemplate.getForObject("http://localhost:8080/storage/{1}", String.class, new Object[] {1}) ;
  }) ;
  cs.submit(() -> {
    return restTemplate.getForObject("http://localhost:8080/discount/{1}", String.class, new Object[] {1}) ;
  }) ;
  for (int i = 2 ; i >=0; i--) {
    try {
      System.out.println(cs.take().get()) ;
    } catch (InterruptedException | ExecutionException e) {
      e.printStackTrace();
    }
  }
  System.out.println("CompletionService方式耗時：" + (System.currentTimeMillis() - start) + "毫秒") ;
  return true ;
}

調用結果：

圖片

通過CompletionService方式不管任務添加的順序是什么，只要通過take方法就能獲取執行完的結果，如果沒有任務執行完，take方法會阻塞。

5、CompletableFuture（異步任務編排），JDK1.8

public boolean createOrder5() {
  long start = System.currentTimeMillis() ;
  CompletableFuture<String> userFuture = CompletableFuture.supplyAsync(() -> {
    return restTemplate.getForObject("http://localhost:8080/users/{1}", String.class, new Object[] {1}) ;
  }) ;
    
  CompletableFuture<String> storageFuture = CompletableFuture.supplyAsync(() -> {
    return restTemplate.getForObject("http://localhost:8080/storage/{1}", String.class, new Object[] {1}) ;
  }) ;
    
  CompletableFuture<String> discountFuture = CompletableFuture.supplyAsync(() -> {
    return restTemplate.getForObject("http://localhost:8080/discount/{1}", String.class, new Object[] {1});
  }) ;
  CompletableFuture<List<String>> result = CompletableFuture
      .allOf(userFuture, storageFuture, discountFuture)
      .thenApply((Void) -> {
        List<String> datas = new ArrayList<>() ;
        try {
          datas.add(userFuture.get()) ;
          datas.add(storageFuture.get()) ;
          datas.add(discountFuture.get()) ;
        } catch (InterruptedException | ExecutionException e) {
          e.printStackTrace();
        }
        return datas ;
      }).exceptionally(e -> {
        e.printStackTrace() ;
        return null ;
      }) ;
  try {
    System.out.println(result.get()) ;
  } catch (InterruptedException | ExecutionException e1) {
    e1.printStackTrace();
  }
  System.out.println("CompletableFuture方式耗時：" + (System.currentTimeMillis() - start) + "毫秒") ;
  return true ;
}

調用結果：

圖片

CompletableFuture提供了非常強大的異步編程方法，可同步，可異步，可編排任務執行，異步通過回調的方式執行。該對象很多的一些方法與前端JAVAScript中的Promise對象有點相像。

完畢！！！