【Elasticsearch系列五】Java API

Elasticsearch Java API 使用指南

Elasticsearch 是一个开源的全文搜索引擎，广泛用于大规模数据的检索和分析。在实践中，我们常常需要通过 Java 应用程序与 Elasticsearch 进行交互。本文将介绍如何使用 Java API 进行基本的 CRUD 操作，并给出相应的代码示例。

1. 引入依赖

在使用 Java API 之前，需要确保你的项目中引入了 Elasticsearch 的相关依赖。如果使用 Maven，可以在 pom.xml 中添加以下依赖：

<dependency>
    <groupId>org.elasticsearch.client</groupId>
    <artifactId>elasticsearch-rest-high-level-client</artifactId>
    <version>7.17.0</version>  <!-- 根据需要选择版本 -->
</dependency>
<dependency>
    <groupId>org.elasticsearch</groupId>
    <artifactId>elasticsearch</artifactId>
    <version>7.17.0</version>
</dependency>

2. 创建 Elasticsearch 客户端

首先，你需要创建一个 RestHighLevelClient 实例，以便与 Elasticsearch 进行通信。以下是如何初始化客户端的示例代码：

import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestHighLevelClient;

public class ElasticsearchClient {
    private static RestHighLevelClient client;

    public static void createClient() {
        client = new RestHighLevelClient(RestClient.builder(
                new HttpHost("localhost", 9200, "http")));
    }

    public static RestHighLevelClient getClient() {
        return client;
    }

    public static void closeClient() throws IOException {
        client.close();
    }
}

确保将 localhost 和端口号 9200 替换为你的 Elasticsearch 实例的地址和端口。

3. CRUD 操作示例

3.1 创建文档

以下是如何向 Elasticsearch 索引中添加文档的示例代码：

import org.elasticsearch.action.index.IndexRequest;
import org.elasticsearch.action.index.IndexResponse;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.common.xcontent.XContentType;

import java.io.IOException;

public class CreateDocument {

    public static void main(String[] args) throws IOException {
        ElasticsearchClient.createClient();
        RestHighLevelClient client = ElasticsearchClient.getClient();

        IndexRequest request = new IndexRequest("my_index").id("1")
                .source(XContentType.JSON, "name", "张三", "age", 30);
        IndexResponse indexResponse = client.index(request);

        System.out.println("文档创建成功，ID: " + indexResponse.getId());

        ElasticsearchClient.closeClient();
    }
}

3.2 读取文档

以下是如何从 Elasticsearch 中读取文档的示例代码：

import org.elasticsearch.action.get.GetRequest;
import org.elasticsearch.action.get.GetResponse;
import org.elasticsearch.client.RestHighLevelClient;

import java.io.IOException;

public class GetDocument {

    public static void main(String[] args) throws IOException {
        ElasticsearchClient.createClient();
        RestHighLevelClient client = ElasticsearchClient.getClient();

        GetRequest getRequest = new GetRequest("my_index", "1");
        GetResponse getResponse = client.get(getRequest);

        if (getResponse.isExists()) {
            System.out.println("文档内容: " + getResponse.getSourceAsString());
        } else {
            System.out.println("文档不存在");
        }

        ElasticsearchClient.closeClient();
    }
}

3.3 更新文档

更新文档的代码示例如下：

import org.elasticsearch.action.update.UpdateRequest;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.common.xcontent.XContentType;

import java.io.IOException;

public class UpdateDocument {

    public static void main(String[] args) throws IOException {
        ElasticsearchClient.createClient();
        RestHighLevelClient client = ElasticsearchClient.getClient();

        UpdateRequest updateRequest = new UpdateRequest("my_index", "1")
                .doc(XContentType.JSON, "age", 31);
        client.update(updateRequest);

        System.out.println("文档更新成功");

        ElasticsearchClient.closeClient();
    }
}

3.4 删除文档

以下是删除文档的代码示例：

import org.elasticsearch.action.delete.DeleteRequest;
import org.elasticsearch.client.RestHighLevelClient;

import java.io.IOException;

public class DeleteDocument {

    public static void main(String[] args) throws IOException {
        ElasticsearchClient.createClient();
        RestHighLevelClient client = ElasticsearchClient.getClient();

        DeleteRequest deleteRequest = new DeleteRequest("my_index", "1");
        client.delete(deleteRequest);

        System.out.println("文档删除成功");

        ElasticsearchClient.closeClient();
    }
}

4. 总结

通过上述示例，可以看到使用 Elasticsearch Java API 进行基本的 CRUD 操作是相对简单的。利用 Java Client API，我们可以方便地与 Elasticsearch 进行交互，执行各种操作。希望本篇文章能够帮助你更好地理解和使用 Elasticsearch 的 Java API。在实际应用中，可以结合更多的功能，如批量处理、搜索和聚合等，以应对更复杂的需求。