springboot集成es代码示例

以下是一个简单的示例，演示如何在 Spring Boot 应用程序中使用 Elasticsearch：

1. 添加依赖

在 pom.xml 文件中添加以下依赖：

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

2. 配置 Elasticsearch

在 application.properties 文件中添加以下配置：

spring.data.elasticsearch.cluster-name=my-application
spring.data.elasticsearch.cluster-nodes=localhost:9300

3. 创建 Elasticsearch 实体类

@Document(indexName = "my_index", type = "my_type")
public class MyEntity {

    @Id
    private String id;

    @Field(type = FieldType.Text)
    private String name;

    // getter and setter methods
}

4. 创建 Elasticsearch 存储库接口

@Repository
public interface MyEntityRepository extends ElasticsearchRepository<MyEntity, String> {
}

5. 使用 Elasticsearch 存储库

@Service
public class MyService {

    @Autowired
    private MyEntityRepository repository;

    public void save(MyEntity entity) {
        repository.save(entity);
    }

    public List<MyEntity> search(String text) {
        SearchQuery searchQuery = new NativeSearchQueryBuilder()
                .withQuery(QueryBuilders.matchQuery("name", text))
                .build();
        return repository.search(searchQuery).toList();
    }
}

以上示例演示了如何在 Spring Boot 应用程序中使用 Elasticsearch。你可以根据自己的需要进行修改和扩展。