Java如何操作Elasticsearch ？

ElasticSearch面试考题 0 86

参考回答

在 Java 中操作 Elasticsearch，可以使用官方提供的 Elasticsearch Java 客户端，它封装了与 Elasticsearch 集群的交互过程，提供了一个高效、简洁的方式来执行常见的操作，如索引、搜索、更新和删除文档。

Elasticsearch 提供了不同版本的 Java 客户端，目前最常用的客户端是 RestHighLevelClient（适用于 Elasticsearch 7.x 及以前版本）和 Elasticsearch Java Client（适用于 8.x 版本及以后）。

以下是使用 Java 操作 Elasticsearch 的基本步骤，包括客户端的设置、索引操作、查询操作等。

1. 安装 Elasticsearch 客户端

在 Java 项目中，可以通过 Maven 或 Gradle 来安装 Elasticsearch 客户端依赖。

1.1 通过 Maven 安装客户端

<dependency>
    <groupId>org.elasticsearch.client</groupId>
    <artifactId>elasticsearch-rest-high-level-client</artifactId>
    <version>7.10.0</version> <!-- 版本号根据需要调整 -->
</dependency>

1.2 通过 Gradle 安装客户端

dependencies {
    implementation 'org.elasticsearch.client:elasticsearch-rest-high-level-client:7.10.0'  // 版本号根据需要调整
}

2. 创建 Elasticsearch 客户端

在 Java 中，使用 RestHighLevelClient 来与 Elasticsearch 进行通信。首先，需要配置连接到 Elasticsearch 集群的地址。

2.1 创建客户端实例

import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestHighLevelClient;
import org.apache.http.HttpHost;

public class ElasticsearchClient {
    public static RestHighLevelClient createClient() {
        // 创建一个 RestHighLevelClient 实例，指定 Elasticsearch 节点的地址
        RestHighLevelClient client = new RestHighLevelClient(
            RestClient.builder(
                new HttpHost("localhost", 9200, "http")  // Elasticsearch 服务器地址和端口
            )
        );
        return client;
    }
}

3. 基本操作示例

3.1 创建索引

在 Elasticsearch 中，索引是数据存储的容器。通过 Java 客户端，你可以创建一个新的索引。

import org.elasticsearch.action.admin.indices.create.CreateIndexRequest;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.action.support.master.AcknowledgedResponse;

public class CreateIndexExample {
    public static void createIndex(RestHighLevelClient client) throws Exception {
        // 创建索引请求
        CreateIndexRequest request = new CreateIndexRequest("my_index");

        // 执行创建索引操作
        AcknowledgedResponse createIndexResponse = client.indices().create(request, RequestOptions.DEFAULT);
        // 检查索引是否创建成功
        if (createIndexResponse.isAcknowledged()) {
            System.out.println("Index created successfully");
        }
    }
}

3.2 索引文档（存储数据）

索引文档是 Elasticsearch 中存储数据的基本单位。以下代码示例展示了如何使用 Java 客户端将文档数据存储到索引中。

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

public class IndexDocumentExample {
    public static void indexDocument(RestHighLevelClient client) throws Exception {
        // 创建文档数据（使用 JSON 格式）
        String jsonString = "{" +
                "\"user\":\"john\"," +
                "\"message\":\"Hello, Elasticsearch!\"" +
                "}";

        // 创建索引请求，指定文档的索引和 ID
        IndexRequest request = new IndexRequest("my_index")
                .id("1")  // 文档的 ID，默认由 Elasticsearch 生成
                .source(jsonString, XContentType.JSON);

        // 执行索引请求并返回响应
        IndexResponse indexResponse = client.index(request, RequestOptions.DEFAULT);
        System.out.println("Document indexed, response: " + indexResponse.getResult());
    }
}

3.3 搜索文档

以下代码展示了如何查询 Elasticsearch 中的数据。你可以使用 Match Query 或 Term Query 等查询方式。

import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.search.builder.SearchSourceBuilder;
import org.elasticsearch.search.SearchHits;

public class SearchDocumentExample {
    public static void searchDocument(RestHighLevelClient client) throws Exception {
        // 创建搜索请求
        SearchRequest searchRequest = new SearchRequest("my_index");

        // 构建查询
        SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
        sourceBuilder.query(QueryBuilders.matchQuery("message", "Elasticsearch"));

        // 设置查询条件
        searchRequest.source(sourceBuilder);

        // 执行查询
        SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
        SearchHits hits = searchResponse.getHits();

        // 输出查询结果
        hits.forEach(hit -> System.out.println("Found doc: " + hit.getSourceAsString()));
    }
}

3.4 更新文档

更新 Elasticsearch 中的现有文档，可以使用 UpdateRequest。

import org.elasticsearch.action.update.UpdateRequest;
import org.elasticsearch.action.update.UpdateResponse;
import org.elasticsearch.client.RequestOptions;

public class UpdateDocumentExample {
    public static void updateDocument(RestHighLevelClient client) throws Exception {
        // 创建更新请求
        UpdateRequest updateRequest = new UpdateRequest("my_index", "1");
        String jsonString = "{" +
                "\"message\":\"Updated message\"" +
                "}";
        updateRequest.doc(jsonString, XContentType.JSON);

        // 执行更新操作
        UpdateResponse updateResponse = client.update(updateRequest, RequestOptions.DEFAULT);
        System.out.println("Document updated, response: " + updateResponse.getResult());
    }
}

3.5 删除文档

通过文档 ID 删除指定文档：

import org.elasticsearch.action.delete.DeleteRequest;
import org.elasticsearch.action.delete.DeleteResponse;
import org.elasticsearch.client.RequestOptions;

public class DeleteDocumentExample {
    public static void deleteDocument(RestHighLevelClient client) throws Exception {
        // 创建删除请求，指定索引和文档 ID
        DeleteRequest deleteRequest = new DeleteRequest("my_index", "1");

        // 执行删除操作
        DeleteResponse deleteResponse = client.delete(deleteRequest, RequestOptions.DEFAULT);
        System.out.println("Document deleted, response: " + deleteResponse.getResult());
    }
}

4. 关闭客户端

在操作完 Elasticsearch 后，需要关闭客户端连接，以释放资源：

public class CloseClientExample {
    public static void closeClient(RestHighLevelClient client) throws Exception {
        // 关闭客户端
        client.close();
    }
}

5. 总结

通过使用 Elasticsearch 的 Java 客户端，Java 开发者可以方便地实现与 Elasticsearch 的交互，包括创建索引、存储数据、执行搜索查询、更新和删除文档等操作。客户端封装了底层的 REST API，提供了简单易用的接口进行集群和文档管理。通过使用客户端，可以在 Java 应用程序中高效地使用 Elasticsearch 提供的强大功能。