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("测试"); }