增加日志

src/main/java/com/viontech/match/config/ElasticsearchConfiguration.java

@@ -56,8 +56,8 @@ public class ElasticsearchConfiguration {
             connectionManager = new PoolingNHttpClientConnectionManager(new
             connectionManager = new PoolingNHttpClientConnectionManager(new
                     DefaultConnectingIOReactor(ioReactorConfig));
                     DefaultConnectingIOReactor(ioReactorConfig));
             // 设置最大连接数
             // 设置最大连接数
-            connectionManager.setMaxTotal(200);  // 整个连接池的最大连接数
-            connectionManager.setDefaultMaxPerRoute(40);
+            connectionManager.setMaxTotal(properties.getMaxConnTotal());  // 整个连接池的最大连接数
+            connectionManager.setDefaultMaxPerRoute(properties.getMaxConnPerRoute());
         } catch (IOReactorException e) {
         } catch (IOReactorException e) {
             throw new RuntimeException(e);
             throw new RuntimeException(e);
         }
         }

src/main/java/com/viontech/match/service/PersonService.java

@@ -596,6 +596,7 @@ public class PersonService {
         List<Person> persons = new ArrayList<>();
         List<Person> persons = new ArrayList<>();
 //        log.info("request:{}", JSON.tojsonS);
 //        log.info("request:{}", JSON.tojsonS);
         try {
         try {
+            log.info("人员匹配查es开始");
             SearchResponse<SearchResultHit> search = client.search(searchRequest, SearchResultHit.class);
             SearchResponse<SearchResultHit> search = client.search(searchRequest, SearchResultHit.class);
             if (agg) {
             if (agg) {
                 Map aggregations = search.aggregations();
                 Map aggregations = search.aggregations();
@@ -611,7 +612,7 @@ public class PersonService {
 //            }
 //            }
             } else {
             } else {
                 HitsMetadata hits = search.hits();
                 HitsMetadata hits = search.hits();
-//            log.info("match0:{}", hits.toString());
+                log.info("人员匹配, 耗时:{}", search.took());
                 List<Hit<SearchResultHit>> hits1 = hits.hits();
                 List<Hit<SearchResultHit>> hits1 = hits.hits();
                 for (Hit item : hits1) {
                 for (Hit item : hits1) {
                     SearchResultHit hit = (SearchResultHit) item.source();
                     SearchResultHit hit = (SearchResultHit) item.source();
@@ -639,7 +640,7 @@ public class PersonService {
                 }
                 }
             }
             }
         } catch (Exception e) {
         } catch (Exception e) {
-           log.error("match0 excepton", e.getMessage());
+           log.error("match0 excepton", e);
         }
         }
 
 
         return persons;
         return persons;