@Bean
public RestHighLevelClient client() {
System.out.println("start client()--------------");
System.out.println("==========" + host);
System.out.println("=========" + port);
System.out.println("==========" + username);
System.out.println("=========" + password);
RestHighLevelClient esClient = null;
final BasicCredentialsProvider credentialsProvider = new BasicCredentialsProvider();
credentialsProvider.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials(username, password));
esClient = new RestHighLevelClient(RestClient.builder(
new HttpHost(host, Integer.parseInt(port)))
.setHttpClientConfigCallback(new RestClientBuilder.HttpClientConfigCallback() {
public HttpAsyncClientBuilder customizeHttpClient(
HttpAsyncClientBuilder httpClientBuilder) {
httpClientBuilder.disableAuthCaching();
return httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider);
}
})
);
return esClient;
}
本文使用 文章同步助手 同步
