Spring Boot整合Elasticsearch

Spring Boot整合Elasticsearch是一个相对简单的过程，可以通过以下步骤来完成：

1. 添加依赖

首先，在你的pom.xml文件中添加Spring Boot和Elasticsearch的依赖。

<dependencies>
    <!-- Spring Boot Starter Data Elasticsearch -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
    </dependency>

    <!-- Elasticsearch Client -->
    <dependency>
        <groupId>org.elasticsearch.client</groupId>
        <artifactId>elasticsearch-java</artifactId>
    </dependency>

    <!-- Spring Boot Starter Web for RESTful services -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
</dependencies>

2. 配置Elasticsearch

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

application.properties

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

application.yml

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

3. 创建Elasticsearch Repository

创建一个接口来定义对Elasticsearch的操作。

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

@Repository
public interface MyDocumentRepository extends ElasticsearchRepository<MyDocument, String> {
}

4. 创建Elasticsearch实体类

创建一个实体类来映射到Elasticsearch的文档。

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

@Document(indexName = "my_documents")
public class MyDocument {

    @Id
    private String id;

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

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

    // Getters and Setters
}

5. 使用Repository进行操作

在你的服务或控制器中使用MyDocumentRepository进行CRUD操作。

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

@Service
public class MyDocumentService {

    @Autowired
    private MyDocumentRepository repository;

    public MyDocument saveDocument(MyDocument document) {
        return repository.save(document);
    }

    public List<MyDocument> findAllDocuments() {
        return repository.findAll();
    }

    public MyDocument findDocumentById(String id) {
        return repository.findById(id).orElse(null);
    }

    public void deleteDocument(String id) {
        repository.deleteById(id);
    }
}

6. 创建控制器

创建一个控制器来提供RESTful API接口。

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;

import java.util.List;

@RestController
@RequestMapping("/documents")
public class MyDocumentController {

    @Autowired
    private MyDocumentService service;

    @PostMapping
    public MyDocument saveDocument(@RequestBody MyDocument document) {
        return service.saveDocument(document);
    }

    @GetMapping
    public List<MyDocument> findAllDocuments() {
        return service.findAllDocuments();
    }

    @GetMapping("/{id}")
    public MyDocument findDocumentById(@PathVariable String id) {
        return service.findDocumentById(id);
    }

    @DeleteMapping("/{id}")
    public void deleteDocument(@PathVariable String id) {
        service.deleteDocument(id);
    }
}

7. 启动应用

启动你的Spring Boot应用，然后访问Elasticsearch的REST API来验证整合是否成功。

curl -X POST "http://localhost:8080/documents" -H 'Content-Type: application/json' -d'
{
    "title": "Sample Document",
    "content": "This is a sample document for Elasticsearch integration."
}'

通过以上步骤，你就可以成功地在Spring Boot应用中整合Elasticsearch，并提供基本的CRUD操作。