SpringBoot項目中異步調用接口方式知多少？
作者：Springboot實戰案例錦集
CompletableFuture提供了非常強大的異步編程方法，可同步，可異步，可編排任務執行，異步通過回調的方式執行。該對象很多的一些方法與前端JavaScript中的Promise對象有點相像。
環境：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對象有點相像。
完畢！！！
責任編輯：武曉燕
來源：
Spring全家桶實戰案例源碼
