elasticsearch实战应用JAVA案例

Elasticsearch 是一个强大的分布式搜索和分析引擎，能够快速处理海量数据，提供高效的全文搜索、结构化搜索和近实时分析。Elasticsearch 的核心是它基于文档存储的设计，数据以JSON格式存储并索引，使得它不仅适用于搜索，还适用于实时数据分析和日志处理等场景。

在Java应用中，Elasticsearch通常作为一个搜索服务集成进来，通过使用Elasticsearch Java API，开发者可以与Elasticsearch集群进行交互，包括数据索引、查询、分析等操作。

本文将通过一个简单的项目展示如何使用Java集成Elasticsearch，构建一个电影搜索引擎。我们将涵盖以下内容：

1. 使用Java客户端连接Elasticsearch。
2. 创建索引并插入文档。
3. 使用全文搜索和结构化查询。
4. 更新与删除数据。
5. 分析和聚合数据。

环境准备

首先，需要确保你的机器上已经安装并运行Elasticsearch。可以在本地搭建Elasticsearch，也可以使用云服务（如Elastic Cloud）提供的托管Elasticsearch。

接下来，你需要在项目中添加Elasticsearch的Java客户端依赖。

依赖

使用Maven作为项目构建工具时，你需要在pom.xml文件中添加以下依赖：

<dependencies>
    <!-- Elasticsearch Java High Level Rest Client -->
    <dependency>
        <groupId>org.elasticsearch.client</groupId>
        <artifactId>elasticsearch-rest-high-level-client</artifactId>
        <version>7.10.2</version>
    </dependency>

    <!-- Jackson for JSON parsing -->
    <dependency>
        <groupId>com.fasterxml.jackson.core</groupId>
        <artifactId>jackson-databind</artifactId>
        <version>2.12.1</version>
    </dependency>
</dependencies>

注意：在此示例中使用的是Elasticsearch 7.x的Java High-Level Rest Client，如果你使用的是8.x版本，可以使用Elasticsearch的新的客户端API。

1. 连接Elasticsearch集群

我们首先需要通过Java代码与Elasticsearch进行连接。Elasticsearch的Java Rest客户端可以通过创建RestHighLevelClient对象来实现与集群的连接。

代码示例：

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

public class ElasticsearchClient {

    private static RestHighLevelClient client;

    // 初始化连接到Elasticsearch集群
    public static RestHighLevelClient createClient() {
        client = new RestHighLevelClient