RestClient查询文档

 //分页和排序
    @Test
    void restPageAndSort() throws IOException {
        //页码，每页大小
        int page = 2,size = 5;

        //1.准备Request
        SearchRequest request = new SearchRequest("hotel");
        //2.准备DSL
        //2.1 query
        request.source().query(QueryBuilders.matchAllQuery());
        //2.2 排序 sort
        request.source().sort("price", SortOrder.ASC);
        //2.3 分页from，size
        request.source().from((page - 1) * size).size(5);

        //3.发送请求
        SearchResponse response = client.search(request,RequestOptions.DEFAULT);

        handleResponce(response);

        System.out.println(response);
    }

    private void handleResponce(SearchResponse response) {
        //4.解析响应
        SearchHits searchHits = response.getHits();
        //4.1获取总条数
        long total = searchHits.getTotalHits().value;
        System.out.println("共搜索到"+total+"条数据");
        //4.2文档数据
        SearchHit[] hits = searchHits.getHits();
        //4.3遍历
        for(SearchHit hit : hits){
            //获取文档source
            String json = hit.getSourceAsString();
            //反序列化
            HotelDoc hotelDoc = JSON.parseObject(json,HotelDoc.class);
            System.out.println("hotelDoc = "+hotelDoc);
        }
    }

//高亮
    @Test
    void testHighlight() throws IOException {
        //1.准备Request
        SearchRequest request = new SearchRequest("hotel");
        //2.准备DSL
        //2.1 query
        request.source().query(QueryBuilders.matchQuery("all","如家"));
        //2.2 高亮
        request.source().highlighter(new HighlightBuilder().field("name").requireFieldMatch(false));

        //3.发送请求
        SearchResponse response = client.search(request,RequestOptions.DEFAULT);

        handleResponce1(response);

        System.out.println(response);
    }

    private void handleResponce1(SearchResponse response) {
        //4.解析响应
        SearchHits searchHits = response.getHits();
        //4.1获取总条数
        long total = searchHits.getTotalHits().value;
        System.out.println("共搜索到"+total+"条数据");
        //4.2文档数组
        SearchHit[] hits = searchHits.getHits();
        //4.3遍历
        for(SearchHit hit : hits){
            //获取文档source
            String json = hit.getSourceAsString();
            //反序列化
            HotelDoc hotelDoc = JSON.parseObject(json,HotelDoc.class);

            //获取高亮结果
            Map highlightFields = hit.getHighlightFields();
            if(!CollectionUtils.isEmpty(highlightFields)){
                //根据各字段名获取高亮结果
                HighlightField highlightField = highlightFields.get("name");
                if(highlightField != null){
                    //获取高亮
                    String name = highlightField.getFragments()[0].string();
                    //覆盖非高亮结果
                    hotelDoc.setName(name);
                }
            }

            System.out.println("hotelDoc = "+hotelDoc);
        }
    }