Skywalking改成适配阿里云等带Http Basic的Elasticsearch服务

@Setter @Getter private String nameSpace;

     @Setter @Getter private String clusterNodes;

     private int indexShardsNumber;

     private int indexReplicasNumber;

     private boolean highPerformanceMode;

     private int traceDataTTL = 90 ;

     private int minuteMetricDataTTL = 90 ;

     private int hourMetricDataTTL = 36 ;

     private int dayMetricDataTTL = 45 ;

     private int monthMetricDataTTL = 18 ;

     private int bulkActions = 2000 ;

     private int bulkSize = 20 ;

     private int flushInterval = 10 ;

     private int concurrentRequests = 2 ;

     private String user;

     private String password;

private static final String TYPE = "type" ;

     private final String clusterNodes;

     private final String namespace;

     private final String user;

     private final String password;

     private RestHighLevelClient client;

     public ElasticSearchClient(String clusterNodes, String namespace, String user, String password) {

         this .clusterNodes = clusterNodes;

         this .namespace = namespace;

         this .user = user;

         this .password = password;

     }

     @Override

     public void connect() {

         ListpairsList = parseClusterNodes(clusterNodes);

         RestClientBuilder builder;

         if (StringUtils.isNotBlank(user) && StringUtils.isNotBlank(password)) {

             final CredentialsProvider credentialsProvider = new BasicCredentialsProvider();

             credentialsProvider.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials(user, password));

             builder = RestClient.builder(pairsList.toArray( new HttpHost[ 0 ]))

                     .setHttpClientConfigCallback( new RestClientBuilder.HttpClientConfigCallback() {

                         @Override

                         public HttpAsyncClientBuilder customizeHttpClient(

                                 HttpAsyncClientBuilder httpClientBuilder) {

                             return httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider);

                         }

                     });

         } else {

             builder = RestClient.builder(pairsList.toArray( new HttpHost[ 0 ]));

         }

         client = new RestHighLevelClient(builder);

     }

storage:

   elasticsearch:

     nameSpace: ${SW_NAMESPACE: "" }

     clusterNodes: ${SW_STORAGE_ES_CLUSTER_NODES:localhost:9200}

     user: ${SW_ES_USER: "" }

     password: ${SW_ES_PASSWORD: "" }

     indexShardsNumber: ${SW_STORAGE_ES_INDEX_SHARDS_NUMBER:2}

     indexReplicasNumber: ${SW_STORAGE_ES_INDEX_REPLICAS_NUMBER:0}

     # Batch process setting, refer to https://HdhCmsTestelastic.co/guide/en/elasticsearch/client/java-api/5.5/java-docs-bulk-processor.html

     bulkActions: ${SW_STORAGE_ES_BULK_ACTIONS:2000} # Execute the bulk every 2000 requests

     bulkSize: ${SW_STORAGE_ES_BULK_SIZE:20} # flush the bulk every 20mb

     flushInterval: ${SW_STORAGE_ES_FLUSH_INTERVAL:10} # flush the bulk every 10 seconds whatever the number of requests

     concurrentRequests: ${SW_STORAGE_ES_CONCURRENT_REQUESTS:2} # the number of concurrent requests