feat(statis):性能

amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-biz/src/main/java/com/yeejoin/amos/boot/module/jg/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-jyjc/amos-boot-module-jyjc-biz/src/main/java/com/yeejoin/amos/boot/module/jyjc/biz/config/ElasticSearchClientConfig.java

@@ -34,7 +34,11 @@ public class ElasticSearchClientConfig {
         try {
             HttpHost[] httpHosts = Arrays.stream(uris.split(",")).map(HttpHost::create).toArray(HttpHost[]::new);
             RestClientBuilder builder = RestClient.builder(httpHosts);
-            builder.setHttpClientConfigCallback(httpClientBuilder -> httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider));
+            builder.setHttpClientConfigCallback(httpClientBuilder ->
+                    httpClientBuilder
+                            .setDefaultCredentialsProvider(credentialsProvider)
+                            .setMaxConnTotal(200)
+                            .setMaxConnPerRoute(50));
             // 该方法接收一个RequestConfig.Builder对象，对该对象进行修改后然后返回。
             builder.setRequestConfigCallback(requestConfigBuilder -> {
                 // 连接超时（默认为1秒）
@@ -43,6 +47,7 @@ public class ElasticSearchClientConfig {
                         .setSocketTimeout(60 * 1000);
             });
 
+
             return new RestHighLevelClient(builder);
         } catch (Exception e) {
             throw new IllegalStateException("Invalid ES nodes " + "property '" + uris + "'", e);

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

@@ -34,10 +34,9 @@ public class ElasticSearchClientConfig {
         try {
             HttpHost[] httpHosts = Arrays.stream(uris.split(",")).map(HttpHost::create).toArray(HttpHost[]::new);
             RestClientBuilder builder = RestClient.builder(httpHosts);
-            builder.setHttpClientConfigCallback(httpClientBuilder -> {
-                httpClientBuilder.disableAuthCaching();
-                return httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider);
-            });
+            builder.setHttpClientConfigCallback(httpClientBuilder -> httpClientBuilder.disableAuthCaching()
+                    .setDefaultCredentialsProvider(credentialsProvider).setMaxConnTotal(200)
+                    .setMaxConnPerRoute(60));
             // 该方法接收一个RequestConfig.Builder对象，对该对象进行修改后然后返回。
             builder.setRequestConfigCallback(requestConfigBuilder -> {
                 // 连接超时（默认为1秒）

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

@@ -34,10 +34,9 @@ public class ElasticSearchClientConfig {
         try {
             HttpHost[] httpHosts = Arrays.stream(uris.split(",")).map(HttpHost::create).toArray(HttpHost[]::new);
             RestClientBuilder builder = RestClient.builder(httpHosts);
-            builder.setHttpClientConfigCallback(httpClientBuilder -> {
-                httpClientBuilder.disableAuthCaching();
-                return httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider);
-            });
+            builder.setHttpClientConfigCallback(httpClientBuilder -> httpClientBuilder.disableAuthCaching().setDefaultCredentialsProvider(credentialsProvider)
+                    .setMaxConnTotal(200)
+                    .setMaxConnPerRoute(60));
             // 该方法接收一个RequestConfig.Builder对象，对该对象进行修改后然后返回。
             builder.setRequestConfigCallback(requestConfigBuilder -> {
                 // 连接超时（默认为1秒）