perf($Starter): abstract rest template configuration

[skip ci]

spring-boot-starter/src/main/java/com/jmsoftware/maf/springbootstarter/MafAutoConfiguration.java

@@ -55,7 +55,8 @@
         RedisConfiguration.class,
         Swagger2Configuration.class,
         SftpConfiguration.class,
-        WebSecurityConfiguration.class
+        WebSecurityConfiguration.class,
+        RestTemplateConfiguration.class
 })
 public class MafAutoConfiguration {
     @PostConstruct
@@ -161,11 +162,4 @@ public JwtConfiguration jwtConfiguration(MafProjectProperty mafProjectProperty)
         log.warn("Initial bean: '{}'", JwtConfiguration.class.getSimpleName());
         return new JwtConfiguration(mafProjectProperty);
     }
-
-    @Bean
-    @LoadBalanced
-    public RestTemplate restTemplate() {
-        log.warn("Initial bean: '{}'", RestTemplate.class.getSimpleName());
-        return new RestTemplate();
-    }
 }

spring-boot-starter/src/main/java/com/jmsoftware/maf/springbootstarter/configuration/RestTemplateConfiguration.java

@@ -0,0 +1,41 @@
+package com.jmsoftware.maf.springbootstarter.configuration;
+
+import lombok.extern.slf4j.Slf4j;
+import lombok.val;
+import org.apache.http.impl.client.HttpClients;
+import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
+import org.springframework.cloud.client.loadbalancer.LoadBalanced;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.http.client.HttpComponentsClientHttpRequestFactory;
+import org.springframework.web.client.DefaultResponseErrorHandler;
+import org.springframework.web.client.RestTemplate;
+
+/**
+ * Description: RestTemplateConfiguration, change description here.
+ *
+ * @author 钟俊（zhongjun）, email: zhongjun@toguide.cn, date: 1/29/2021 4:29 PM
+ **/
+@Slf4j
+@Configuration
+public class RestTemplateConfiguration {
+    @Bean
+    @LoadBalanced
+    public RestTemplate restTemplate() {
+        val poolingHttpClientConnectionManager = new PoolingHttpClientConnectionManager();
+        poolingHttpClientConnectionManager.setMaxTotal(1000);
+        poolingHttpClientConnectionManager.setDefaultMaxPerRoute(1000);
+        val httpClientBuilder = HttpClients.custom();
+        httpClientBuilder.setConnectionManager(poolingHttpClientConnectionManager);
+        val httpClient = httpClientBuilder.build();
+        val httpComponentsClientHttpRequestFactory = new HttpComponentsClientHttpRequestFactory(httpClient);
+        httpComponentsClientHttpRequestFactory.setConnectTimeout(6000);
+        httpComponentsClientHttpRequestFactory.setReadTimeout(6000);
+        httpComponentsClientHttpRequestFactory.setConnectionRequestTimeout(200);
+        val restTemplate = new RestTemplate();
+        restTemplate.setRequestFactory(httpComponentsClientHttpRequestFactory);
+        restTemplate.setErrorHandler(new DefaultResponseErrorHandler());
+        log.warn("Initial bean: '{}'", restTemplate.getClass().getSimpleName());
+        return restTemplate;
+    }
+}