feat(statis):性能

amos-boot-system-tzs/amos-boot-module-statistics/amos-boot-module-statistics-biz/src/main/java/com/yeejoin/amos/boot/module/statistcs/biz/config/ElasticSearchClientConfig.java

@@ -36,7 +36,9 @@ public class ElasticSearchClientConfig {
             RestClientBuilder builder = RestClient.builder(httpHosts);
             builder.setHttpClientConfigCallback(httpClientBuilder -> {
                 httpClientBuilder.disableAuthCaching();
-                return httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider);
+                return httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider)
+                        .setMaxConnTotal(200)
+                        .setMaxConnPerRoute(60);
             });
             // 该方法接收一个RequestConfig.Builder对象，对该对象进行修改后然后返回。
             builder.setRequestConfigCallback(requestConfigBuilder -> {

amos-boot-system-tzs/amos-boot-module-statistics/amos-boot-module-statistics-biz/src/main/java/com/yeejoin/amos/boot/module/statistcs/biz/config/RestTemplateConfig.java

 package com.yeejoin.amos.boot.module.statistcs.biz.config;
 
+import org.apache.http.impl.client.CloseableHttpClient;
+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.RestTemplate;
 
 /**
@@ -15,7 +19,18 @@ public class RestTemplateConfig {
 
     @Bean
     @LoadBalanced
-    public RestTemplate getRestTemplate() {
-        return new RestTemplate();
+    public RestTemplate loadBalancedRestTemplate() {
+        PoolingHttpClientConnectionManager manager = new PoolingHttpClientConnectionManager();
+        manager.setMaxTotal(200);
+        manager.setDefaultMaxPerRoute(50);
+        CloseableHttpClient httpClient = HttpClients.custom()
+                .setConnectionManager(manager)
+                .build();
+
+        // 2. 创建自定义工厂（最终会被 InterceptingClientHttpRequestFactory 包装）
+        HttpComponentsClientHttpRequestFactory factory = new HttpComponentsClientHttpRequestFactory(httpClient);
+        factory.setConnectTimeout(5000);
+        factory.setReadTimeout(60000);
+        return new RestTemplate(factory);
     }
-}
\ No newline at end of file
+}

amos-boot-system-tzs/amos-boot-module-statistics/amos-boot-module-statistics-biz/src/main/java/com/yeejoin/amos/boot/module/statistcs/biz/service/impl/DPSubServiceImpl.java

@@ -54,8 +54,7 @@ public class DPSubServiceImpl {
     private static final String GATEWAY_SERVER_NAME = "AMOS-SERVER-GATEWAY";
 
     @Autowired
-    @LoadBalanced
-    private RestTemplate restTemplate;
+    private RestTemplate loadBalancedRestTemplate;
 
     @Autowired
     DataDictionaryServiceImpl iDataDictionaryService;
@@ -857,6 +856,7 @@ public class DPSubServiceImpl {
     }
 
     public ResponseModel getApiResult(JSONObject apiObj, String resultConvert, JSONObject detailResult) {
+        log.info("restTemplate 请求的客户端是：{}", loadBalancedRestTemplate.getRequestFactory().getClass());;
         String url = apiObj.getString("apiPath");
         if(ValidationUtil.isEmpty(url)){
             return null;
@@ -893,19 +893,19 @@ public class DPSubServiceImpl {
                 URI reqUri = new URI(reqUrl);
                 if (StringUtils.contrastLowerStr("GET", reqType)) {
                     responseEntity = reqUrl.contains(GATEWAY_SERVER_NAME)
-                            ? RestTemplateUtils.get(restTemplate, reqUri, httpHeaders, body, String.class, new HashMap<>())
+                            ? RestTemplateUtils.get(loadBalancedRestTemplate, reqUri, httpHeaders, body, String.class, new HashMap<>())
                             : RestTemplateUtils.get(reqUri, httpHeaders, body, String.class, new HashMap<>());
                 } else if (StringUtils.contrastLowerStr("POST", reqType)) {
                     responseEntity = reqUrl.contains(GATEWAY_SERVER_NAME)
-                            ? RestTemplateUtils.post(restTemplate, reqUri, httpHeaders, body, String.class, new HashMap<>())
+                            ? RestTemplateUtils.post(loadBalancedRestTemplate, reqUri, httpHeaders, body, String.class, new HashMap<>())
                             : RestTemplateUtils.post(reqUri, httpHeaders, body, String.class, new HashMap<>());
                 } else if (StringUtils.contrastLowerStr("PUT", reqType)) {
                     responseEntity = reqUrl.contains(GATEWAY_SERVER_NAME)
-                            ? RestTemplateUtils.put(restTemplate, reqUri, httpHeaders, body, String.class)
+                            ? RestTemplateUtils.put(loadBalancedRestTemplate, reqUri, httpHeaders, body, String.class)
                             : RestTemplateUtils.put(reqUri, httpHeaders, body, String.class);
                 } else if (StringUtils.contrastLowerStr("DELETE", reqType)) {
                     responseEntity = reqUrl.contains(GATEWAY_SERVER_NAME)
-                            ? RestTemplateUtils.delete(restTemplate, reqUri, httpHeaders, body, String.class)
+                            ? RestTemplateUtils.delete(loadBalancedRestTemplate, reqUri, httpHeaders, body, String.class)
                             : RestTemplateUtils.delete(reqUri, httpHeaders, body, String.class);
                 }
             } catch (Exception e) {