From 5bd75fb4a2781c0d1e7f796f1e2f90e656e8b84a Mon Sep 17 00:00:00 2001 From: zrlw Date: Tue, 14 Apr 2026 17:54:35 +0800 Subject: [PATCH] Bump org.asynchttpclient:async-http-client from 2.12.4 to 3.0.9 and refactor DownloadZookeeperInitializer in /dubbo-test/dubbo-test-check --- dubbo-test/dubbo-test-check/pom.xml | 2 +- .../initializer/DownloadZookeeperInitializer.java | 7 ++++--- 2 files changed, 5 insertions(+), 4 deletions(-) diff --git a/dubbo-test/dubbo-test-check/pom.xml b/dubbo-test/dubbo-test-check/pom.xml index 631178db6a63..f4bdc80cf6d9 100644 --- a/dubbo-test/dubbo-test-check/pom.xml +++ b/dubbo-test/dubbo-test-check/pom.xml @@ -33,7 +33,7 @@ 4.2.0 1.28.0 1.6.0 - 2.12.4 + 3.0.9 diff --git a/dubbo-test/dubbo-test-check/src/main/java/org/apache/dubbo/test/check/registrycenter/initializer/DownloadZookeeperInitializer.java b/dubbo-test/dubbo-test-check/src/main/java/org/apache/dubbo/test/check/registrycenter/initializer/DownloadZookeeperInitializer.java index 93573edc3b0c..66aa5b39512d 100644 --- a/dubbo-test/dubbo-test-check/src/main/java/org/apache/dubbo/test/check/registrycenter/initializer/DownloadZookeeperInitializer.java +++ b/dubbo-test/dubbo-test-check/src/main/java/org/apache/dubbo/test/check/registrycenter/initializer/DownloadZookeeperInitializer.java @@ -26,6 +26,7 @@ import java.nio.file.Path; import java.nio.file.Paths; import java.nio.file.StandardCopyOption; +import java.time.Duration; import java.util.concurrent.ExecutionException; import java.util.concurrent.Future; import java.util.concurrent.TimeUnit; @@ -66,12 +67,12 @@ public class DownloadZookeeperInitializer extends ZookeeperInitializer { /** * The timeout when download zookeeper binary archive file. */ - private static final int REQUEST_TIMEOUT = 180 * 1000; + private static final Duration REQUEST_TIMEOUT = Duration.ofSeconds(180); /** * The timeout when connect the download url. */ - private static final int CONNECT_TIMEOUT = 60 * 1000; + private static final Duration CONNECT_TIMEOUT = Duration.ofSeconds(60); /** * Returns {@code true} if the file exists with the given file path, otherwise {@code false}. @@ -204,7 +205,7 @@ public void onThrowable(Throwable t) { } }); // Future timeout should 2 times as equal as REQUEST_TIMEOUT, because it will retry 1 time. - Response response = responseFuture.get(REQUEST_TIMEOUT * 2, TimeUnit.MILLISECONDS); + Response response = responseFuture.get(REQUEST_TIMEOUT.getSeconds() * 2, TimeUnit.SECONDS); Files.copy(response.getResponseBodyAsStream(), targetPath, StandardCopyOption.REPLACE_EXISTING); } }