返回

极速Elasticsearch8.x Java API Client完美使用指南，赶紧来学习！

后端

认识 Elasticsearch 8.x 的全新 Java API 客户端

Elasticsearch 8.x 版本引入了重磅更新，其中包括重新设计的 Java API 客户端，旨在提升开发人员的交互体验。本文将深入探讨该客户端的创新特性，并通过示例代码展示其强大功能。

直观的设计理念

Elasticsearch 8.x 的 Java API 客户端采用了符合 Java 惯例的简洁设计。它抛弃了旧版 API 中晦涩的语法和冗长的代码，转而采用现代化的编程理念，让开发人员轻松自如地与 Elasticsearch 交互。

导入依赖项

为了在项目中使用 Java API 客户端，需要在 pom.xml 文件中添加如下依赖项：

<dependency>
    <groupId>org.elasticsearch.client</groupId>
    <artifactId>elasticsearch-rest-high-level-client</artifactId>
    <version>8.2.0</version>
</dependency>

创建客户端实例

要与 Elasticsearch 集群建立连接，可以使用以下代码创建客户端实例：

Client client = RestHighLevelClient.create(HttpHost.create("localhost:9200"));

定义实体类

为了存储数据，我们需要定义一个 POJO（普通旧 Java 对象）类来表示文档。例如，要存储有关人员的信息，我们可以创建一个 Person 类：

@Data
@Builder
public class Person {
    private String name;
    private Integer age;
}

创建索引

创建索引是将数据存储在 Elasticsearch 中的第一步。索引是逻辑容器，包含特定类型的文档。使用 Java API 客户端创建索引的过程非常简单：

CreateIndexRequest request = new CreateIndexRequest("person");
client.indices().create(request, RequestOptions.DEFAULT);

插入数据

向索引中插入数据可以通过创建 IndexRequest 对象来完成。以下代码展示了如何使用 Java 对象插入文档：

Person person = Person.builder().name("John").age(20).build();
IndexRequest request = new IndexRequest("person").id("1").source(JSON.stringify(person));
client.index(request, RequestOptions.DEFAULT);

查询数据

Elasticsearch 提供了强大的搜索功能。使用 Java API 客户端，可以通过构建 SearchRequest 对象来查询数据：

SearchRequest request = new SearchRequest("person");
SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
sourceBuilder.query(QueryBuilders.termQuery("name", "John"));
request.source(sourceBuilder);
SearchResponse response = client.search(request, RequestOptions.DEFAULT);

修改数据

更新文档可以通过创建 UpdateRequest 对象来完成。以下代码展示了如何更新文档中的年龄字段：

UpdateRequest request = new UpdateRequest("person", "1");
request.doc(JSON.stringify(Map.of("age", 21)));
client.update(request, RequestOptions.DEFAULT);

删除数据

删除文档可以使用 DeleteRequest 对象来完成。以下代码展示了如何删除一个文档：

DeleteRequest request = new DeleteRequest("person", "1");
client.delete(request, RequestOptions.DEFAULT);

关闭客户端

在使用完 Java API 客户端后，应将其关闭以释放资源：

client.close();

结论

Elasticsearch 8.x 的 Java API 客户端带来了突破性的改进，使开发人员能够更轻松、更有效地与 Elasticsearch 交互。其直观的设计理念、强大的功能和简洁的语法为开发人员提供了无与伦比的便利和灵活性。

常见问题解答

  1. Java API 客户端与旧版 API 有何不同？

    • Java API 客户端采用了符合 Java 惯例的新设计，更加直观且易于使用。它摒弃了旧版 API 中复杂的语法和冗长的代码，提供了更简洁且功能更强大的 API。

  2. 如何使用 Java API 客户端创建索引？

    • 使用 CreateIndexRequest 对象创建索引，并指定索引名称。然后使用 client.indices().create() 方法创建索引。

  3. 如何向 Elasticsearch 中插入数据？

    • 使用 IndexRequest 对象插入数据，并指定索引名称、文档 ID 和文档源（JSON 格式）。然后使用 client.index() 方法插入数据。

  4. 如何使用 Java API 客户端查询数据？

    • 使用 SearchRequest 对象构建查询，并指定索引名称和查询条件（QueryBuilders）。然后使用 client.search() 方法执行查询。

  5. 如何关闭 Java API 客户端？

    • 使用 client.close() 方法关闭客户端，以释放资源。