Commit40744e0

Thomasr

authored and

committed

Added timeout to http request.

1 parent5f79327 commit40744e0Copy full SHA for 40744e0

File tree

+11

-2

lines changed

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

+11

-2

lines changed

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -44,7 +44,7 @@ public class QueryExecutionServiceImpl implements QueryExecutionService {`
`44`	`44`	`publicMono<QueryExecutionResult>executeQuery(Datasourcedatasource,Map<String,Object>queryConfig,Map<String,Object>requestParams,`
`45`	`45`	`StringtimeoutStr,QueryVisitorContextqueryVisitorContext) {`
`46`	`46`
`47`		`-inttimeoutMs =QueryTimeoutUtils.parseQueryTimeoutMs(timeoutStr,requestParams,common.getMaxQueryTimeout());`
	`47`	`+inttimeoutMs =QueryTimeoutUtils.parseQueryTimeoutMs(timeoutStr,requestParams,common.getMaxQueryTimeout() *1000);`
`48`	`48`	`queryConfig.putIfAbsent("timeoutMs",String.valueOf(timeoutMs));`
`49`	`49`
`50`	`50`	`returnMono.defer(() -> {`

Lines changed: 10 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -1,8 +1,11 @@`
`1`	`1`	`packageorg.lowcoder.sdk.webclient;`
`2`	`2`
	`3`	`+importio.netty.channel.ChannelOption;`
`3`	`4`	`importio.netty.handler.ssl.SslContext;`
`4`	`5`	`importio.netty.handler.ssl.SslContextBuilder;`
`5`	`6`	`importio.netty.handler.ssl.util.InsecureTrustManagerFactory;`
	`7`	`+importio.netty.handler.timeout.ReadTimeoutHandler;`
	`8`	`+importio.netty.handler.timeout.WriteTimeoutHandler;`
`6`	`9`	`importlombok.extern.slf4j.Slf4j;`
`7`	`10`	`importorg.apache.commons.collections4.CollectionUtils;`
`8`	`11`	`importorg.apache.commons.lang3.StringUtils;`
`@@ -24,6 +27,7 @@`
`24`	`27`	`importjava.security.cert.X509Certificate;`
`25`	`28`	`importjava.time.Duration;`
`26`	`29`	`importjava.util.Set;`
	`30`	`+importjava.util.concurrent.TimeUnit;`
`27`	`31`
`28`	`32`	`@Slf4j`
`29`	`33`	`publicclassWebClientBuildHelper {`
`@@ -87,7 +91,12 @@ public Builder toWebClientBuilder() {`
`87`	`91`	`HttpClienthttpClient =HttpClient.create();`
`88`	`92`	`if (timeoutMs !=null)`
`89`	`93`	`{`
`90`		`-httpClient.responseTimeout(Duration.ofMillis(timeoutMs));`
	`94`	`+httpClient =httpClient`
	`95`	`+ .responseTimeout(Duration.ofMillis(timeoutMs))`
	`96`	`+ .option(ChannelOption.CONNECT_TIMEOUT_MILLIS,timeoutMs.intValue())`
	`97`	`+ .doOnConnected(conn ->conn`
	`98`	`+ .addHandlerLast(newReadTimeoutHandler(timeoutMs,TimeUnit.SECONDS))`
	`99`	`+ .addHandlerLast(newWriteTimeoutHandler(timeoutMs,TimeUnit.SECONDS)));`
`91`	`100`	`}`
`92`	`101`
`93`	`102`	`if (sslConfig !=null) {`

Comments

(0)