c/c++语言开发共享ElasticSearch配置需要权限认证的jest客户端

1.使用背景

es服务端配置了xpack权限认证，客户端连接使用需要进行权限认证，之前写过的jestClient是不带权限认证的，实际上加了权限认证以后只是需要将es的用户名和密码放到【默认凭证】方法里面，其他没有大改动，二话不说，上代码：

2.实际运用：

1. application.yml配置文件配置es相关属性：

elastic-search:   enabled: true   cluster-ips: 86.1.*.*,86.1.*.*   cluster-rest-port: 9200   username: zazz   password: ***** 

2. 将配置文件中的键值对属性映射到ElasticSearchJestConfig配置类:
   注意：xpack权限认证的，需要httpClientConfig设置默认凭证，defaultCredentials(username, password)

package com.wyk.studyhttp.es;  import io.searchbox.client.JestClient; import io.searchbox.client.JestClientFactory; import io.searchbox.client.config.HttpClientConfig; import io.searchbox.strings.StringUtils; import org.springframework.beans.factory.DisposableBean; import org.springframework.boot.autoconfigure.EnableAutoConfiguration; import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty; import org.springframework.boot.context.properties.ConfigurationProperties; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.PropertySource;  import java.util.ArrayList; import java.util.List;   /**  * es 工具类  使用时 注入 JestClient  */ @Configuration @EnableAutoConfiguration @ConfigurationProperties(prefix = "elastic-search") @ConditionalOnProperty(prefix = "elastic-search", value = "enabled", havingValue = "true", matchIfMissing = false) public class ElasticSearchJestConfig implements DisposableBean {      private String[] clusterIps;      private int clusterRestPort;      private String username;      private String password;      private String scheme = "https://";      private JestClient jestClient;      public ElasticSearchJestConfig() {     }      @Bean     public HttpClientConfig httpClientConfig() {         List<String> esIps = new ArrayList<String>();         HttpClientConfig httpClientConfig = null;         for (String ip : clusterIps) {             esIps.add(scheme + ip + ":" + clusterRestPort);         }         if (username != null && password != null) {             httpClientConfig = new HttpClientConfig.Builder(esIps)                     .defaultCredentials(username, password)//设置默认凭证（es的用户名和密码），否则es报权限异常                     .multiThreaded(true).build();             return httpClientConfig;         } else {             httpClientConfig = new HttpClientConfig.Builder(esIps).multiThreaded(true).build();             return httpClientConfig;         }     }      @Bean     public JestClient jestClient() {         JestClientFactory factory = new JestClientFactory();         factory.setHttpClientConfig(httpClientConfig());         return factory.getObject();     }      public String[] getClusterIps() {         return clusterIps;     }      public void setClusterIps(String[] clusterIps) {         this.clusterIps = clusterIps;     }      public int getClusterRestPort() {         return clusterRestPort;     }      public void setClusterRestPort(int clusterRestPort) {         this.clusterRestPort = clusterRestPort;     }      public String getUsername() {         return username;     }      public void setUsername(String username) {         this.username = username;     }      public String getPassword() {         return password;     }      public void setPassword(String password) {         this.password = password;     }      public String getScheme() {         return scheme;     }      public void setScheme(String scheme) {         this.scheme = scheme;     }      @Override     public void destroy() throws Exception {         if (jestClient != null) {             jestClient.shutdownClient();         }     }  } 

3. jestClient()方法返回一个JestClient对象，使用时注入JestClient即可。
   完毕！

c/c++开发分享ElasticSearch配置需要权限认证的jest客户端地址：https://blog.csdn.net/wyk_dao/article/details/109640143