Added timeout to http request.

Author: Thomasr

server/api-service/lowcoder-domain/src/main/java/org/lowcoder/domain/query/service/QueryExecutionServiceImpl.java

@@ -44,7 +44,7 @@ public class QueryExecutionServiceImpl implements QueryExecutionService {
     public Mono<QueryExecutionResult> executeQuery(Datasource datasource, Map<String, Object> queryConfig, Map<String, Object> requestParams,
                                                    String timeoutStr, QueryVisitorContext queryVisitorContext) {
 
-        int timeoutMs = QueryTimeoutUtils.parseQueryTimeoutMs(timeoutStr, requestParams, common.getMaxQueryTimeout());
+        int timeoutMs = QueryTimeoutUtils.parseQueryTimeoutMs(timeoutStr, requestParams, common.getMaxQueryTimeout() * 1000);
         queryConfig.putIfAbsent("timeoutMs", String.valueOf(timeoutMs));
 
         return Mono.defer(() -> {

server/api-service/lowcoder-sdk/src/main/java/org/lowcoder/sdk/webclient/WebClientBuildHelper.java

@@ -1,8 +1,11 @@
 package org.lowcoder.sdk.webclient;
 
+import io.netty.channel.ChannelOption;
 import io.netty.handler.ssl.SslContext;
 import io.netty.handler.ssl.SslContextBuilder;
 import io.netty.handler.ssl.util.InsecureTrustManagerFactory;
+import io.netty.handler.timeout.ReadTimeoutHandler;
+import io.netty.handler.timeout.WriteTimeoutHandler;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections4.CollectionUtils;
 import org.apache.commons.lang3.StringUtils;
@@ -24,6 +27,7 @@
 import java.security.cert.X509Certificate;
 import java.time.Duration;
 import java.util.Set;
+import java.util.concurrent.TimeUnit;
 
 @Slf4j
 public class WebClientBuildHelper {
@@ -87,7 +91,12 @@ public Builder toWebClientBuilder() {
         HttpClient httpClient = HttpClient.create();
         if (timeoutMs != null)
         {
-        	httpClient.responseTimeout(Duration.ofMillis(timeoutMs));
+            httpClient = httpClient
+                .responseTimeout(Duration.ofMillis(timeoutMs))
+                .option(ChannelOption.CONNECT_TIMEOUT_MILLIS, timeoutMs.intValue())
+                .doOnConnected(conn -> conn
+                    .addHandlerLast(new ReadTimeoutHandler(timeoutMs, TimeUnit.SECONDS))
+                    .addHandlerLast(new WriteTimeoutHandler(timeoutMs, TimeUnit.SECONDS)));
         }
 
         if (sslConfig != null) {