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

httpclient 复用
All checks were successful
continuous-integration/drone Build is passing
Details

Browse Source
This commit is contained in:
liukang 2025-03-04 23:27:36 +08:00
parent ae05f59e73
commit 5702612323
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -303,9 +303,9 @@ public class RyTask {
Thread.sleep(start - now - perform.getDelayTime()); Thread.sleep(start - now - perform.getDelayTime());
log.info("抢票开始了"); log.info("抢票开始了");
for (MyReq r : req) { for (MyReq r : req) {
log.info("【用户】：" + r.getUser());
// 发起异步请求，但不等待结果 // 发起异步请求，但不等待结果
CompletableFuture<HttpResponse<String>> future2 = client.sendAsync(r.getRequest(), HttpResponse.BodyHandlers.ofString()); CompletableFuture<HttpResponse<String>> future2 = client.sendAsync(r.getRequest(), HttpResponse.BodyHandlers.ofString());
log.info("【用户】：" + r.getUser());
future2.thenAccept(response -> { future2.thenAccept(response -> {
// 处理响应（例如，记录日志） // 处理响应（例如，记录日志）
log.info("Response received: " + response.statusCode()); log.info("Response received: " + response.statusCode());
@ -315,6 +315,7 @@ public class RyTask {
ex.printStackTrace(); ex.printStackTrace();
return null; return null;
}); });
log.info("测试");
} }