kkgggkgkgkg/weverse-api
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

httpclient 复用
All checks were successful
continuous-integration/drone Build is passing
Details

Browse Source
This commit is contained in:
liukang 2025-03-05 00:00:09 +08:00
parent b987415fa2
commit d404ded7e0
1 changed files with 3 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
ruoyi-admin/src/main/java/com/ruoyi/web/task/RyTask.java
View File

@ -273,8 +273,6 @@ public class RyTask {
List<MyReq> req = new ArrayList<>(); List<MyReq> req = new ArrayList<>();
ExecutorService executorService = Executors.newFixedThreadPool(100); ExecutorService executorService = Executors.newFixedThreadPool(100);
HttpClient client = HttpClient.newHttpClient(); HttpClient client = HttpClient.newHttpClient();
// 创建一个请求列表
List<CompletableFuture<String>> futures = new ArrayList<>();
for (Apply a : applies) { for (Apply a : applies) {
// 准备JSON负载 // 准备JSON负载
@ -312,20 +310,12 @@ public class RyTask {
// 发起异步请求，但不等待结果 // 发起异步请求，但不等待结果
CompletableFuture<String> future2 = client.sendAsync(r.getRequest(), HttpResponse.BodyHandlers.ofString()) CompletableFuture<String> future2 = client.sendAsync(r.getRequest(), HttpResponse.BodyHandlers.ofString())
.thenApplyAsync(HttpResponse::body, executorService); .thenApplyAsync(HttpResponse::body, executorService);
futures.add(future2); future2.thenAccept(response -> {
log.info(response);
});
} }
// 等待所有请求完成
CompletableFuture.allOf(futures.toArray(new CompletableFuture[0])).join();
// 输出所有请求的响应（可选）
for (CompletableFuture<String> future : futures) {
try {
System.out.println(future.get());
} catch (Exception e) {
log.error(e.getMessage());
}
}
// 关闭线程池 // 关闭线程池
executorService.shutdown(); executorService.shutdown();