feat: support portal restTemplate config ConnectionTimeToLive via Por…

…talConfig `api.connectionTimeToLive` (#5120)
apolloconfig · Apr 9, 2024 · 287ec50 · 287ec50
1 parent c884de5
commit 287ec50
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 1 deletion.
diff --git a/...portal/src/main/java/com/ctrip/framework/apollo/portal/component/RestTemplateFactory.java b/...portal/src/main/java/com/ctrip/framework/apollo/portal/component/RestTemplateFactory.java
@@ -28,6 +28,7 @@
 import org.springframework.web.client.RestTemplate;
 
 import java.io.UnsupportedEncodingException;
+import java.util.concurrent.TimeUnit;
 
 @Component
 public class RestTemplateFactory implements FactoryBean<RestTemplate>, InitializingBean {
@@ -58,7 +59,9 @@ public boolean isSingleton() {
   }
 
   public void afterPropertiesSet() throws UnsupportedEncodingException {
-    CloseableHttpClient httpClient = HttpClientBuilder.create().build();
+    CloseableHttpClient httpClient = HttpClientBuilder.create()
+        .setConnectionTimeToLive(portalConfig.connectionTimeToLive(), TimeUnit.MILLISECONDS)
+        .build();
 
     restTemplate = new RestTemplate(httpMessageConverters.getConverters());
     HttpComponentsClientHttpRequestFactory requestFactory =

diff --git a/...portal/src/main/java/com/ctrip/framework/apollo/portal/component/config/PortalConfig.java b/...portal/src/main/java/com/ctrip/framework/apollo/portal/component/config/PortalConfig.java
@@ -169,6 +169,10 @@ public int readTimeout() {
     return getIntProperty("api.readTimeout", 10000);
   }
 
+  public int connectionTimeToLive() {
+    return getIntProperty("api.connectionTimeToLive", -1);
+  }
+
   public List<Organization> organizations() {
 
     String organizations = getValue("organizations");