diff --git a/ruoyi-admin/src/main/java/com/ruoyi/web/task/MyReq.java b/ruoyi-admin/src/main/java/com/ruoyi/web/task/MyReq.java index 1013f58..63a4c85 100644 --- a/ruoyi-admin/src/main/java/com/ruoyi/web/task/MyReq.java +++ b/ruoyi-admin/src/main/java/com/ruoyi/web/task/MyReq.java @@ -4,18 +4,11 @@ import java.net.http.HttpClient; import java.net.http.HttpRequest; public class MyReq { - private HttpClient client; + private HttpRequest request; private String user; - public HttpClient getClient() { - return client; - } - - public void setClient(HttpClient client) { - this.client = client; - } public HttpRequest getRequest() { return request; @@ -33,8 +26,7 @@ public class MyReq { this.user = user; } - public MyReq(HttpClient client, HttpRequest request, String user) { - this.client = client; + public MyReq( HttpRequest request, String user) { this.request = request; this.user = user; } 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 56c685d..f68494d 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 @@ -269,6 +269,8 @@ public class RyTask { List req = new ArrayList<>(); + HttpClient client = HttpClient.newHttpClient(); + for (Apply a : applies) { // 准备JSON负载 Map eventData = new HashMap<>(); @@ -283,7 +285,6 @@ public class RyTask { ObjectMapper mapper = new ObjectMapper(); String jsonPayload = mapper.writeValueAsString(eventData); - HttpClient client = HttpClient.newHttpClient(); HttpRequest request = HttpRequest.newBuilder() .uri(URI.create(url)) .header("Content-Type", "application/json") @@ -291,7 +292,7 @@ public class RyTask { .header("User-Agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/91.0.4472.124 Safari/537.36") .POST(HttpRequest.BodyPublishers.ofString(jsonPayload)) .build(); - req.add(new MyReq(client, request, a.getWeverseEmail())); + req.add(new MyReq(request, a.getWeverseEmail())); } Calendar calendar = Calendar.getInstance(); @@ -304,7 +305,7 @@ public class RyTask { for (MyReq r : req) { log.info("【用户】:" + r.getUser()); // 发起异步请求,但不等待结果 - CompletableFuture> future2 = r.getClient().sendAsync(r.getRequest(), HttpResponse.BodyHandlers.ofString()); + CompletableFuture> future2 = client.sendAsync(r.getRequest(), HttpResponse.BodyHandlers.ofString()); future2.thenAccept(response -> { // 处理响应(例如,记录日志) log.info("Response received: " + response.statusCode()); @@ -316,6 +317,7 @@ public class RyTask { }); } + //status Perform pStatus2 = new Perform(); pStatus2.setStatus("3");