使用 RestHighLevelClient 进行 Elasticsearch 分页查询

在处理大量数据的搜索应用中，分页查询是一种常见的需求。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
2
3
4
5

分页查询示例

1. 分页查询基础

在 Elasticsearch 中，可以通过设置 from 和 size 参数来实现分页查询。

Java Code

@Test
void testPagination() throws IOException {
    // 页码，每页大小
    int page = 1, size = 5;
    // 1. 准备 SearchRequest
    SearchRequest 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);
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

DSL Equivalent

GET /hotel/_search
{
  "query": {
    "match_all": {}
  },
  "sort": [
    {
      "price": {
        "order": "asc"
      }
    }
  ],
  "from": 0,
  "size": 5
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

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);
    }
}
1
2
3
4
5
6
7
8
9
10

结语

Elasticsearch 的分页查询功能通过简单的 API 调用即可实现，结合 from 和 size 参数，我们可以轻松地对搜索结果进行分页处理。在实际应用中，分页查询可以显著提高用户体验和后端性能。本文提供的示例代码展示了如何使用 Java 的 RestHighLevelClient 进行分页查询，并给出了对应的 DSL 查询语句，帮助你更好地理解和使用 Elasticsearch 的分页功能。