【详解】ElasticSearchJava操作ES实例

原创

大盘鸡拌面

发布于 2025-01-19 18:55:41

11400

代码可运行

运行总次数：0

代码可运行

ElasticSearch Java操作ES实例

简介

Elasticsearch 是一个分布式的搜索和分析引擎，广泛用于全文搜索、日志分析等场景。本文将介绍如何在 Java 应用中使用 Elasticsearch 客户端来连接和操作 Elasticsearch 集群。

环境准备

1. 安装 Elasticsearch

首先，确保你的环境中已经安装了 Elasticsearch。可以从 Elasticsearch 官方网站下载最新版本的 Elasticsearch，并按照官方文档进行安装和启动。

2. 添加依赖

在你的 Java 项目中，需要添加 Elasticsearch 的客户端依赖。如果你使用的是 Maven，可以在 pom.xml 文件中添加以下依赖：

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

连接 Elasticsearch

1. 创建客户端

使用 RestHighLevelClient 类来创建一个连接到 Elasticsearch 集群的客户端。

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

public class ElasticsearchClient {
    public static RestHighLevelClient createClient() {
        return new RestHighLevelClient(
            RestClient.builder(
                new HttpHost("localhost", 9200, "http")
            )
        );
    }
}

2. 关闭客户端

在完成所有操作后，记得关闭客户端以释放资源。

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

基本操作

1. 创建索引

创建一个新的索引，并指定一些设置和映射。

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

public class IndexOperations {
    public static void createIndex(RestHighLevelClient client) throws IOException {
        CreateIndexRequest request = new CreateIndexRequest("test_index");
        request.mapping("{\n" +
                "  \"properties\": {\n" +
                "    \"title\": {\n" +
                "      \"type\": \"text\"\n" +
                "    },\n" +
                "    \"content\": {\n" +
                "      \"type\": \"text\"\n" +
                "    }\n" +
                "  }\n" +
                "}", XContentType.JSON);
        CreateIndexResponse response = client.indices().create(request, RequestOptions.DEFAULT);
        System.out.println("Index created: " + response.isAcknowledged());
    }
}

2. 插入数据

向索引中插入一条文档。

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

public class DocumentOperations {
    public static void indexDocument(RestHighLevelClient client) throws IOException {
        String jsonString = "{" +
                "\"title\":\"Elasticsearch基础教程\"," +
                "\"content\":\"Elasticsearch是一个分布式搜索和分析引擎\"}";
        IndexRequest request = new IndexRequest("test_index").source(jsonString, XContentType.JSON);
        IndexResponse response = client.index(request, RequestOptions.DEFAULT);
        System.out.println("Document indexed with ID: " + response.getId());
    }
}

3. 查询数据

从索引中查询文档。

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

public class SearchOperations {
    public static void getDocument(RestHighLevelClient client) throws IOException {
        GetRequest request = new GetRequest("test_index", "1");
        GetResponse response = client.get(request, RequestOptions.DEFAULT);
        if (response.isExists()) {
            System.out.println("Document found: " + response.getSourceAsString());
        } else {
            System.out.println("Document not found.");
        }
    }
}

通过上述步骤，你可以在 Java 应用中轻松地连接和操作 Elasticsearch 集群。本文介绍了如何创建客户端、创建索引、插入文档和查询文档。这些基本操作为更复杂的使用场景奠定了基础。

以上就是使用 Java 操作 Elasticsearch 的一个简单示例。希望对你有帮助！当然可以！Elasticsearch 是一个分布式的搜索和分析引擎，广泛用于全文搜索、日志分析、实时应用监控等场景。下面是一个使用 Java 操作 Elasticsearch 的示例代码，包括连接到 ES 集群、创建索引、插入文档、查询文档等基本操作。

环境准备

添加依赖：在你的 Maven 项目的 pom.xml 文件中添加 Elasticsearch 客户端依赖。

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

配置 Elasticsearch：确保你有一个运行中的 Elasticsearch 实例。你可以使用 Docker 快速启动一个：

docker run -d --name elasticsearch -p 9200:9200 -p 9300:9300 -e "discovery.type=single-node" elasticsearch:7.10.2

示例代码

以下是一个完整的 Java 示例代码，展示了如何连接到 Elasticsearch 集群、创建索引、插入文档和查询文档。

import org.apache.http.HttpHost;
import org.elasticsearch.action.index.IndexRequest;
import org.elasticsearch.action.index.IndexResponse;
import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.common.xcontent.XContentType;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.builder.SearchSourceBuilder;

