• 使用Elasticsearch与Java进行全文搜索


    全文搜索是现代应用中不可或缺的功能之一,它允许用户通过关键词快速找到所需的信息。Elasticsearch是一个基于Lucene库的分布式搜索和分析引擎,它提供了强大的全文搜索功能。本文将详细介绍如何使用Java与Elasticsearch进行全文搜索,并提供详细的代码示例。

    1. 环境准备

    在开始之前,确保你已经安装了以下软件:

    • Java 8或更高版本
    • Elasticsearch 7.x或更高版本
    • IntelliJ IDEA或其他Java IDE

    1.1 安装Elasticsearch

    你可以从Elasticsearch官方网站下载并安装Elasticsearch。安装完成后,启动Elasticsearch服务:

    ./bin/elasticsearch
    

    默认情况下,Elasticsearch将在http://localhost:9200上运行。

    1.2 添加Elasticsearch依赖

    在你的Java项目中,添加Elasticsearch的Java客户端依赖。如果你使用Maven,可以在pom.xml中添加以下依赖:

    1. <dependency>
    2. <groupId>org.elasticsearch.clientgroupId>
    3. <artifactId>elasticsearch-rest-high-level-clientartifactId>
    4. <version>7.10.0version>
    5. dependency>

    2. 连接到Elasticsearch

    首先,我们需要创建一个Elasticsearch客户端并连接到Elasticsearch服务。以下是一个简单的示例:

    1. import org.apache.http.HttpHost;
    2. import org.elasticsearch.client.RestClient;
    3. import org.elasticsearch.client.RestHighLevelClient;
    4. public class ElasticsearchClient {
    5. private static RestHighLevelClient client;
    6. public static RestHighLevelClient getClient() {
    7. if (client == null) {
    8. client = new RestHighLevelClient(
    9. RestClient.builder(
    10. new HttpHost("localhost", 9200, "http")
    11. )
    12. );
    13. }
    14. return client;
    15. }
    16. public static void closeClient() {
    17. if (client != null) {
    18. try {
    19. client.close();
    20. } catch (IOException e) {
    21. e.printStackTrace();
    22. }
    23. }
    24. }
    25. }

    3. 创建索引

    在Elasticsearch中,数据存储在索引中。我们需要创建一个索引来存储我们的文档。以下是一个创建索引的示例:

    1. import org.elasticsearch.action.admin.indices.create.CreateIndexRequest;
    2. import org.elasticsearch.action.admin.indices.create.CreateIndexResponse;
    3. import org.elasticsearch.client.RequestOptions;
    4. import org.elasticsearch.client.RestHighLevelClient;
    5. public class IndexCreator {
    6. public static void createIndex(String indexName) {
    7. RestHighLevelClient client = ElasticsearchClient.getClient();
    8. CreateIndexRequest request = new CreateIndexRequest(indexName);
    9. try {
    10. CreateIndexResponse response = client.indices().create(request, RequestOptions.DEFAULT);
    11. if (response.isAcknowledged()) {
    12. System.out.println("Index created: " + indexName);
    13. } else {
    14. System.err.println("Failed to create index: " + indexName);
    15. }
    16. } catch (IOException e) {
    17. e.printStackTrace();
    18. }
    19. }
    20. }

    4. 索引文档

    接下来,我们将文档索引到Elasticsearch中。以下是一个索引文档的示例:

    1. import org.elasticsearch.action.index.IndexRequest;
    2. import org.elasticsearch.action.index.IndexResponse;
    3. import org.elasticsearch.client.RequestOptions;
    4. import org.elasticsearch.client.RestHighLevelClient;
    5. import org.elasticsearch.common.xcontent.XContentType;
    6. public class DocumentIndexer {
    7. public static void indexDocument(String indexName, String id, String jsonDocument) {
    8. RestHighLevelClient client = ElasticsearchClient.getClient();
    9. IndexRequest request = new IndexRequest(indexName)
    10. .id(id)
    11. .source(jsonDocument, XContentType.JSON);
    12. try {
    13. IndexResponse response = client.index(request, RequestOptions.DEFAULT);
    14. System.out.println("Document indexed with ID: " + response.getId());
    15. } catch (IOException e) {
    16. e.printStackTrace();
    17. }
    18. }
    19. }

    5. 搜索文档

    现在,我们将进行全文搜索。以下是一个简单的搜索示例:

    1. import org.elasticsearch.action.search.SearchRequest;
    2. import org.elasticsearch.action.search.SearchResponse;
    3. import org.elasticsearch.client.RequestOptions;
    4. import org.elasticsearch.client.RestHighLevelClient;
    5. import org.elasticsearch.index.query.QueryBuilders;
    6. import org.elasticsearch.search.builder.SearchSourceBuilder;
    7. public class DocumentSearcher {
    8. public static void searchDocuments(String indexName, String query) {
    9. RestHighLevelClient client = ElasticsearchClient.getClient();
    10. SearchRequest searchRequest = new SearchRequest(indexName);
    11. SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
    12. searchSourceBuilder.query(QueryBuilders.matchQuery("content", query));
    13. searchRequest.source(searchSourceBuilder);
    14. try {
    15. SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
    16. searchResponse.getHits().forEach(hit -> {
    17. System.out.println("Document ID: " + hit.getId());
    18. System.out.println("Document Source: " + hit.getSourceAsString());
    19. });
    20. } catch (IOException e) {
    21. e.printStackTrace();
    22. }
    23. }
    24. }

    6. 完整示例

    以下是一个完整的示例,展示了如何创建索引、索引文档和进行搜索:

    1. public class ElasticsearchExample {
    2. public static void main(String[] args) {
    3. String indexName = "my_index";
    4. String documentId = "1";
    5. String jsonDocument = "{" +
    6. "\"title\": \"Elasticsearch入门\"," +
    7. "\"content\": \"Elasticsearch是一个强大的全文搜索和分析引擎。\"" +
    8. "}";
    9. // 创建索引
    10. IndexCreator.createIndex(indexName);
    11. // 索引文档
    12. DocumentIndexer.indexDocument(indexName, documentId, jsonDocument);
    13. // 搜索文档
    14. DocumentSearcher.searchDocuments(indexName, "Elasticsearch");
    15. // 关闭客户端
    16. ElasticsearchClient.closeClient();
    17. }
    18. }

    7. 总结

    本文详细介绍了如何使用Java与Elasticsearch进行全文搜索。我们从环境准备开始,逐步讲解了如何连接到Elasticsearch、创建索引、索引文档和进行搜索。通过这些步骤和代码示例,你应该能够开始在自己的项目中使用Elasticsearch进行全文搜索。希望这篇文章对你有所帮助!

  • 相关阅读:
    乾象投资:基于JuiceFS 构建云上量化投研平台
    【Go 编程实践】从零到一:创建、测试并发布自己的 Go 库
    write_project_tcl
    2022河南萌新联赛第(四)场-苹方树-(LCA+重链剖分)
    Jetson Orin NX 开发指南(2): 基本环境配置
    【行为型模式】解释器模式
    【无标题】
    【牛客网刷题】VL11-VL24 组合逻辑 & 时序逻辑
    SBCS MBCS Unicode三种编码方式?
    Arrays.asList() 和 new ArrayList() 的区别(详解)
  • 原文地址:https://blog.csdn.net/weixin_53840353/article/details/140341812