Spring Boot使用ElasticSearch

在Spring Boot中集成Elasticsearch可以让你的应用程序轻松地利用到全文搜索、实时分析和数据可视化等功能。

1. 添加依赖

首先，在你的pom.xml或build.gradle文件中添加Elasticsearch的依赖。如果你使用的是Maven，可以添加如下依赖：

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

如果你使用的是Gradle，可以添加如下依赖：

implementation 'org.springframework.boot:spring-boot-starter-data-elasticsearch'

2. 配置Elasticsearch

在application.properties或application.yml文件中配置Elasticsearch的连接信息。例如：

# application.properties
spring.data.elasticsearch.cluster-nodes=localhost:9300
spring.data.elasticsearch.repositories.enabled=true

或者在application.yml中：

spring:
  data:
    elasticsearch:
      cluster-nodes: localhost:9300
      repositories:
        enabled: true

确保你的Elasticsearch服务正在运行，并且可以在指定的端口上访问。

3. 创建Repository

使用Spring Data Elasticsearch的Repository接口来操作Elasticsearch中的数据。首先，定义一个实体类，然后创建一个Repository接口继承自ElasticsearchRepository。

实体类

import org.springframework.data.annotation.Id;
import org.springframework.data.elasticsearch.annotations.Document;

@Document(indexName = "users")
public class User {

    @Id
    private String id;
    private String name;
    private int age;

    // getters and setters
}

Repository接口

import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;

public interface UserRepository extends ElasticsearchRepository<User, String> {
}

4. 使用Repository

现在，你可以在你的Service层中注入UserRepository并使用它来执行CRUD操作和其他查询。

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

@Service
public class UserService {

    @Autowired
    private UserRepository userRepository;

    public void save(User user) {
        userRepository.save(user);
    }

    public User findById(String id) {
        return userRepository.findById(id).orElse(null);
    }
}

5. 高级查询

Spring Data Elasticsearch还支持复杂的查询，如全文搜索、聚合等，可以通过@Query注解来实现。

import org.springframework.data.elasticsearch.core.query.NativeSearchQueryBuilder;
import org.springframework.data.elasticsearch.core.query.SearchQuery;

public List<User> searchByName(String name) {
    SearchQuery query = new NativeSearchQueryBuilder()
            .withQuery(QueryBuilders.matchQuery("name", name))
            .build();
    return userRepository.search(query);
}

以上就是Spring Boot集成Elasticsearch的基本步骤。根据你的具体需求，可能还需要进行更详细的配置和编码。