public void testTransportClient() {
        Map<String, Object> params = new HashMap<>();
        String endtmStart = "2019-03-07 00:00";
        String endtmEnd = "2019-03-09 23:59";
        String removezonecode = "852RA";
        String[] array = new String[]{"a","b"};


        //查询条件
        BoolQueryBuilder boolQueryBuilder = QueryBuilders
                .boolQuery()
                //字段匹配
                .must(QueryBuilders.termQuery("removezonecode", removezonecode))
                //匹配多个值
                .must(QueryBuilders.termsQuery("removezonecode", array))
                // 范围
                .must(new RangeQueryBuilder("endtm").gte(endtmStart).lte(endtmEnd));
        boolQueryBuilder.must(new RangeQueryBuilder("endtm").gte(endtmStart).lte(endtmEnd));

        TransportClient client = TransportClientFactory.getInstance().getTransportClient();

        SearchSourceBuilder ssb = new SearchSourceBuilder();

        SearchResponse searchResponse = client
                .prepareSearch(esIndexName).setSearchType(SearchType.DEFAULT)
                .setSize(5).setQuery(boolQueryBuilder).execute()
                .actionGet();
//        System.out.println(searchResponse.getHits().totalHits);
        for (SearchHit searchHit : searchResponse.getHits()) {
            String jsonStr = searchHit.getSourceAsString();
            System.out.println(jsonStr);
        }
    }

Rest Client

public void testRestHighClient() {
    String endtmStart = "2019-03-07 00:00";
    String endtmEnd = "2019-03-09 23:59";
    String removezonecode = "852RA";
    String[] array = new String[]{"a","b"};

    //条件查找
    BoolQueryBuilder boolQueryBuilder = QueryBuilders
            .boolQuery()
            //字段匹配
            .must(QueryBuilders.termQuery("removezonecode", removezonecode))
            //匹配多个值
            .must(QueryBuilders.termsQuery("removezonecode", array))
            // 范围
            .must(new RangeQueryBuilder("endtm").gte(endtmStart).lte(endtmEnd));


    //聚合
    AggregationBuilder tb1 = AggregationBuilders.terms("src_dist_code_list").field("src_dist_code").size(10000);

    TermsAggregationBuilder tb2 = AggregationBuilders.terms("dest_area_code_list").field("dest_area_code").size(10000);
    TermsAggregationBuilder tb3 = AggregationBuilders.terms("src_city_code_list").field("src_city_code").size(10000);

    SumAggregationBuilder tbSum = AggregationBuilders.sum("meterage_weight_qty_sum").field("meterage_weight_qty");


    tb3.subAggregation(tbSum);
    tb2.subAggregation(tb3);
    tb1.subAggregation(tb2);




    SearchSourceBuilder ssb = new SearchSourceBuilder();
    ssb.query(boolQueryBuilder);
    ssb.aggregation(tb1);

    //查询请求
    SearchRequest sr = new SearchRequest();
    sr.indices(esIndexName);
    sr.source(ssb);
    

    System.out.println(sr.source());

    RestHighLevelClient client = RestHighLevelClientFactory.getInstance().getHighLevelClient();
    try {
        SearchResponse response = client.search(sr);
        System.out.println(response.getHits().getTotalHits());

        for (SearchHit searchHit : response.getHits().getHits()) {
            String jsonStr = searchHit.getSourceAsString();
            System.out.println(jsonStr);
        }

        RestHighLevelClientFactory.getInstance().close();

    } catch (IOException e) {
        e.printStackTrace();
    }
}