Elasticsearch Java REST高级客户端 MultiSearch Api-蒲公英云

Elasticsearch Java REST高级客户端 MultiSearch Api

版本：Elasticsearch 7.2.0

maven配置见：Elasticsearch Java REST高级客户端-DocumentApi

对人工智能感兴趣的同学，可以点击以下链接：

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

https://www.cbedai.net/u014646662

使用 MultiSearch Api 在一个http请求中并行执行多个Search请求。

public static void multiSearch() {
        var client = getClient();
        MultiSearchRequest msRequest = new MultiSearchRequest();
        SearchRequest request1 = new SearchRequest("movies");
        SearchSourceBuilder builder1 = new SearchSourceBuilder();
        builder1.query(QueryBuilders.matchQuery("title", "you"));
        request1.source(builder1);
        msRequest.add(request1);
        SearchRequest request2 = new SearchRequest("movies");
        SearchSourceBuilder builder2 = new SearchSourceBuilder();
        builder2.query(QueryBuilders.matchQuery("title", "life"));
        request2.source(builder2);
        msRequest.add(request2);
        try {
            MultiSearchResponse responses = client.msearch(msRequest, RequestOptions.DEFAULT);
            Arrays.asList(responses.getResponses()).stream()
            .map(item -> item.getResponse())
            .map(response -> response.getHits())
            .filter(hit -> hit != null)
            .forEach(hit -> hit.forEach(System.out::println));
        } catch (IOException e) {
            e.printStackTrace();
        }finally {
            close(client);
        }
    }
    /**
     * 关闭客户端
     * 
     * @param client
     */
    private static void close(RestHighLevelClient client) {
        try {
            client.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    /**
     * 获取客户端
     * 
     * @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;
    }