RestHighLevelClient：详解Elasticsearch的Java客户端

发布时间：2023-05-18

一、RestHighlevelClient批量写入

批量写入是一种高效的方式，可以提高写入速度，同时减少网络开销。使用RestHighLevelClient进行批量写入非常容易。下面是一个简单的例子，展示如何使用RestHighLevelClient进行批量写入操作。

BulkRequest bulkRequest = new BulkRequest(); 
// 添加多个写入请求
IndexRequest request1 = new IndexRequest(index, type, "1")
        .source(XContentType.JSON,"title", "Java高级编程", "author", "张三", "createDate",new Date());
bulkRequest.add(request1);    
IndexRequest request2 = new IndexRequest(index, type, "2")
        .source(XContentType.JSON,"title", "Spring Boot开发实战", "author", "李四", "createDate", new Date());
bulkRequest.add(request2);
BulkResponse bulkResponse = client.bulk(bulkRequest, RequestOptions.DEFAULT);

上面的代码创建了一个BulkRequest对象，然后添加两个IndexRequest对象到该请求中，最后使用RestHighLevelClient的bulk方法提交批量写入请求。

二、RestHighlevelClient ES 集群

与Elasticsearch集群通信需要使用RestHighLevelClient。RestHighLevelClient可以轻松的与ES集群建立通信并执行各种操作。下面的示例展示了如何使用RestHighLevelClient进行与ES集群的通信。

RestHighLevelClient client = new RestHighLevelClient(
    RestClient.builder(
            new HttpHost("192.168.1.100", 9200, "http"),
            new HttpHost("192.168.1.101", 9200, "http"),
            new HttpHost("192.168.1.102", 9200, "http")));

上面的代码创建了一个RestHighLevelClient对象并传入多个HttpHost对象。HttpHost类表示Elasticsearch主机的参数，例如：主机名、端口和方案。

三、RestHighlevelClient 5.3.4

RestHighLevelClient还支持与旧版本的Elasticsearch进行通信。下面是如何使用RestHighLevelClient 5.3.4与Elasticsearch进行通信的简单示例。

RestHighLevelClient client = new RestHighLevelClient(
    RestClient.builder(
            new HttpHost("localhost", 9200, "http")).setHttpClientConfigCallback(new HttpClientConfigCallback() {
                @Override
                public HttpAsyncClientBuilder customizeHttpClient(
                        HttpAsyncClientBuilder httpClientBuilder) {
                    return httpClientBuilder.setDefaultCredentialsProvider(
                            new BasicCredentialsProvider() {{
                                this.setCredentials(AuthScope.ANY,
                                        new UsernamePasswordCredentials("username", "password"));
                            }});
                }
            }));

上面的代码创建了一个RestHighLevelClient对象并使用RestClient.builder方法设置了连接的主机和端口。同时也设置了HTTP客户端SSL和ES节点的认证，以便与ES中具有访问权限的用户进行交互。

四、RestHighlevelclient 高级查询

RestHighLevelClient支持非常复杂的高级查询操作。下面是一个简单示例，演示如何使用RestHighLevelClient进行高级查询操作。

SearchRequest searchRequest = new SearchRequest(index);
SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder(); 
MatchQueryBuilder matchQueryBuilder = new MatchQueryBuilder("title", "Java高级编程"); 
searchSourceBuilder.query(matchQueryBuilder);   
searchRequest.source(searchSourceBuilder); 
SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);

上面的代码中，创建了一个SearchRequest对象和一个SearchSourceBuilder对象。然后我们使用MatchQueryBuilder设置查询请求，最后使用RestHighLevelClient的search方法执行查询操作。

五、RestHighlevelClient 分页查询

RestHighLevelClient可以执行分页查询，我们可以使用SearchSourceBuilder设置请求的起始位置和大小。下面是一个简单的示例，演示如何使用RestHighLevelClient进行分页查询操作。

SearchRequest searchRequest = new SearchRequest(index);
SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder(); 
searchSourceBuilder.from(0); 
searchSourceBuilder.size(20); 
searchRequest.source(searchSourceBuilder); 
SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);

