在 Spring Boot 3 与 Elasticsearch 8.x 的整合中，使用 Spring Data Elasticsearch 提供的 Repository 接口是一种非常高效和简洁的方法。以下是如何使用 Repository 进行操作的指南。

前置条件

1. Elasticsearch 8.x：确保已经安装并运行 Elasticsearch 8.x 实例。
2. Spring Boot 3：在 Spring Boot 项目中引入了必要的依赖。

引入依赖

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

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

配置 Elasticsearch

在 application.properties 或 application.yml 中添加 Elasticsearch 的基本配置：

spring.elasticsearch.uris=http://localhost:9200  
spring.elasticsearch.username=your-username  
spring.elasticsearch.password=your-password  

如果需要更复杂的配置（例如 SSL），请参考相关文档。

创建实体

创建一个与 Elasticsearch 索引对应的实体类，并使用注解进行配置。

import org.springframework.data.annotation.Id;  
import org.springframework.data.elasticsearch.annotations.Document;  
@Document(indexName = "products")  
public class Product {  
    @Id  
    private String id;  
    private String name;  
    private double price;  
    // Getters and setters  
}  

创建 Repository 接口

使用 Spring Data Elasticsearch 提供的 ElasticsearchRepository 接口，创建一个 Repository 接口来进行数据存取。

import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;  
public interface ProductRepository extends ElasticsearchRepository<Product, String> {  
    // 自定义查询方法  
    List<Product> findByName(String name);  
}  

使用 Repository

在服务层或控制器中，注入 ProductRepository，并使用其提供的方法对 Elasticsearch 数据进行操作。

import org.springframework.beans.factory.annotation.Autowired;  
import org.springframework.stereotype.Service;  
import java.util.List;  
@Service  
public class ProductService {  
    @Autowired  
    private ProductRepository productRepository;  
    public Product save(Product product) {  
        return productRepository.save(product);  
    }  
    public Product findById(String id) {  
        return productRepository.findById(id).orElse(null);  
    }  
    public List<Product> findByName(String name) {  
        return productRepository.findByName(name);  
    }  
    public void deleteById(String id) {  
        productRepository.deleteById(id);  
    }  
}  

测试

可以通过编写测试用例或直接在应用程序中调用 ProductService 的方法来验证与 Elasticsearch 的交互是否正常工作。例如，创建一些产品并查询它们。

import org.springframework.beans.factory.annotation.Autowired;  
import org.springframework.boot.CommandLineRunner;  
import org.springframework.stereotype.Component;  
@Component  
public class AppRunner implements CommandLineRunner {  
    @Autowired  
    private ProductService productService;  
    @Override  
    public void run(String... args) throws Exception {  
        // 创建并保存产品  
        Product product = new Product();  
        product.setName("Laptop");  
        product.setPrice(999.99);  
        productService.save(product);  
        // 查询产品  
        Product retrievedProduct = productService.findById(product.getId());  
        System.out.println("Retrieved Product: " + retrievedProduct.getName());  
        // 删除产品  
        productService.deleteById(product.getId());  
    }  
}  

通过以上步骤，你可以在 Spring Boot 3 项目中成功整合 Elasticsearch 8.x，并使用 Repository 方法高效地管理数据。确保在生产环境中考虑安全性和性能优化，如启用 SSL 和适当的索引设置。