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))); }
简单记录下
乐享:知识积累,快乐无限。