import java.io.IOException;
import java.util.HashMap;
import java.util.Map;

public class ElasticsearchExample {

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

        try {
            // 创建索引
            createIndex(client);

            // 插入文档
            insertDocument(client);

            // 查询文档
            searchDocument(client);

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

    private static void createIndex(RestHighLevelClient client) throws IOException {
        // 创建索引请求
        Map<String, Object> mappings = new HashMap<>();
        mappings.put("properties", Map.of(
                "title", Map.of("type", "text"),
                "content", Map.of("type", "text")
        ));

        String mappingJson = XContentType.JSON.toString(mappings);
        IndexRequest indexRequest = new IndexRequest("my_index")
                .source(mappingJson, XContentType.JSON);

        // 执行请求
        IndexResponse indexResponse = client.index(indexRequest, RequestOptions.DEFAULT);
        System.out.println("Index created: " + indexResponse.getResult());
    }

    private static void insertDocument(RestHighLevelClient client) throws IOException {
        // 创建文档
        Map<String, Object> document = new HashMap<>();
        document.put("title", "Elasticsearch Example");
        document.put("content", "This is an example of using Elasticsearch with Java.");

        // 创建索引请求
        IndexRequest indexRequest = new IndexRequest("my_index")
                .id("1")
                .source(document);

        // 执行请求
        IndexResponse indexResponse = client.index(indexRequest, RequestOptions.DEFAULT);
        System.out.println("Document inserted: " + indexResponse.getResult());
    }

    private static void searchDocument(RestHighLevelClient client) throws IOException {
        // 创建搜索请求
        SearchRequest searchRequest = new SearchRequest("my_index");
        SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
        searchSourceBuilder.query(QueryBuilders.matchQuery("title", "Elasticsearch"));
        searchRequest.source(searchSourceBuilder);

        // 执行请求
        SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);

        // 处理响应
        for (SearchHit hit : searchResponse.getHits().getHits()) {
            System.out.println("Document found: " + hit.getSourceAsString());
        }
    }
}

代码说明

创建客户端：使用 RestHighLevelClient 连接到 Elasticsearch 集群。
创建索引：定义索引的映射并创建索引。
插入文档：创建一个文档并将其插入到指定的索引中。
查询文档：使用匹配查询（matchQuery）来搜索包含特定关键字的文档。

运行代码

确保你的 Elasticsearch 实例正在运行，然后运行上述 Java 程序。你应该会看到索引创建、文档插入和查询结果的输出。

希望这个示例对你有帮助！如果有任何问题或需要进一步的帮助，请随时告诉我。当然可以！Elasticsearch 是一个分布式的搜索和分析引擎，广泛用于全文搜索、日志分析、实时应用监控等场景。在 Java 应用中操作 Elasticsearch 通常需要使用官方提供的客户端库，如 elasticsearch-rest-high-level-client（现已停止更新）或更现代的 elasticsearch-java 客户端。

以下是一个详细的步骤和示例代码，展示如何在 Java 中使用 elasticsearch-java 客户端来操作 Elasticsearch 实例：

1. 添加依赖

首先，在你的 pom.xml 文件中添加 Elasticsearch 客户端的依赖。这里以 Maven 为例：

<dependency>
    <groupId>co.elastic.clients</groupId>
    <artifactId>elasticsearch-java</artifactId>
    <version>8.6.2</version> <!-- 请根据实际情况选择合适的版本 -->
</dependency>

2. 创建客户端

创建一个 Elasticsearch 客户端实例，用于与 Elasticsearch 集群进行通信。

import co.elastic.clients.elasticsearch.ElasticsearchClient;
import co.elastic.clients.json.jackson.JacksonJsonpMapper;
import co.elastic.clients.transport.ElasticsearchTransport;
import co.elastic.clients.transport.rest_client.RestClientTransport;
import org.apache.http.HttpHost;
import org.elasticsearch.client.RestClient;

public class ElasticsearchClientExample {

    public static ElasticsearchClient createClient() {
        // 创建 Rest 客户端
        RestClient restClient = RestClient.builder(
            new HttpHost("localhost", 9200, "http")
        ).build();

        // 创建 Elasticsearch 客户端
        ElasticsearchTransport transport = new RestClientTransport(
            restClient, new JacksonJsonpMapper()
        );

        return new ElasticsearchClient(transport);
    }
}

