From 57026123239887185095b93e65fb4a91f85431ae Mon Sep 17 00:00:00 2001 From: liukang <644012909@qq.com> Date: Tue, 4 Mar 2025 23:27:36 +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 --- ruoyi-admin/src/main/java/com/ruoyi/web/task/RyTask.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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 f68494d..73d655d 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 @@ -303,9 +303,9 @@ public class RyTask { Thread.sleep(start - now - perform.getDelayTime()); log.info("抢票开始了"); for (MyReq r : req) { - log.info("【用户】:" + r.getUser()); // 发起异步请求,但不等待结果 CompletableFuture> future2 = client.sendAsync(r.getRequest(), HttpResponse.BodyHandlers.ofString()); + log.info("【用户】:" + r.getUser()); future2.thenAccept(response -> { // 处理响应(例如,记录日志) log.info("Response received: " + response.statusCode()); @@ -315,6 +315,7 @@ public class RyTask { ex.printStackTrace(); return null; }); + log.info("测试"); }