在处理大量数据的搜索应用中，分页查询是一种常见的需求。Elasticsearch 以其灵活的搜索能力，支持高效的分页查询操作。本文将介绍如何在 Java 应用程序中使用 Elasticsearch 的 RestHighLevelClient 执行分页查询，并展示如何结合排序进行结果的有序展示。
环境准备
确保你的项目中已经添加了 Elasticsearch 客户端库的依赖。如果使用 Maven，可以在 pom.xml 文件中添加如下依赖：
<dependency><groupId>org.elasticsearch.client</groupId><artifactId>elasticsearch-rest-high-level</artifactId><version>7.10.0</version> <!-- 使用适合的版本号 -->
</dependency>
分页查询示例
1. 分页查询基础
在 Elasticsearch 中，可以通过设置 from 和 size 参数来实现分页查询。
Java Code
@Test
void testPagination() throws IOException {// 页码，每页大小int page = 1, size = 5;// 1. 准备 SearchRequestSearchRequest request = new SearchRequest("hotel"); // 指定索引名称// 2. 准备 DSL 查询request.source().query(QueryBuilders.matchAllQuery()) // 查询所有文档.sort("price", SortOrder.ASC) // 按价格升序排序.from((page - 1) * size) // 分页开始位置.size(size); // 每页大小// 3. 发送请求SearchResponse response = client.search(request, RequestOptions.DEFAULT);// 4. 解析响应handleResponse(response);
}
DSL Equivalent
GET /hotel/_search
{"query": {"match_all": {}},"sort": [{"price": {"order": "asc"}}],"from": 0,"size": 5
}
2. 响应处理
定义一个通用方法来处理搜索响应，打印结果。
private void handleResponse(SearchResponse response) throws IOException {SearchHits searchHits = response.getHits();long total = searchHits.getTotalHits().value;System.out.println("共搜索到 " + total + " 条数据");for (SearchHit hit : searchHits.getHits()) {String json = hit.getSourceAsString();System.out.println(json);}
}
结语
Elasticsearch 的分页查询功能通过简单的 API 调用即可实现，结合 from 和 size 参数，我们可以轻松地对搜索结果进行分页处理。在实际应用中，分页查询可以显著提高用户体验和后端性能。本文提供的示例代码展示了如何使用 Java 的 RestHighLevelClient 进行分页查询，并给出了对应的 DSL 查询语句，帮助你更好地理解和使用 Elasticsearch 的分页功能。