3. 索引文档

接下来，我们演示如何索引（插入）一个文档到 Elasticsearch 中。

import co.elastic.clients.elasticsearch.core.IndexResponse;
import co.elastic.clients.elasticsearch.core.IndexRequest;
import co.elastic.clients.elasticsearch.core.IndexResponse.Result;
import com.fasterxml.jackson.databind.ObjectMapper;

public class IndexDocumentExample {

    public static void main(String[] args) throws Exception {
        ElasticsearchClient client = ElasticsearchClientExample.createClient();

        // 创建一个文档对象
        MyDocument document = new MyDocument();
        document.setId(1);
        document.setTitle("Elasticsearch Java Client Example");
        document.setContent("This is an example of using the Elasticsearch Java client.");

        // 使用 ObjectMapper 将对象转换为 JSON 字符串
        ObjectMapper objectMapper = new ObjectMapper();
        String jsonString = objectMapper.writeValueAsString(document);

        // 创建索引请求
        IndexRequest<MyDocument> request = new IndexRequest.Builder<MyDocument>()
            .index("my_index")
            .id(String.valueOf(document.getId()))
            .document(document)
            .build();

        // 执行索引请求
        IndexResponse response = client.index(request);

        // 检查响应结果
        if (response.result() == Result.Created) {
            System.out.println("Document indexed successfully.");
        } else {
            System.out.println("Failed to index document.");
        }

        // 关闭客户端
        client.close();
    }
}

class MyDocument {
    private int id;
    private String title;
    private String content;

    // Getters and Setters
    public int getId() {
        return id;
    }

    public void setId(int id) {
        this.id = id;
    }

    public String getTitle() {
        return title;
    }

    public void setTitle(String title) {
        this.title = title;
    }

    public String getContent() {
        return content;
    }

    public void setContent(String content) {
        this.content = content;
    }
}

4. 查询文档

接下来，我们演示如何查询 Elasticsearch 中的文档。

import co.elastic.clients.elasticsearch.core.SearchRequest;
import co.elastic.clients.elasticsearch.core.SearchResponse;
import co.elastic.clients.elasticsearch.core.search.Hit;

public class SearchDocumentExample {

    public static void main(String[] args) throws Exception {
        ElasticsearchClient client = ElasticsearchClientExample.createClient();

        // 创建查询请求
        SearchRequest request = new SearchRequest.Builder()
            .index("my_index")
            .query(q -> q.match(m -> m.field("title").query("Elasticsearch")))
            .build();

        // 执行查询请求
        SearchResponse<MyDocument> response = client.search(request, MyDocument.class);

        // 处理查询结果
        for (Hit<MyDocument> hit : response.hits().hits()) {
            MyDocument document = hit.source();
            System.out.println("Found document: " + document.getTitle());
        }

        // 关闭客户端
        client.close();
    }
}

5. 删除文档

最后，我们演示如何删除 Elasticsearch 中的文档。

import co.elastic.clients.elasticsearch.core.DeleteRequest;
import co.elastic.clients.elasticsearch.core.DeleteResponse;
import co.elastic.clients.elasticsearch.core.DeleteResponse.Result;

public class DeleteDocumentExample {

    public static void main(String[] args) throws Exception {
        ElasticsearchClient client = ElasticsearchClientExample.createClient();

        // 创建删除请求
        DeleteRequest request = new DeleteRequest.Builder()
            .index("my_index")
            .id("1")
            .build();

        // 执行删除请求
        DeleteResponse response = client.delete(request);

        // 检查响应结果
        if (response.result() == Result.Deleted) {
            System.out.println("Document deleted successfully.");
        } else {
            System.out.println("Failed to delete document.");
        }

        // 关闭客户端
        client.close();
    }
}

总结

以上代码展示了如何在 Java 中使用 elasticsearch-java 客户端进行基本的 CRUD 操作。你可以根据实际需求扩展这些示例，例如处理更复杂的查询、批量操作等。希望这些示例对你有所帮助！

原创声明：本文系作者授权腾讯云开发者社区发表，未经许可，不得转载。

如有侵权，请联系 cloudcommunity@tencent.com 删除。

腾讯技术创作特训营S11#重启人生

原创声明：本文系作者授权腾讯云开发者社区发表，未经许可，不得转载。

如有侵权，请联系 cloudcommunity@tencent.com 删除。

腾讯技术创作特训营S11#重启人生

登录后参与评论

0 条评论

热度