【详解】ElasticSearchJava操作ES实例

2025-07-21 23:12:28

【详解】ElasticSearchJava操作ES实例 ElasticSearch Java操作ES实例简介Elasticsearch 是一个分布式的搜索和分析引擎，广泛用于全文搜索、日志分析等场景。本文将介绍如何在 Java 应用中使用 Elasticsearch 客户端来连接和操作 Elasticsearch 集。环境准备1. 安装 Elasticsearch首先，确保你的环境中已经安装了

【详解】ElasticSearchJava操作ES实例

ElasticSearch Java操作ES实例

简介

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

环境准备

1. 安装 Elasticsearch

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

2. 添加依赖

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

代码语言：javascript代码运行次数：0运行复制

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

连接 Elasticsearch

1. 创建客户端

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

代码语言：javascript代码运行次数：0运行复制

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

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

2. 关闭客户端

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

代码语言：javascript代码运行次数：0运行复制

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

基本操作

1. 创建索引

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

代码语言：javascript代码运行次数：0运行复制

import action.admin.CreateIndexRequest;
import action.admin.CreateIndexRespe;
import .RequestOpti;
import xcontent.XContentType;

public class IndexOperati {
    public static void createIndex(RestHighLevelClient client) throws IOException {
        CreateIndexRequest request = new CreateIndexRequest("test_index");
        ("{\n" +
                "  \"properties\": {\n" +
                "    \"title\": {\n" +
                "      \"type\": \"text\"\n" +
                "    },\n" +
                "    \"content\": {\n" +
                "      \"type\": \"text\"\n" +
                "    }\n" +
                "  }\n" +
                "}", XContentType.JSO);
        CreateIndexRespe respe = client.indices().create(request, RequestOpti.DEFAULT);
        println("Index created: " + respe.isAcknowledged());
    }
}

2. 插入数据

向索引中插入一条文档。

代码语言：javascript代码运行次数：0运行复制

import action.index.IndexRequest;
import action.index.IndexRespe;
import xcontent.XContentType;

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

. 查询数据

从索引中查询文档。

代码语言：javascript代码运行次数：0运行复制

import action.get.GetRequest;
import action.get.GetRespe;

public class SearchOperati {
    public static void getDocument(RestHighLevelClient client) throws IOException {
        GetRequest request = new GetRequest("test_index", "1");
        GetRespe respe = client.get(request, RequestOpti.DEFAULT);
        if (respe.isExists()) {
            println("Document found: " + respe.getSourceAsString());
        } else {
            println("Document not found.");
        }
    }
}

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

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

环境准备

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

代码语言：javascript代码运行次数：0运行复制

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

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

代码语言：javascript代码运行次数：0运行复制

docker run -d --name elasticsearch -p 9200:9200 -p 900:900 -e "=single-node" elasticsearch:7.10.2

示例代码

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

代码语言：javascript代码运行次数：0运行复制

import org.apache.http.HttpHost;
import action.index.IndexRequest;
import action.index.IndexRespe;
import action.search.SearchRequest;
import action.search.SearchRespe;
import .RequestOpti;
import .RestClient;
import .RestHighLevelClient;
import xcontent.XContentType;
import index.query.QueryBuilders;
import search.SearchHit;
import 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 {
                ();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

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

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

        // 执行请求
        IndexRespe indexRespe = client.index(indexRequest, RequestOpti.DEFAULT);
        println("Index created: " + indexRespe.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);

        // 执行请求
        IndexRespe indexRespe = client.index(indexRequest, RequestOpti.DEFAULT);
        println("Document inserted: " + indexRespe.getResult());
    }

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

        // 执行请求
        SearchRespe searchRespe = client.search(searchRequest, RequestOpti.DEFAULT);

        // 处理响应
        for (SearchHit hit : searchRespe.getHits().getHits()) {
            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 为例：

代码语言：javascript代码运行次数：0运行复制

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

2. 创建客户端

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

代码语言：javascript代码运行次数：0运行复制

import .elasticsearch.ElasticsearchClient;
import .json.jackson.JacksonJsonpMapper;
import .transport.ElasticsearchTransport;
import .transport.rest_client.RestClientTransport;
import org.apache.http.HttpHost;
import .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);
    }
}

. 索引文档

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

代码语言：javascript代码运行次数：0运行复制

import .elasticsearch.core.IndexRespe;
import .elasticsearch.core.IndexRequest;
import .elasticsearch.core.IndexRespe.Result;
import com.fasterxml.jackson.databind.ObjectMapper;

public class IndexDocumentExample {

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

        // 创建一个文档对象
        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 将对象转换为 JSO 字符串
        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();

        // 执行索引请求
        IndexRespe respe = client.index(request);

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

        // 关闭客户端
        ();
    }
}

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) {
         = title;
    }

    public String getContent() {
        return content;
    }

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

4. 查询文档

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

代码语言：javascript代码运行次数：0运行复制

import .elasticsearch.core.SearchRequest;
import .elasticsearch.core.SearchRespe;
import .elasticsearch.core.search.Hit;

public class SearchDocumentExample {

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

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

        // 执行查询请求
        SearchRespe<MyDocument> respe = client.search(request, );

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

        // 关闭客户端
        ();
    }
}

5. 删除文档

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

代码语言：javascript代码运行次数：0运行复制

import .elasticsearch.core.DeleteRequest;
import .elasticsearch.core.DeleteRespe;
import .elasticsearch.core.DeleteRespe.Result;

public class DeleteDocumentExample {

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

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

        // 执行删除请求
        DeleteRespe respe = client.delete(request);

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

        // 关闭客户端
        ();
    }
}

总结

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

#感谢您对电脑配置推荐网 - 最新i3 i5 i7组装电脑配置单推荐报价格的认可，转载请说明来源于"电脑配置推荐网 - 最新i3 i5 i7组装电脑配置单推荐报价格

本文地址：http://www.dnpztj.cn/biancheng/1166931.html

本站网友苹果怎么越狱	5分钟前发表
7.10.2示例代码以下是一个完整的 Java 示例代码
本站网友妇产医院网上挂号	2分钟前发表
Object> mappings = new HashMap<>(); mappings.put("properties"
本站网友羊角参	18分钟前发表
查询文档：使用匹配查询（matchQuery）来搜索包含特定关键字的文档
本站网友南通男科	11分钟前发表
RequestOpti.DEFAULT); println("Index created
本站网友贵州茅台酒厂集团	11分钟前发表
" + respe.getSourceAsString()); } else { println("Document not found."); } } }通过上述步骤
本站网友猪腰汤的做法	1分钟前发表
代码语言：javascript代码运行次数：0运行复制import .elasticsearch.ElasticsearchClient; import .json.jackson.JacksonJsonpMapper; import .transport.ElasticsearchTransport; import .transport.rest_client.RestClientTransport; import org.apache.http.HttpHost; import .RestClient; public class ElasticsearchClientExample { public static ElasticsearchClient createClient() { // 创建 Rest 客户端 RestClient restClient = RestClient.builder( new HttpHost("localhost"
本站网友灯光也暗了	2分钟前发表
"text") )); String mappingJson = XContentType.(mappings); IndexRequest indexRequest = new IndexRequest("my_index") .source(mappingJson
本站网友网络购物	9分钟前发表
日志分析
本站网友君子周而不比	28分钟前发表
批量操作等
本站网友丽晶国际	25分钟前发表
以下是一个详细的步骤和示例代码
本站网友公历转农历	7分钟前发表
RequestOpti.DEFAULT); println("Document inserted

【详解】ElasticSearchJava操作ES实例