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 8222c66..1013f58 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 @@ -7,6 +7,8 @@ public class MyReq { private HttpClient client; private HttpRequest request; + private String user; + public HttpClient getClient() { return client; } @@ -23,8 +25,17 @@ public class MyReq { this.request = request; } - public MyReq(HttpClient client, HttpRequest request) { + public String getUser() { + return user; + } + + public void setUser(String user) { + this.user = user; + } + + public MyReq(HttpClient client, HttpRequest request, String user) { this.client = client; 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 21ee645..f30ad61 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 @@ -104,7 +104,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)); + req.add(new MyReq(client, request, a.getName())); } Calendar calendar = Calendar.getInstance(); @@ -115,6 +115,7 @@ public class RyTask { Thread.sleep(start - now); log.info("抢票开始了"); for (MyReq r : req) { + log.info(r.getUser()); // 发起异步请求,但不等待结果 CompletableFuture> future2 = r.getClient().sendAsync(r.getRequest(), HttpResponse.BodyHandlers.ofString()); future2.thenAccept(response -> {