连接地址调整

src/main/java/com/bfd/crawl/handlerdata/service/ElasticSearchService.java

@@ -49,7 +49,7 @@ public class ElasticSearchService {
             String host = (String) admin.get("host");
             String port = (String) admin.get("port");
             String requestUrl = "http://";
-            requestUrl = requestUrl.concat("172.26.250.44").concat(":").concat("9200").concat("/");
+            requestUrl = requestUrl.concat("8.152.196.157").concat(":").concat("19200").concat("/");
             String scoreUrl = requestUrl.concat("_search/scroll");
             requestUrl = requestUrl.concat("cl_special_1.0_").concat(indexs).concat("/_search?scroll=5m");
             int index = 1;
@@ -86,7 +86,7 @@ public class ElasticSearchService {
                     Request firstRequest = new Request.Builder()
                             .url(requestUrl)
                             .method("POST", body)
-                            .addHeader("Authorization", "Basic ZWxhc3RpYzpiYWlmZW5kaWFuMTIz")
+                            .addHeader("Authorization", "Basic ZWxhc3RpYzpid0AyMDI1")
                             .addHeader("Content-Type", "application/json")
                             .build();
                     String firstResultString = null;
@@ -136,7 +136,7 @@ public class ElasticSearchService {
                         RequestBody bodyScroll = RequestBody.create(mediaTypeScroll, JSON.toJSONString(newQlMap));
                         Request scrollRequest = new Request.Builder()
                                 .url(scoreUrl)
-                                .method("POST", bodyScroll).addHeader("Authorization", "Basic ZWxhc3RpYzpiYWlmZW5kaWFuMTIz")
+                                .method("POST", bodyScroll).addHeader("Authorization", "Basic ZWxhc3RpYzpid0AyMDI1")
                                 .addHeader("Content-Type", "application/json")
                                 .build();
                         String scrollResultString = null;
@@ -227,7 +227,7 @@ public class ElasticSearchService {
             Request firstRequest = new Request.Builder()
                     .url(requestUrl)
                     .method("POST", body)
-                    .addHeader("Authorization", "Basic ZWxhc3RpYzpiYWlmZW5kaWFuMTIz")
+                    .addHeader("Authorization", "Basic ZWxhc3RpYzpid0AyMDI1")
                     .addHeader("Content-Type", "application/json")
                     .build();
             Response firstResponse = client.newCall(firstRequest).execute();