使用Elasticsearch查询大量数据时基本的分页查询就会报错,这种状况下可使用scroll(滚动)查询java
直接上代码:服务器
// 建立查询条件对象 BoolQueryBuilder queryBuilder = QueryBuilders.boolQuery(); // 拼接查询条件 queryBuilder.must(QueryBuilders.termQuery("status", 1)); 假设查询状态为1的 // 建立查询对象 SearchQuery searchQuery = new NativeSearchQueryBuilder() .withIndices("test_index")//索引名 .withTypes("test")//类型名 .withQuery(queryBuilder)// 查询条件对象 .withPageable(PageRequest.of(0, 1000))//从0页开始查,每页1000个结果 .build(); // 滚动查询 ScrolledPage<TestEntity> scroll = (ScrolledPage<TestEntity>) elasticsearchTemplate.startScroll(3000, searchQuery, TestEntity.class); // 判断是否有内容 while (scroll.hasContent()) { List<TestEntity> content = scroll.getContent(); // 业务逻辑省略 //取下一页,scrollId在es服务器上可能会发生变化,须要用最新的。发起continueScroll请求会从新刷新快照保留时间 scroll = (ScrolledPage<EstateInfoEntity>) elasticsearchTemplate.continueScroll(scroll.getScrollId(), 3000, EstateInfoEntity.class); } // 最后释放查询 elasticsearchTemplate.clearScroll(scroll.getScrollId());