ElasticSearch Java REST客户端创建

ゝ一纸荒年。 2021-11-04 10:10 464阅读 0赞

# ElasticSearch Java REST客户端创建 #

1.低级客户端创建

2.高级客户端创建

3.安全验证高级客户端创建（带用户名和密码）

4.Java REST高级客户端 maven配置

对人工智能感兴趣点下面链接

[现在人工智能非常火爆，很多朋友都想学，但是一般的教程都是为博硕生准备的，太难看懂了。最近发现了一个非常适合小白入门的教程，不仅通俗易懂而且还很风趣幽默。所以忍不住分享一下给大家。点这里可以跳转到教程。][Link 1]

[https://www.cbedai.net/u014646662][Link 1]

## 1.低级客户端创建 ##

/**
    	 * 获取低级客户端
    	 * 
    	 * @return
    	 */
    	private static RestClient getLowClient() {
    		RestClient client = RestClient.builder(new HttpHost("elk-node01", 9200, "http"),
    				new HttpHost("elk-node02", 9200, "http"), new HttpHost("elk-node03", 9200, "http")).build();
    		return client;
    	}

## 2.高级客户端创建 ##

/**
    	 * 获取客户端
    	 * 
    	 * @return
    	 */
    	private static RestHighLevelClient getClient() {
    		RestHighLevelClient client = new RestHighLevelClient(
    				RestClient.builder(new HttpHost("elk-node01", 9200, "http"), new HttpHost("elk-node02", 9200, "http"),
    						new HttpHost("elk-node03", 9200, "http")));
    		return client;
    	}

## 3.安全验证高级客户端创建（带用户名和密码） ##

最简获取

public static RestHighLevelClient createClient(String user,String passwd) throws Exception {
    
    		RestClientBuilder restClientBuilder = RestClient.builder(new HttpHost("192.168.68.101", 9200, "http"),new HttpHost("192.168.68.102", 9200, "http"),new HttpHost("192.168.68.103", 9200, "http"));
    		final CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
    		credentialsProvider.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials(user, passwd));
    		// 认证
    		restClientBuilder.setHttpClientConfigCallback(httpClientBuilder -> httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider));
    		RestHighLevelClient restHighLevelClient = new RestHighLevelClient(restClientBuilder);
    		return restHighLevelClient;
    	}

增加部分参数

public static RestHighLevelClient createClient1(String user,String passwd) throws Exception {
    
    		RestClientBuilder restClientBuilder = RestClient.builder(new HttpHost("192.168.68.102", 9200, "http"),
    				new HttpHost("192.168.68.103", 9200, "http"));
    
    		final CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
    		credentialsProvider.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials(user, passwd));
    
    		// 认证和线程数
    		restClientBuilder.setHttpClientConfigCallback(httpClientBuilder -> {
    			httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider);
    			int threadCount = 10;
    			httpClientBuilder.setDefaultIOReactorConfig(IOReactorConfig.custom().setIoThreadCount(threadCount).build());
    
    			return httpClientBuilder;
    		});
    
    		// 超时超时设置
    		restClientBuilder.setRequestConfigCallback(requestConfigCallback -> {
    			requestConfigCallback.setConnectTimeout(10);
    			requestConfigCallback.setSocketTimeout(10);
    			return requestConfigCallback;
    		});
    		RestHighLevelClient restHighLevelClient = new RestHighLevelClient(restClientBuilder);
    		return restHighLevelClient;
    	}

## 4.Java REST高级客户端 maven配置 ##

maven配置：[https://blog.csdn.net/u014646662/article/details/97895028][https_blog.csdn.net_u014646662_article_details_97895028]

[Link 1]: https://www.cbedai.net/u014646662
[https_blog.csdn.net_u014646662_article_details_97895028]: https://blog.csdn.net/u014646662/article/details/97895028