Elasticsearch 在 Java 中的使用教程

Elasticsearch 在 Java 中的使用教程

Elasticsearch 是一个开源的分布式搜索引擎，通常用于全文搜索、日志分析、以及大数据处理等场景。借助其强大的查询能力和实时的性能，Elasticsearch 在很多应用中得到了广泛的使用。本文将介绍如何在 Java 中使用 Elasticsearch，并给出相应的代码示例。

环境准备

在开始之前，你需要做好以下环境准备：

1. 安装 Elasticsearch： 可以从 Elasticsearch 官网 下载并安装。
2. Maven 项目： 创建一个新的 Maven 项目，并在 pom.xml 中添加如下依赖：

<dependencies>
    <dependency>
        <groupId>org.elasticsearch.client</groupId>
        <artifactId>elasticsearch-rest-high-level-client</artifactId>
        <version>7.14.0</version> <!-- 请根据实际情况选择版本 -->
    </dependency>
    <dependency>
        <groupId>org.elasticsearch</groupId>
        <artifactId>elasticsearch</artifactId>
        <version>7.14.0</version>
    </dependency>
    <dependency>
        <groupId>org.apache.httpcomponents</groupId>
        <artifactId>httpclient</artifactId>
        <version>4.5.13</version>
    </dependency>
</dependencies>

连接 Elasticsearch

在 Java 中使用 Elasticsearch，首先需要创建一个客户端，并连接到 Elasticsearch 服务。

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

public class ElasticsearchClient {
    private static RestHighLevelClient client;

    public static void main(String[] args) {
        client = new RestHighLevelClient(
                RestClient.builder(new HttpHost("localhost", 9200, "http"))
        );

        // 进行后续操作...

        // 关闭客户端
        try {
            client.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

创建索引

接下来，我们将创建一个索引。如果索引已存在，则需要先删除。

import org.elasticsearch.action.admin.indices.create.CreateIndexRequest;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.common.xcontent.XContentType;

public void createIndex(String indexName) {
    CreateIndexRequest request = new CreateIndexRequest(indexName);
    // 可以添加设置，比如分片数、复制数等
    request.settings(Settings.builder()
            .put("index.number_of_shards", 3)
            .put("index.number_of_replicas", 2)
    );

    // 添加映射
    request.mapping("doc", "{\n" +
            "  \"properties\": {\n" +
            "    \"message\": {\n" +
            "      \"type\": \"text\"\n" +
            "    }\n" +
            "  }\n" +
            "}", XContentType.JSON);

    try {
        client.indices().create(request, RequestOptions.DEFAULT);
    } catch (IOException e) {
        e.printStackTrace();
    }
}

插入文档

现在我们已经创建了索引，可以在其中插入文档。

import org.elasticsearch.action.index.IndexRequest;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestHighLevelClient;

public void indexDocument(String indexName, String id, String message) {
    IndexRequest request = new IndexRequest(indexName);
    request.id(id);
    request.source("message", message);

    try {
        client.index(request, RequestOptions.DEFAULT);
    } catch (IOException e) {
        e.printStackTrace();
    }
}

查询文档

插入数据后，我们可以根据条件查询文档。

import org.elasticsearch.action.get.GetRequest;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.builder.SearchSourceBuilder;

public void searchDocument(String indexName, String id) {
    GetRequest getRequest = new GetRequest(indexName, id);

    try {
        GetResponse getResponse = client.get(getRequest, RequestOptions.DEFAULT);
        System.out.println("Document: " + getResponse.getSourceAsString());
    } catch (IOException e) {
        e.printStackTrace();
    }
}

关闭连接

所有操作完成后，确保关闭客户端连接，避免资源泄露。

try {
    client.close();
} catch (IOException e) {
    e.printStackTrace();
}

总结

通过以上步骤，我们可以在 Java 应用中使用 Elasticsearch，进行索引的创建、文档的插入和查询等操作。在大数据和搜索引擎的应用场景中，掌握 Elasticsearch 的使用可以有效提升系统的性能和用户体验。希望本文能对你在 Java 中使用 Elasticsearch 产生帮助。