• RestHighLevelClient 操作ElasticSearch

    1、jar包

    2.     org.elasticsearch
    3.     elasticsearch
    4.     7.8
    6.  
    8.     org.elasticsearch.client
    9.     elasticsearch-rest-high-level-client
    10.     7.8

    2、kerberos认证

    1. public void kerberos() {
    2.     try {
    3.         System.setProperty("http.auth.preference", "Kerberos");
    4.         System.setProperty("java.security.krb5.conf", KRB5CONF);
    5.         System.setProperty("sun.security.krb5.debug", "false");
    6.         System.setProperty("sun.security.spnego.debug", "false");
    7.         String acceptorPrincipal = PRINCIPAL;
    8.  
    9.         Path acceptorKeyTabPath = Paths.get(KEYTAB);
    10.         Set set = new HashSet<>();
    11.         set.add(acceptorPrincipal);
    12.         final Subject subject = JaasKrbUtil.loginUsingKeytab(set, acceptorKeyTabPath, true); // 工具类未提供，需要单联
    13.         Set privateCredentials = subject.getPrivateCredentials();
    14.  
    15.         log.info("getPrivateCredentials ------------------- ");
    16.         privateCredentials.forEach(System.out::println);
    17.     } catch (Exception e) {
    18.         e.printStackTrace();
    19.     }
    20. }
      21.  

      1. public void kerberosRest(String index) {
      2.     RestHighLevelClient restHighLevelClient = null;
      3.     String indexName = "cool_test_one";
      4.     String typeName = "cool_test_one_table";
      5.     try {
      6.         log.info("kerberos 访问 start =======================");
      7.         log.info("开始认证");
      8.         SpnegoHttpClientConfigCallbackHandler callbackHandler = new SpnegoHttpClientConfigCallbackHandler(PRINCIPAL, KEYTAB, true); // 工具类未提供，需要单联
      9.         log.info("认证成功 ===================================");
      10.  
      11.         // 业务逻辑开始
      12.         List hosts = new ArrayList<>();
      13.         HttpHost hostNew = new HttpHost("localhost", 9200, "http");
      14.         hosts.add(hostNew);
      15.         HttpHost[] httpHosts = hosts.toArray(new HttpHost[0]);
      16.  
      17.         RestClientBuilder restClientBuilder = RestClient.builder(httpHosts);
      18.  
      19.         /** options start **/
      20.  
      21.         
      22.         // 异步连接延时配置 https://www.elastic.co/guide/en/elasticsearch/client/java-rest/7.12/_timeouts.html
      23.         // RequestConfig有三个超时如下
      24.         int connectTimeout = 5000; // 设置连接超时时间，单位毫秒。指的是连接一个url的连接等待时间
      25.         int socketTimeout = 5000; // 请求获取数据的超时时间，单位毫秒。 如果访问一个接口，多少时间内无法返回数据，就直接放弃此次调用。指的是连接上一个url，获取response的返回等待时间。
      26.         int connectionRequestTimeout = 5000; // 设置从connect Manager获取Connection 超时时间，单位毫秒。这个属性是新加的属性，因为目前版本是可以共享连接池的。
      27.         //配置请求超时超时，分为 连接超时(默认1s) 和 套接字超时(默认30s)
      28.         restClientBuilder.setRequestConfigCallback(requestConfigBuilder -> {
      29.             requestConfigBuilder.setConnectTimeout(connectTimeout);//配置连接超时时间
      30.             requestConfigBuilder.setSocketTimeout(socketTimeout);//配置套接字超时时间
      31.             requestConfigBuilder.setConnectionRequestTimeout(connectionRequestTimeout);//获取连接的超时时间
      32.             return requestConfigBuilder;
      33.         });
      34.  
      35.         // 异步连接数配置
      36.         int maxConnectNum = 100; // 最大连接数
      37.         int maxConnectPerRoute = 100; // 最大路由连接数
      38.         restClientBuilder.setHttpClientConfigCallback(httpClientBuilder -> {
      39.             httpClientBuilder.setMaxConnTotal(maxConnectNum);
      40.             httpClientBuilder.setMaxConnPerRoute(maxConnectPerRoute);
      41.             return httpClientBuilder;
      42.         });
      43.  
      44.         /** options end **/
      45.  
      46.         restHighLevelClient = new RestHighLevelClient(restClientBuilder);
      47.  
      48.         log.info("operation start =========================================");
      49.  
      50.         singleIndex(restHighLevelClient, indexName, typeName); // 单条文档写入
      51.         bulkIndex(restHighLevelClient, indexName, typeName); // 批量文档写入
      52.  
      53.         singleUpdate(restHighLevelClient, indexName, typeName); // 单条文档更新
      54.         bulkUpdate(restHighLevelClient, indexName, typeName); // 批量文档更新
      55.  
      56.         singleUpsert(restHighLevelClient, indexName, typeName); // 单条文档upsert
      57.         bulkUpsert(restHighLevelClient, indexName, typeName); // 批量文档upsert
      58.  
      59.         bulkUpdateNoDocId(restHighLevelClient, indexName, typeName);
      60.         bulkUpsertNoDocId(restHighLevelClient, indexName, typeName);
      61.  
      62.         singleDelete(restHighLevelClient, indexName, typeName);
      63.         log.info("operation end ===========================================");
      64.  
      65.         // 测试获取所有的索引
      66.         log.info("获取" + indexName + " 索引数据");
      67.         getIndex(restHighLevelClient, indexName);
      68.         log.info("kerberos 访问 end");
      69.  
      70.     } catch (Exception e) {
      71.         e.printStackTrace();
      72.     } finally {
      73.         if (restHighLevelClient != null) {
      74.             try {
      75.                 restHighLevelClient.close();
      76.             } catch (IOException e) {
      77.                 e.printStackTrace();
      78.             }
      79.         }
      80.     }
      81. }
       

      3、写入操作
       

      1）根据_id单条文档写入
       

      单条文档写入需要创建IndexRequest对象，设置索引名称，类型名称，id名称，以及使用source传入文档字段的Map对象，在执行写入时使用客户端的index方法把IndexRequest传入即可
       

      1. public String singleIndex(RestHighLevelClient restHighLevelClient, String indexName, String typeName) throws IOException {
      2.     XContentBuilder builder = XContentFactory.jsonBuilder();
      3.     builder.startObject();
      4.     builder.field("a1", "bb");
      5.     builder.field("a2", 100);
      6.     builder.field("a3", 10.12);
      7.     builder.field("a4", "2055-05-05");
      8.     builder.field("a5", "20:55:55");
      9.     builder.field("a6", "2055-05-05");
      10.     builder.endObject();
      11.  
      12.     String docIdStr = Md5Util.encode("bb");
      13.     log.info("doc_id ===>" + docIdStr);
      14.  
      15.     IndexRequest request = new IndexRequest(indexName, typeName, docIdStr).source(builder);
      16.     IndexResponse response = null;
      17.  
      18.     try {
      19.         // 不使用默认的RequestOptions.DEFAULT，而通过使用自定义RequestOptions的方式（ES官方api已经给我们开放出来了）：
      20.         RequestOptions.Builder buildersize = RequestOptions.DEFAULT.toBuilder();
      21.         buildersize.setHttpAsyncResponseConsumerFactory(
      22.                 new HttpAsyncResponseConsumerFactory
      23.                         //修改为500MB
      24.                         .HeapBufferedResponseConsumerFactory(500 * 1024 * 1024));
      25.         //             response = restHighLevelClient.index(request, RequestOptions.DEAFULT);
      26.  
      27.  
      28.         response = restHighLevelClient.index(request, buildersize.build());
      29.     } catch (IOException e) {
      30.         e.printStackTrace();
      31.     }
      32.     return response.getId();
      33. }
       

      2）批量写入文档
       

      批量写入需要创建BulkRequest，多条数据每条创建一个IndexRequest对象设置index，type，id和数据Map，将这些IndexRequest对象条件到BulkRequest中，调用客户端的bulk方法执行即可
       

      1. public static void bulkIndex(RestHighLevelClient restHighLevelClient, String indexName, String typeName) throws IOException {
      2.     BulkRequest bulkRequest = new BulkRequest();
      3.  
      4.     Map data = new HashMap<>();
      5.     Object colData = "kugou";
      6.     data.put("a1", String.valueOf(colData));
      7.     data.put("a2", 100);
      8.     data.put("a3", 10.12);
      9.     data.put("a4", "2055-05-05");
      10.     data.put("a5", "20:55:55");
      11.     data.put("a6", "2055-05-05");
      12.  
      13.     for (int i = 0; i < 2; i++) {
      14.         String docIdStr = Md5Util.encode("bb" + i);
      15.         log.info("doc_id =>" + docIdStr);
      16.  
      17.         // 有doc_id
      18.         IndexRequest indexRequest = new IndexRequest(indexName, typeName, docIdStr).source(data);
      19.         // 无doc_id
      20. //            IndexRequest indexRequest1 = new IndexRequest(indexName, typeName, docIdStr).source(data);
      21.  
      22.         bulkRequest.add(indexRequest);
      23.     }
      24.  
      25.     BulkResponse response = restHighLevelClient.bulk(bulkRequest, RequestOptions.DEFAULT);
      26.     log.info("bulk write result is " + !response.hasFailures());
      27. }
       

       3）更新单条文档
       

      更新单条文档需要创建UpdateRequest对象，设置index，type，id和文档字段数据，调用客户端的update方法执行即可
       

      1. public static void singleUpdate(RestHighLevelClient restHighLevelClient, String indexName, String typeName) throws IOException {
      2.  
      3.         Map data = new HashMap<>();
      4.         Object colData = "kugou";
      5.         data.put("a1", String.valueOf(colData));
      6.         data.put("a2", 100);
      7.         data.put("a3", 10.12);
      8.         data.put("a4", "2055-05-05");
      9.         data.put("a5", "20:55:55");
      10.         data.put("a6", "2055-05-05");
      11.  
      12.         String docIdStr = Md5Util.encode("kugou");
      13.  
      14.         UpdateRequest updateRequest = new UpdateRequest(indexName, typeName, docIdStr);
      15.         UpdateResponse updateResponse = restHighLevelClient.update(updateRequest, RequestOptions.DEFAULT);
      16.  
      17.         DocWriteResponse.Result result = updateResponse.getResult();
      18. }
       

      4）批量文档更新
       

      1. public static void bulkUpdate(RestHighLevelClient restHighLevelClient, String indexName, String typeName) throws IOException {
      2.     BulkRequest bulkRequest = new BulkRequest();
      3.  
      4.     Map data = new HashMap<>();
      5.     Object colData = "test";
      6.     data.put("a1", String.valueOf(colData));
      7.     data.put("a2", 100);
      8.     data.put("a3", 10.12);
      9.     data.put("a4", "2055-05-05");
      10.     data.put("a5", "20:55:55");
      11.     data.put("a6", "2055-05-05");
      12.  
      13.     for (int i = 0; i < 2; i++) {
      14.         String docIdStr = Md5Util.encode("bb" + i);
      15.         log.info("doc_id =>" + docIdStr);
      16.  
      17.         UpdateRequest updateRequest = new UpdateRequest(indexName, typeName, docIdStr);
      18.         updateRequest.doc(data);
      19.         bulkRequest.add(updateRequest);
      20.     }
      21.  
      22.     BulkResponse response = restHighLevelClient.bulk(bulkRequest, RequestOptions.DEFAULT);
      23.     log.info("bulk write result is " + !response.hasFailures());
      24. }
       

      5）upsert方式
       

      对于有则更新无则插入的情况，UpdateRequest在设置doc之后再设置以下upsert即可，其他一样
       

      1. public static void singleUpsert(RestHighLevelClient restHighLevelClient, String indexName, String typeName) throws IOException {
      2.     // 对于有则更新无则插入的情况，UpdateRequest在设置doc之后再设置以下upsert即可，其他一样
      3.     Map data = new HashMap<>();
      4.     Object colData = "kugou";
      5.     data.put("a1", String.valueOf(colData));
      6.     data.put("a2", 100);
      7.     data.put("a3", 10.12);
      8.     data.put("a4", "2055-05-05");
      9.     data.put("a5", "20:55:55");
      10.     data.put("a6", "2055-05-05");
      11.  
      12.     /**
      13.      * 测试过程中，如果es定义的字段数为6个；先index的时候，字段数为5个；upsert的时候，字段数6个，结果是success
      14.      */
      15.  
      16.     String docIdStr = Md5Util.encode("kugou");
      17.  
      18.     UpdateRequest updateRequest = new UpdateRequest(indexName, typeName, docIdStr);
      19.     updateRequest.doc(data).upsert(data);
      20.     UpdateResponse updateResponse = restHighLevelClient.update(updateRequest, RequestOptions.DEFAULT);
      21. }
      22.  
      23. public static void bulkUpsert(RestHighLevelClient restHighLevelClient, String indexName, String typeName) throws IOException {
      24.     BulkRequest bulkRequest = new BulkRequest();
      25.  
      26.     Map data = new HashMap<>();
      27.     Object colData = "test";
      28.     data.put("a1", String.valueOf(colData));
      29.     data.put("a2", 100);
      30.     data.put("a3", 10.12);
      31.     data.put("a4", "2055-05-05");
      32.     data.put("a5", "20:55:55");
      33.     data.put("a6", "2055-05-05");
      34.  
      35.     for (int i = 0; i < 2; i++) {
      36.         String docIdStr = Md5Util.encode("bb" + i);
      37.         log.info("doc_id =>" + docIdStr);
      38.  
      39.         UpdateRequest updateRequest = new UpdateRequest(indexName, typeName, docIdStr);
      40.         updateRequest.doc(data).upsert(data); // 对于有则更新无则插入的情况，UpdateRequest在设置doc之后再设置以下upsert即可，其他一样
      41.         bulkRequest.add(updateRequest);
      42.     }
      43.  
      44.     BulkResponse response = restHighLevelClient.bulk(bulkRequest, RequestOptions.DEFAULT);
      45.     log.info("bulk write result is " + !response.hasFailures());
      46. }
       

      6）多种操作类型混合操作
       

      1. public static void bulkMixOperation(RestHighLevelClient restHighLevelClient, String indexName, String typeName) throws IOException {
      2.     Map data = new HashMap<>();
      3.     Object colData = "index_id";
      4.     data.put("a1", String.valueOf(colData));
      5.     data.put("a2", 100);
      6.     data.put("a3", 10.12);
      7.     data.put("a4", "2055-05-05");
      8.     data.put("a5", "20:55:55");
      9.     data.put("a6", "2055-05-05");
      10.     String index_doc_id = Md5Util.encode(String.valueOf(colData));
      11.  
      12.     Map data1 = new HashMap<>();
      13.     Object colData1 = "upsert_id";
      14.     data1.put("a1", String.valueOf(colData1));
      15.     data1.put("a2", 100);
      16.     data1.put("a3", 10.12);
      17.     data1.put("a4", "2055-05-05");
      18.     data1.put("a5", "20:55:55");
      19.     data1.put("a6", "2055-05-05");
      20.     String upsert_doc_id = Md5Util.encode(String.valueOf(colData1));
      21.  
      22.     Map data2 = new HashMap<>();
      23.     Object colData2 = "update_id";
      24.     data2.put("a1", String.valueOf(colData1));
      25.     data2.put("a2", 100);
      26.     data2.put("a3", 10.12);
      27.     data2.put("a4", "2055-05-05");
      28.     data2.put("a5", "20:55:55");
      29.     data2.put("a6", "2055-05-05");
      30.     String update_doc_id = Md5Util.encode(String.valueOf(colData2));
      31.  
      32.     BulkRequest bulkRequest = new BulkRequest();
      33.     IndexRequest indexRequest = new IndexRequest(indexName, typeName, index_doc_id).source(data);
      34.     UpdateRequest updateRequest = new UpdateRequest(indexName, typeName, upsert_doc_id).doc(data1).upsert(data1);
      35.     UpdateRequest updateRequest1 = new UpdateRequest(indexName, typeName, update_doc_id).doc(data2);
      36.  
      37.     bulkRequest.add(indexRequest);
      38.     bulkRequest.add(updateRequest);
      39.     bulkRequest.add(updateRequest1);
      40.  
      41.     BulkResponse result = restHighLevelClient.bulk(bulkRequest, RequestOptions.DEFAULT);
      42.  
      43.     log.info("mix bulk result is " + !result.hasFailures());
      44.  
      45. }
       

      7）listMap构造数据插入ES
       

      1. public static void ListMapIndex(RestHighLevelClient restHighLevelClient, String indexName, String typeName) throws IOException {
      2.         List> list = new ArrayList<>();
      3.         list.add(new HashMap() {{
      4.             put("id", "003");
      5.             put("name", "c宾馆");
      6.             put("city", "苏州");
      7.             put("price", 7.54);
      8.         }});
      9.         list.add(new HashMap() {{
      10.             put("id", "004");
      11.             put("name", "d宾馆");
      12.             put("city", "杭州");
      13.             put("price", 17.34);
      14.         }});
      15.         list.add(new HashMap() {{
      16.             put("id", "005");
      17.             put("name", "e宾馆");
      18.             put("city", "上海");
      19.             put("price", 21.92);
      20.         }});
      21.  
      22.         BulkRequest bulkRequest = new BulkRequest();
      23.         list.forEach(s -> bulkRequest.add(new IndexRequest().index(indexName).type(typeName).id(s.get("id").toString()).source(s)));
      24.         bulkRequest.timeout(TimeValue.timeValueSeconds(5));
      25.         BulkResponse bulkResponse = restHighLevelClient.bulk(bulkRequest, RequestOptions.DEFAULT);
      26.  
      27.         log.info("result is " + !bulkResponse.hasFailures());
      28.         restHighLevelClient.close();
      29.     }
       

      8）根据条件批量更新文档
       

      创建UpdateByQueryRequest对象，分别设置setQuery和setScript，分别代表条件和更新语句，最后客户端调用updateByQuery更新
       

      1. public static void updateByQuery(RestHighLevelClient restHighLevelClient, String indexName, String typeName) throws IOException {
      2.         UpdateByQueryRequest updateByQueryRequest = new UpdateByQueryRequest(indexName, typeName);
      3.         updateByQueryRequest.setQuery(new TermQueryBuilder("city", "上海"));
      4.         updateByQueryRequest.setScript(new Script("ctx._source['city']='杭州'"));
      5.         restHighLevelClient.updateByQuery(updateByQueryRequest, RequestOptions.DEFAULT);
      6.         restHighLevelClient.close();
      7.     }
       

      9）删除单条文档
       

      删除单条文档使用DeleteRequest对象，传入index，type，doc_id，客户端调用delete方法即可
       

      1. public static void singleDelete(RestHighLevelClient restHighLevelClient, String indexName, String typeName) {
      2.         DeleteByQueryRequest deleteByQueryRequest = new DeleteByQueryRequest();
      3.         deleteByQueryRequest.indices(indexName);
      4.         deleteByQueryRequest.setQuery(new MatchQueryBuilder("a1", "hello"));
      5.         try {
      6.             restHighLevelClient.deleteByQuery(deleteByQueryRequest, RequestOptions.DEFAULT);
      7.         } catch (IOException e) {
      8.             e.printStackTrace();
      9.         }
      10.     }
       

      10）批量删除文档
       

      批量删除使用BulkRequest对象，将DeleteRequest传入BulkRequest中，最后调用客户端的bulk提交即可
       

      1. public static void bulkDelete(RestHighLevelClient restHighLevelClient, String indexName, String typeName) throws IOException {
      2.         BulkRequest bulkRequest = new BulkRequest();
      3.         bulkRequest.add(new DeleteRequest("hotel", "_doc", "004"));
      4.         bulkRequest.add(new DeleteRequest("hotel", "_doc", "003"));
      5.         restHighLevelClient.bulk(bulkRequest, RequestOptions.DEFAULT);
      6.  
      7.         restHighLevelClient.close();
      8.     }
       

      11）根据条件删除文档
       

      使用deleteByQueryRequest对象，设置setQuery参数为条件，客户端调用deleteByQuery即可
       

      1.     public static void deleteByQuery(RestHighLevelClient restHighLevelClient, String indexName, String typeName) throws IOException {
      2.         DeleteByQueryRequest deleteByQueryRequest = new DeleteByQueryRequest(indexName);
      3.         deleteByQueryRequest.setQuery(new BoolQueryBuilder().mustNot(new TermQueryBuilder("city", "上海")));
      4.         restHighLevelClient.deleteByQuery(deleteByQueryRequest, RequestOptions.DEFAULT);
      5.  
      6.         restHighLevelClient.close();
      7.     }
       

      12）搜索文档操作
       

      1. /**
      2.      *
      3.      * @param restHighLevelClient
      4.      * @param indexName
      5.      * @param typeName
      6.      * @throws IOException
      7.      */
      8.     public static void searchIndex(RestHighLevelClient restHighLevelClient, String indexName, String typeName) throws IOException {
      9.         SearchRequest searchRequest = new SearchRequest(indexName, typeName);
      10.         SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
      11.         sourceBuilder.query(QueryBuilders.matchQuery("city", "上海"));
      12.         searchRequest.source(sourceBuilder);
      13.         SearchResponse searchResponse = restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT);
      14.         RestStatus restStatus = searchResponse.status();
      15.         System.out.println(restStatus);
      16.         if (restStatus == RestStatus.OK) {
      17.             SearchHits searchHits = searchResponse.getHits();
      18.             for (SearchHit searchHit : searchHits) {
      19.                 System.out.println("id:" + searchHit.getId());
      20.                 System.out.println("index:" + searchHit.getIndex());
      21.                 System.out.println("score:" + searchHit.getScore());
      22.                 Map map = searchHit.getSourceAsMap();
      23.                 System.out.println("name:" + (String) map.get("name"));
      24.                 System.out.println("city:" + (String) map.get("city"));
      25.                 System.out.println("price:" + (Double) map.get("price"));
      26.             }
      27.         }
      28.         restHighLevelClient.close();
      29.     }
      30.  
      31.     /**
      32.      * term精确搜索
      33.      *
      34.      * @param restHighLevelClient
      35.      * @param indexName
      36.      * @param typeName
      37.      * @throws IOException
      38.      */
      39.     public static void termSearch(RestHighLevelClient restHighLevelClient, String indexName, String typeName) throws IOException {
      40.         SearchRequest searchRequest = new SearchRequest(indexName, typeName);
      41.         SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder().query(QueryBuilders.termQuery("_id", "007"));
      42.         searchRequest.source(searchSourceBuilder);
      43.  
      44.         SearchResponse searchResponse = restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT);
      45.         if (searchResponse.status() == RestStatus.OK) {
      46.             SearchHits searchHits = searchResponse.getHits();
      47.             Object city = searchHits.getAt(0).getSourceAsMap().get("city");
      48.             System.out.println(String.valueOf(city));
      49.         }
      50.  
      51.         restHighLevelClient.close();
      52.     }
      53.  
      54.     /**
      55.      * range范围搜索
      56.      *
      57.      * @param restHighLevelClient
      58.      * @param indexName
      59.      * @param typeName
      60.      * @throws IOException
      61.      */
      62.     public static void rangeSearch(RestHighLevelClient restHighLevelClient, String indexName, String typeName) throws IOException {
      63.         SearchRequest searchRequest = new SearchRequest(indexName, typeName);
      64.         SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder().query(QueryBuilders.rangeQuery("price").gte(10.0).lte(100.0));
      65.         searchRequest.source(searchSourceBuilder);
      66.         SearchResponse searchResponse = restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT);
      67.         if (searchResponse.status() == RestStatus.OK) {
      68.             SearchHits searchHits = searchResponse.getHits();
      69.             for (SearchHit searchHit : searchHits) {
      70.                 System.out.println(searchHit.getSourceAsMap());
      71.             }
      72.         }
      73.  
      74.         restHighLevelClient.close();
      75.     }
      76.  
      77.     /**
      78.      * 分页查询
      79.      *
      80.      * @param restHighLevelClient
      81.      * @param indexName
      82.      * @param typeName
      83.      * @throws IOException
      84.      */
      85.     public static void pageSearch(RestHighLevelClient restHighLevelClient, String indexName, String typeName) throws IOException {
      86.         SearchRequest searchRequest = new SearchRequest(indexName, typeName);
      87.         SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder().from(1).size(1).query(QueryBuilders.rangeQuery("price").gte(10.0).lte(100.0));
      88.         searchRequest.source(searchSourceBuilder);
      89.         SearchResponse searchResponse = restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT);
      90.         if (searchResponse.status() == RestStatus.OK) {
      91.             SearchHits searchHits = searchResponse.getHits();
      92.             for (SearchHit searchHit : searchHits) {
      93.                 System.out.println(searchHit.getSourceAsMap());
      94.             }
      95.         }
      96.         restHighLevelClient.close();
      97.     }
      98.  
      99.     /**
      100.      * 这种常用于根据筛选条件之后抽取全部数据的场景，
      101.      * scroll API 可以被用来检索大量的结果， 甚至所有的结果 ，
      102.      * 注意es的游标查询的是当下时刻的数据快照，
      103.      * 即在游标查询之后的数据的变动不会影响游标查询的结果，
      104.      * 默认游标查询根据_doc字段进行排序
      105.      *
      106.      * @param restHighLevelClient
      107.      * @param indexName
      108.      * @param typeName
      109.      * @throws IOException
      110.      */
      111.     public static void cusorSearch(RestHighLevelClient restHighLevelClient, String indexName, String typeName) throws IOException {
      112.         SearchRequest searchRequest = new SearchRequest(indexName, typeName);
      113.         SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder().query(QueryBuilders.rangeQuery("price").gte(5.0).lte(100.0));
      114.         searchSourceBuilder.size(2);
      115.         searchRequest.source(searchSourceBuilder);
      116.         Scroll scroll = new Scroll(timeValueMillis(1L));
      117.         /**
      118.          *
      119.          * 在搜索条件之后使用searchSourceBuilder.size(2)设置了每次游标只抽取2条数据，
      120.          * 设置每次游标的超时时间是1毫秒timeValueMillis，可以适当调高超时时间防止由于超时还没查完导致游标提前结束。
      121.          * 在执行游标的时候，第一次使用了客户端的search方法，从第二次开始使用scroll方法，
      122.          * 每开始下一次游标的时候都通过查看本次游标的结果是否为空searchResponse.getHits().getHits()来判断是否还要继续，
      123.          * 把每次游标的返回结果收集起来拿到全部数据
      124.          *
      125.          */
      126.         searchRequest.scroll(scroll);
      127.         SearchResponse searchResponse = restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT);
      128.         String scrollId = searchResponse.getScrollId();
      129.         SearchHit[] hits = searchResponse.getHits().getHits();
      130.         List resultSearchHit = new ArrayList<>();
      131.         while (hits != null && hits.length > 0) {
      132.             System.out.println(hits.length);
      133.             System.out.println(scrollId);
      134.             resultSearchHit.addAll(Arrays.asList(hits));
      135.             SearchScrollRequest searchScrollRequest = new SearchScrollRequest(scrollId);
      136.             searchScrollRequest.scroll(scroll);
      137.             SearchResponse searchScrollResponse = restHighLevelClient.scroll(searchScrollRequest, RequestOptions.DEFAULT);
      138.             scrollId = searchScrollResponse.getScrollId();
      139.             hits = searchScrollResponse.getHits().getHits();
      140.         }
      141.         ClearScrollRequest clearScrollRequest = new ClearScrollRequest();
      142.         clearScrollRequest.addScrollId(scrollId);
      143.         restHighLevelClient.clearScroll(clearScrollRequest, RequestOptions.DEFAULT);
      144.         restHighLevelClient.close();
      145.     }
      146.  
      147.     /**
      148.      * 返回指定字段
      149.      * 设置fetchSource参数，传入两个数组，前一个是包含的字段，后一个是排除的字段
      150.      *
      151.      * @param restHighLevelClient
      152.      * @param indexName
      153.      * @param typeName
      154.      * @throws IOException
      155.      */
      156.     public static void specColSearch(RestHighLevelClient restHighLevelClient, String indexName, String typeName) throws IOException {
      157.         SearchRequest searchRequest = new SearchRequest(indexName, typeName);
      158.         SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder()
      159.                 .query(QueryBuilders.termQuery("_id", "001"))
      160.                 .fetchSource(new String[]{"city"}, new String[]{});
      161.         searchRequest.source(searchSourceBuilder);
      162.         SearchResponse searchResponse = restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT);
      163.         if (searchResponse.status() == RestStatus.OK) {
      164.             SearchHits searchHits = searchResponse.getHits();
      165.             System.out.println(searchHits.getAt(0));
      166.         }
      167.  
      168.         restHighLevelClient.close();
      169.     }
      170.  
      171.     /**
      172.      * 排序
      173.      * 排序在SearchSourceBuilder对象后构建sort参数，通过SortOrder.DESC倒序列和SortOrder.ASC升序
      174.      * @param restHighLevelClient
      175.      * @param indexName
      176.      * @param typeName
      177.      * @throws IOException
      178.      */
      179.     public static void sortSearch(RestHighLevelClient restHighLevelClient, String indexName, String typeName) throws IOException {
      180.         SearchRequest searchRequest = new SearchRequest(indexName, typeName);
      181.         SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder().sort("price", SortOrder.DESC);
      182.         searchRequest.source(searchSourceBuilder);
      183.         SearchResponse searchResponse = restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT);
      184.         if (searchResponse.status() == RestStatus.OK) {
      185.             SearchHits searchHits = searchResponse.getHits();
      186.             for (SearchHit searchHit : searchHits) {
      187.                 System.out.println(searchHit);
      188.             }
      189.         }
      190.  
      191.         restHighLevelClient.close();
      192.     }
       

      
                
                    
                

                
    21. 

                    相关阅读:
      
                    
Java 中常用进制转换                            
      
mac使用python递归删除文件夹下所有的.DS_Store文件                            
      
STM32物联网项目-GPRS模块介绍                            
      
C语言：通讯录联系(内存存储)                            
      
springboot项目结构命名规范                            
      
vue的生命周期                            
      
113-JavaSE基础进阶：补充知识-工厂模式、装饰模式                            
      
【电路参考】缓启动电路                            
      
opencv之修改尺寸、灰度转换（python）                            
      
java计算机毕业设计基于springboo+vue的个人家庭理财记账管理系统                            
      
                          
                
      22. 
                
    22. 
                    原文地址：https://blog.csdn.net/dkjhl/article/details/126872986
                
      23.