上面的代码中，我们创建了一个SearchRequest对象和一个SearchSourceBuilder对象。然后我们使用from方法设置用户想要的开始位置。使用size方法设置用户想要的返回结果的数量。最后使用RestHighLevelClient的search方法执行查询操作。

六、RestHighlevelClient 重建索引

RestHighLevelClient可以执行重建索引操作。如果需要进行索引的重新构建，则可以使用reindex()方法创建ReindexRequest，并获取可移植的RestHighLevelClient SDK对象。

ReindexRequest request = new ReindexRequest(); 
request.setSourceIndices("source_index"); 
request.setDestIndex("dest_index"); 
BulkByScrollResponse response = client.reindex(request, RequestOptions.DEFAULT);

上面的代码中，我们首先创建了一个ReindexRequest对象。然后我们将source_index中所有的数据重建到dest_index，最后使用RestHighLevelClient的reindex方法执行重建操作。

七、RestHighlevelClient分页工具类

RestHighLevelClient提供了一个非常方便的分页工具类，可以让开发人员以非常简单的方式执行分页操作。下面是一个展示如何使用RestHighLevelClient分页工具类的简单示例代码。

SearchRequest searchRequest = new SearchRequest(index);
SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder(); 
searchSourceBuilder.query(QueryBuilders.matchQuery("title", "Java高级编程")); 
searchSourceBuilder.from(0);  
searchSourceBuilder.size(20); 
SearchResponse searchResponse = PaginatedSearchUtil.search(client, searchRequest, searchSourceBuilder);

上面的代码中，我们首先执行一个简单的查询操作并将请求和SearchSourceBuilder传递给PaginatedSearchUtil.search方法，该方法将返回一个SearchResponse对象。

八、RestHighlevelClient高并发

RestHighLevelClient可以快速响应高并发请求。当多个后台线程并发发送请求时，RestHighLevelClient可以保证线程安全，并且不会阻塞主线程。下面是一个演示如何使用RestHighLevelClient实现高并发操作的示例代码。

ExecutorService executorService = Executors.newFixedThreadPool(50);
for (int i = 0; i < 1000; i++) {
    final String index = "example-index";
    final String type = "_doc";
    executorService.execute(new Runnable() {
        @Override
        public void run() {
            try {
                IndexRequest indexRequest = new IndexRequest(index, type, UUID.randomUUID().toString())
                        .source(XContentType.JSON,"title", "Java高级编程", "author", "张三", "createDate",new Date());
                client.index(indexRequest, RequestOptions.DEFAULT);
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    });
}

上面的代码中，我们首先创建了一个包含50个线程的线程池，然后循环了1000次，每次将一个IndexRequest对象添加到线程池中，并使用RestHighLevelClient的index方法执行写入操作。

九、RestHighlevelClientHolder

RestHighLevelClientHolder类用于持有一个RestHighLevelClient对象，以避免频繁地创建和销毁对象。这样不仅可以节省内存，还可以减少连接ES所需的时间。

public class RestHighLevelClientHolder { 
    private static volatile RestHighLevelClient client = null;
    public static RestHighLevelClient getClient() {
        if (client == null) {
            synchronized (RestHighLevelClientHolder.class) {
                if (client == null) {
                    client = new RestHighLevelClient(
                        RestClient.builder(
                                new HttpHost("localhost", 9200, "http")));
                }
            }
        }
        return client;
    }
}

上面的代码中，RestHighLevelClientHolder类仅具有一个getClient方法，该方法用于返回一个已创建的RestHighLevelClient对象。如果对象尚未创建，则使用双重检查锁定机制创建新对象。

十、结语

本文我们对RestHighLevelClient的各种用法进行了详细的说明，实现了从批量写入、ES集群通信、5.3.4版本兼容、高级查询、分页查询、重建索引、分页工具类、高并发和单例模式等方面的展示。相信你在实际的工作中也会发现RestHighLevelClient在使用Elasticsearch时非常实用。在使用过程中，我们也需要根据实际需求进行调整，以获得最佳的使用效果。

推荐文章