From d404ded7e0d9b27a6005cc5e84db17fc3380ef68 Mon Sep 17 00:00:00 2001
From: liukang <644012909@qq.com>
Date: Wed, 5 Mar 2025 00:00:09 +0800
Subject: [PATCH] =?UTF-8?q?httpclient=20=E5=A4=8D=E7=94=A8?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../src/main/java/com/ruoyi/web/task/RyTask.java | 16 +++-------------
 1 file changed, 3 insertions(+), 13 deletions(-)

diff --git a/ruoyi-admin/src/main/java/com/ruoyi/web/task/RyTask.java b/ruoyi-admin/src/main/java/com/ruoyi/web/task/RyTask.java
index ccd213a..7010215 100644
--- a/ruoyi-admin/src/main/java/com/ruoyi/web/task/RyTask.java
+++ b/ruoyi-admin/src/main/java/com/ruoyi/web/task/RyTask.java
@@ -273,8 +273,6 @@ public class RyTask {
         List<MyReq> req = new ArrayList<>();
         ExecutorService executorService = Executors.newFixedThreadPool(100);
         HttpClient client = HttpClient.newHttpClient();
-        // 创建一个请求列表
-        List<CompletableFuture<String>> futures = new ArrayList<>();
 
         for (Apply a : applies) {
             // 准备JSON负载
@@ -312,20 +310,12 @@ public class RyTask {
             // 发起异步请求，但不等待结果
             CompletableFuture<String> future2 = client.sendAsync(r.getRequest(), HttpResponse.BodyHandlers.ofString())
                     .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();