kkgggkgkgkg/weverse-api
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

抢票日志

Browse Source
This commit is contained in:
liukang 2025-02-24 09:01:16 +08:00
parent 97ccfaa912
commit 6160ddb8f5
2 changed files with 14 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
ruoyi-admin/src/main/java/com/ruoyi/web/task/MyReq.java
View File

@ -7,6 +7,8 @@ public class MyReq {
private HttpClient client; private HttpClient client;
private HttpRequest request; private HttpRequest request;
private String user;
public HttpClient getClient() { public HttpClient getClient() {
return client; return client;
} }
@ -23,8 +25,17 @@ public class MyReq {
this.request = request; 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.client = client;
this.request = request; this.request = request;
this.user = user;
} }
} }

3
ruoyi-admin/src/main/java/com/ruoyi/web/task/RyTask.java
View File

@ -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") .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)) .POST(HttpRequest.BodyPublishers.ofString(jsonPayload))
.build(); .build();
req.add(new MyReq(client, request)); req.add(new MyReq(client, request, a.getName()));
} }
Calendar calendar = Calendar.getInstance(); Calendar calendar = Calendar.getInstance();
@ -115,6 +115,7 @@ public class RyTask {
Thread.sleep(start - now); Thread.sleep(start - now);
log.info("抢票开始了"); log.info("抢票开始了");
for (MyReq r : req) { for (MyReq r : req) {
log.info(r.getUser());
// 发起异步请求，但不等待结果 // 发起异步请求，但不等待结果
CompletableFuture<HttpResponse<String>> future2 = r.getClient().sendAsync(r.getRequest(), HttpResponse.BodyHandlers.ofString()); CompletableFuture<HttpResponse<String>> future2 = r.getClient().sendAsync(r.getRequest(), HttpResponse.BodyHandlers.ofString());
future2.thenAccept(response -> { future2.thenAccept(response -> {