RestHighLevelClient getRHLClient(){
final CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
credentialsProvider.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials(username, passworld));
RestClientBuilder builder = RestClient.builder(new HttpHost(host, Integer.parseInt(port), protocol)).setRequestConfigCallback(new RestClientBuilder.RequestConfigCallback() {
@Override
public RequestConfig.Builder customizeRequestConfig(RequestConfig.Builder requestConfigBuilder) {
// requestConfigBuilder.setConnectTimeout(-1);
// requestConfigBuilder.setSocketTimeout(-1);
// requestConfigBuilder.setConnectionRequestTimeout(-1);
return requestConfigBuilder;
}
}).setHttpClientConfigCallback(new RestClientBuilder.HttpClientConfigCallback() {
@Override
public HttpAsyncClientBuilder customizeHttpClient(HttpAsyncClientBuilder httpClientBuilder) {
httpClientBuilder.disableAuthCaching();
return httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider);
}
});
RestHighLevelClient client = new RestHighLevelClient(builder);
return client;
// return new RestHighLevelClient(RestClient.builder(new HttpHost(host, Integer.parseInt(port), protocol)));
}简单记录下
乐享:知识积累,快乐无限。