Java中的ElasticSearch集成与实践

本文主要是介绍Java中的ElasticSearch集成与实践，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

Java中的ElasticSearch集成与实践

大家好，我是免费搭建查券返利机器人省钱赚佣金就用微赚淘客系统3.0的小编，也是冬天不穿秋裤，天冷也要风度的程序猿！今天我们来讨论如何在Java应用中集成和实践ElasticSearch。ElasticSearch是一种分布式搜索和分析引擎，能够处理海量数据的实时搜索和分析需求。本文将从ElasticSearch的基本概念、Java中的集成方法、实际案例等方面进行详细阐述。

ElasticSearch的基本概念

ElasticSearch基于Lucene构建，是一个开源的分布式搜索引擎。它能够实现实时的全文搜索、结构化搜索和分析功能。以下是一些关键概念：

索引（Index）：类似于数据库中的数据库，一个索引包含多个文档。
类型（Type）：类似于数据库中的表，一个索引可以有多个类型（在ElasticSearch 7.x中类型已经被移除）。
文档（Document）：类似于数据库中的行，文档是可以被索引的基本单元。
字段（Field）：类似于数据库中的列，一个文档可以包含多个字段。

Java中的ElasticSearch集成

在Java中集成ElasticSearch主要有两种方式：使用官方提供的ElasticSearch Java API和使用Spring Data ElasticSearch。

1. 使用ElasticSearch Java API

首先，我们需要添加ElasticSearch的依赖：

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

然后，创建ElasticSearch客户端：

import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestHighLevelClient;public class ElasticSearchClient {private static final String HOST = "localhost";private static final int PORT = 9200;public static RestHighLevelClient createClient() {return new RestHighLevelClient(RestClient.builder(new HttpHost(HOST, PORT, "http")));}
}

索引文档

import org.elasticsearch.action.index.IndexRequest;
import org.elasticsearch.action.index.IndexResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.common.xcontent.XContentType;public class ElasticSearchService {private final RestHighLevelClient client;public ElasticSearchService(RestHighLevelClient client) {this.client = client;}public void indexDocument(String index, String id, String jsonString) throws IOException {IndexRequest request = new IndexRequest(index).id(id).source(jsonString, XContentType.JSON);IndexResponse response = client.index(request, RequestOptions.DEFAULT);System.out.println(response.getResult().toString());}
}

查询文档

import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.search.builder.SearchSourceBuilder;public class ElasticSearchService {// Constructor and other methodspublic void searchDocument(String index, String field, String value) throws IOException {SearchRequest searchRequest = new SearchRequest(index);SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();searchSourceBuilder.query(QueryBuilders.matchQuery(field, value));searchRequest.source(searchSourceBuilder);SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);searchResponse.getHits().forEach(hit -> System.out.println(hit.getSourceAsString()));}
}

2. 使用Spring Data ElasticSearch

Spring Data ElasticSearch简化了ElasticSearch在Spring应用中的集成。首先，添加依赖：

<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-elasticsearch</artifactId><version>2.4.5</version>
</dependency>

配置ElasticSearch

在application.properties中配置ElasticSearch的连接信息：

spring.elasticsearch.rest.uris=http://localhost:9200

定义实体类和仓库接口

import org.springframework.data.annotation.Id;
import org.springframework.data.elasticsearch.annotations.Document;@Document(indexName = "product")
public class Product {@Idprivate String id;private String name;private double price;// Getters and setters
}import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;public interface ProductRepository extends ElasticsearchRepository<Product, String> {List<Product> findByName(String name);
}

使用仓库接口

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;@Service
public class ProductService {@Autowiredprivate ProductRepository productRepository;public void saveProduct(Product product) {productRepository.save(product);}public List<Product> findProductsByName(String name) {return productRepository.findByName(name);}
}