{"id":1391,"date":"2023-03-19T11:08:35","date_gmt":"2023-03-19T03:08:35","guid":{"rendered":"https:\/\/www.appblog.cn\/?p=1391"},"modified":"2023-04-28T21:11:18","modified_gmt":"2023-04-28T13:11:18","slug":"elasticsearch-high-level-rest-api-scroll-scrolling","status":"publish","type":"post","link":"https:\/\/www.appblog.cn\/index.php\/2023\/03\/19\/elasticsearch-high-level-rest-api-scroll-scrolling\/","title":{"rendered":"ElasticSearch High Level REST API\uff083\uff09Scroll \u6eda\u5c4f"},"content":{"rendered":"<p>ElasticSearch\u4e2d\u63d0\u4f9b\u4e86 FROM\/SIZE \u5206\u9875\uff0c\u4f46\u8fd9\u79cd\u5206\u9875\u6709\u6027\u80fd\u74f6\u9888\u3002<\/p>\n<p>Scroll\u4f1a\u4ee5\u95f4\u9694\u65f6\u95f4\u6eda\u5c4f\u7684\u65b9\u5f0f\u8fd4\u56de\u5168\u90e8\u7684\u67e5\u8be2\u6570\u636e\uff0c\u53ef\u4ee5\u4f5c\u4e3a\u6570\u636e\u91cf\u5f88\u5927\u7684\u60c5\u51b5\u4e0b\uff0c\u5206\u9875\u7684\u4e00\u4e2a\u66ff\u4ee3\u65b9\u6848<\/p>\n<p><!-- more --><\/p>\n<p>\u5b8c\u6574\u7684\u793a\u4f8b\u5982\u4e0b\uff1a<\/p>\n<pre><code class=\"language-java\">@GetMapping(&quot;scroll&quot;)\npublic String scroll() {\n    \/\/\u521d\u59cb\u5316scroll\n    final Scroll scroll = new Scroll(TimeValue.timeValueMinutes(1L)); \/\/\u8bbe\u5b9a\u6eda\u52a8\u65f6\u95f4\u95f4\u9694\n    SearchRequest searchRequest = new SearchRequest(&quot;test&quot;);\n    searchRequest.scroll(scroll);\n    SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();\n    searchSourceBuilder.query(QueryBuilders.matchAllQuery());\n    searchSourceBuilder.size(2); \/\/\u8bbe\u5b9a\u6bcf\u6b21\u8fd4\u56de\u591a\u5c11\u6761\u6570\u636e\n    searchRequest.source(searchSourceBuilder);\n\n    SearchResponse searchResponse = null;\n    try {\n        searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);\n    } catch (IOException e) {\n        e.printStackTrace();\n    }\n    if (searchResponse == null) {\n        return &quot;&quot;;\n    }\n    String scrollId = searchResponse.getScrollId();\n    SearchHit[] searchHits = searchResponse.getHits().getHits();\n    log.info(&quot;-----\u9996\u9875-----&quot;);\n    for (SearchHit searchHit : searchHits) {\n        log.info(searchHit.getSourceAsString());\n    }\n    \/\/\u904d\u5386\u641c\u7d22\u547d\u4e2d\u7684\u6570\u636e\uff0c\u76f4\u5230\u6ca1\u6709\u6570\u636e\n    while (searchHits != null &amp;&amp; searchHits.length &gt; 0) {\n        SearchScrollRequest scrollRequest = new SearchScrollRequest(scrollId);\n        scrollRequest.scroll(scroll);\n        try {\n            searchResponse = client.scroll(scrollRequest, RequestOptions.DEFAULT);\n        } catch (IOException e) {\n            e.printStackTrace();\n        }\n        scrollId = searchResponse.getScrollId();\n        searchHits = searchResponse.getHits().getHits();\n        if (searchHits != null &amp;&amp; searchHits.length &gt; 0) {\n            log.info(&quot;-----\u4e0b\u4e00\u9875-----&quot;);\n            for (SearchHit searchHit : searchHits) {\n                log.info(searchHit.getSourceAsString());\n            }\n        }\n    }\n    \/\/\u6e05\u9664\u6eda\u5c4f\n    ClearScrollRequest clearScrollRequest = new ClearScrollRequest();\n    clearScrollRequest.addScrollId(scrollId); \/\/\u4e5f\u53ef\u4ee5\u9009\u62e9setScrollIds()\u5c06\u591a\u4e2ascrollId\u4e00\u8d77\u4f7f\u7528\n    ClearScrollResponse clearScrollResponse = null;\n    try {\n        clearScrollResponse = client.clearScroll(clearScrollRequest, RequestOptions.DEFAULT);\n    } catch (IOException e) {\n        e.printStackTrace();\n    }\n    boolean succeeded = clearScrollResponse.isSucceeded();\n    log.info(&quot;succeeded:&quot; + succeeded);\n    return String.valueOf(succeeded);\n}<\/code><\/pre>\n<pre><code>-----\u9996\u9875-----\n{&quot;name&quot;:&quot;Joe.Ye@AppBlog.CN&quot;,&quot;email&quot;:&quot;yezhou@yezhou.org&quot;,&quot;homepage&quot;:&quot;http:\/\/www.appblog.cn&quot;,&quot;age&quot;:18}\n{&quot;name&quot;:&quot;Joe.Ye&quot;,&quot;email&quot;:&quot;yezhou@yezhou.org&quot;,&quot;homepage&quot;:&quot;http:\/\/www.appblog.cn&quot;}\n-----\u4e0b\u4e00\u9875-----\n{&quot;name&quot;:&quot;Joe.Ye@AppBlog.CN&quot;,&quot;age&quot;:18,&quot;homepage&quot;:&quot;http:\/\/www.appblog.cn&quot;}\n{&quot;name&quot;:&quot;Joe.Ye&quot;,&quot;age&quot;:28,&quot;homepage&quot;:&quot;http:\/\/www.appblog.cn&quot;}\n-----\u4e0b\u4e00\u9875-----\n{&quot;name&quot;:&quot;Joe.Ye&quot;,&quot;email&quot;:&quot;yezhou@yezhou.org&quot;,&quot;homepage&quot;:&quot;http:\/\/www.appblog.cn&quot;}\nsucceeded:true<\/code><\/pre>\n","protected":false},"excerpt":{"rendered":"<p>ElasticSearch\u4e2d\u63d0\u4f9b\u4e86 FROM\/SIZE \u5206\u9875\uff0c\u4f46\u8fd9\u79cd\u5206\u9875\u6709\u6027\u80fd\u74f6\u9888\u3002 Scroll\u4f1a\u4ee5\u95f4\u9694\u65f6\u95f4 [&hellip;]<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[301],"tags":[],"class_list":["post-1391","post","type-post","status-publish","format-standard","hentry","category-elasticsearch"],"_links":{"self":[{"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/posts\/1391","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/comments?post=1391"}],"version-history":[{"count":0,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/posts\/1391\/revisions"}],"wp:attachment":[{"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/media?parent=1391"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/categories?post=1391"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/tags?post=1391"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}