<aside> 💡 ES为了避免深分页，不允许使用分页(from&size)查询10000条以后的数据，因此如果要查询第10000条以后的数据，要使用ES提供的 scroll(游标) 来查询

</aside>

原理

• 可以把 scroll 理解爲关系型数据库里的 cursor，因此，scroll 并不适合用来做实时搜索，而更适用于后台批处理任务，比如群发
• scroll 具体分为初始化和遍历两步
  • 初始化时将所有符合搜索条件的搜索结果缓存起来，可以想象成快照
  • 在遍历时，从这个快照里取数据
  • 也就是说，在初始化后对索引插入、删除、更新数据都不会影响遍历结果
• 游标可以增加性能的原因，是因为如果做深分页，每次搜索都必须重新排序，非常浪费，使用scroll就是一次把要用的数据都排完了，分批取出，因此比使用from+size还好

实践

ElasticSearchTemplate

@Test
public void testScorll() {
    BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();

    NativeSearchQuery build = new NativeSearchQueryBuilder()
            .withQuery(boolQueryBuilder)
            .withIndices().build();
    //获取s
    Page<PatientInfo> patientInfos = elasticsearchTemplate.startScroll(1000, build, PatientInfo.class);
    printJson(patientInfos);
    Page<PatientInfo> nextPatientInfos = elasticsearchTemplate.continueScroll(((AggregatedPageImpl) patientInfos).getScrollId(), 1000, PatientInfo.class);
    printJson(nextPatientInfos);
}

查询全部

/**
 * query all by searchQuery from es
 * @author fujian
 *
 */
public <T> List<T> queryAll(SearchQuery searchQuery, Class<T> T) {

    String scrollId = scan(searchQuery, 5000l, false);

    List<T> entities = new ArrayList<>();
    boolean hasRecords = true;
    while (hasRecords) {
        SearchResponse searchResponse = getClient().prepareSearchScroll(scrollId).
                setScroll(new TimeValue(5000l)).execute().actionGet();

        Page<T> page = getResultsMapper().mapResults(searchResponse, T, null);
        if(page.hasContent()) {
            entities.addAll(page.getContent());
            scrollId = searchResponse.getScrollId();
        } else {
            hasRecords = false;
        }
    }

    clearScroll(scrollId);

    return entities;

}