<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
</dependency>
<!-- 可選：使用 Elasticsearch 高級(jí)客戶端 -->
<dependency>
    <groupId>org.elasticsearch.client</groupId>
    <artifactId>elasticsearch-rest-high-level-client</artifactId>
    <version>8.0.0</version>
</dependency>

spring:
  elasticsearch:
    uris: https://localhost:9200
    username: elastic
    password: your-password
    connection-timeout: 10000
    socket-timeout: 10000

@Configuration
public class ElasticsearchConfig {
    @Bean
    public RestHighLevelClient elasticsearchClient() {
        ClientConfiguration clientConfiguration = ClientConfiguration.builder()
            .connectedTo("localhost:9200")
            .withBasicAuth("elastic", "your-password")
            .withConnectTimeout(Duration.ofSeconds(10))
            .withSocketTimeout(Duration.ofSeconds(10))
            .withTls()
            .build();
        return RestClients.create(clientConfiguration).rest();
    }
}

@Document(indexName = "users")
public class User {
    @Id
    private String id;
    @Field(type = FieldType.Text)
    private String name;
    @Field(type = FieldType.Integer)
    private int age;
    @Field(type = FieldType.Text, analyzer = "ik_max_word")
    private String address;
    @Field(type = FieldType.Date)
    private LocalDateTime createdAt;
    // getters and setters
}

@Document(indexName = "products")
public class Product {
    @Id
    private String id;
    @Field(type = FieldType.Text)
    private String name;
    @Field(type = FieldType.Double)
    private double price;
    @Field(type = FieldType.Keyword)
    private String category;
    @Field(type = FieldType.Nested)
    private List<Review> reviews;
    @Field(type = FieldType.Object)
    private Manufacturer manufacturer;
    // getters and setters
}
public class Review {
    @Field(type = FieldType.Integer)
    private int rating;
    @Field(type = FieldType.Text)
    private String comment;
    @Field(type = FieldType.Date)
    private LocalDateTime createdAt;
    // getters and setters
}
public class Manufacturer {
    @Field(type = FieldType.Text)
    private String name;
    @Field(type = FieldType.Text)
    private String country;
    // getters and setters
}

public interface UserRepository extends ElasticsearchRepository<User, String> {
    // 基于方法名的查詢
    List<User> findByName(String name);
    List<User> findByAgeBetween(int minAge, int maxAge);
    List<User> findByNameAndAge(String name, int age);
}

public interface ProductRepository extends ElasticsearchRepository<Product, String> {
    // 使用 @Query 注解
    @Query("{\"bool\": {\"must\": [{\"match\": {\"name\": \"?0\"}}, {\"range\": {\"price\": {\"lte\": ?1}}}]}}")
    List<Product> findByNameAndPriceLessThanEqual(String name, double price);
    // 基于方法名的復(fù)雜查詢
    List<Product> findByCategoryAndReviewsRatingGreaterThan(String category, int rating);
}

@Service
public class UserService {
    private final UserRepository userRepository;
    @Autowired
    public UserService(UserRepository userRepository) {
        this.userRepository = userRepository;
    }
    // 保存用戶
    public User saveUser(User user) {
        return userRepository.save(user);
    }
    // 根據(jù) ID 查詢用戶
    public Optional<User> getUserById(String id) {
        return userRepository.findById(id);
    }
    // 查詢所有用戶
    public Iterable<User> getAllUsers() {
        return userRepository.findAll();
    }
    // 刪除用戶
    public void deleteUser(String id) {
        userRepository.deleteById(id);
    }
    // 根據(jù)名稱查詢用戶
    public List<User> getUsersByName(String name) {
        return userRepository.findByName(name);
    }
}

@Service
public class ProductService {
    private final ProductRepository productRepository;
    private final ElasticsearchOperations elasticsearchOperations;
    @Autowired
    public ProductService(ProductRepository productRepository, ElasticsearchOperations elasticsearchOperations) {
        this.productRepository = productRepository;
        this.elasticsearchOperations = elasticsearchOperations;
    }
    // 復(fù)雜查詢
    public List<Product> searchProducts(String keyword, double maxPrice, String category) {
        NativeSearchQuery query = new NativeSearchQueryBuilder()
            .withQuery(QueryBuilders.boolQuery()
                .must(QueryBuilders.multiMatchQuery(keyword, "name", "description"))
                .filter(QueryBuilders.rangeQuery("price").lte(maxPrice))
                .filter(QueryBuilders.termQuery("category", category)))
            .withSort(SortBuilders.fieldSort("price").order(SortOrder.ASC))
            .withPageable(PageRequest.of(0, 10))
            .build();
        return elasticsearchOperations.search(query, Product.class)
            .stream()
            .map(SearchHit::getContent)
            .collect(Collectors.toList());
    }
}

@Service
public class AnalyticsService {
    private final ElasticsearchOperations elasticsearchOperations;
    
    @Autowired
    public AnalyticsService(ElasticsearchOperations elasticsearchOperations) {
        this.elasticsearchOperations = elasticsearchOperations;
    }
    
    // 按類別聚合產(chǎn)品
    public Map<String, Long> getProductCountByCategory() {
        NativeSearchQuery query = new NativeSearchQueryBuilder()
            .withQuery(QueryBuilders.matchAllQuery())
            .withAggregations(AggregationBuilders.terms("byCategory").field("category"))
            .build();
        
        SearchHits<Product> searchHits = elasticsearchOperations.search(query, Product.class);
        Terms terms = searchHits.getAggregations().get("byCategory");
        
        Map<String, Long> result = new HashMap<>();
        for (Terms.Bucket bucket : terms.getBuckets()) {
            result.put(bucket.getKeyAsString(), bucket.getDocCount());
        }
        
        return result;
    }
    
    // 計(jì)算平均價(jià)格
    public double getAveragePrice() {
        NativeSearchQuery query = new NativeSearchQueryBuilder()
            .withQuery(QueryBuilders.matchAllQuery())
            .withAggregations(AggregationBuilders.avg("averagePrice").field("price"))
            .build();
        
        SearchHits<Product> searchHits = elasticsearchOperations.search(query, Product.class);
        Avg avg = searchHits.getAggregations().get("averagePrice");
        
        return avg.getValue();
    }
}

@Service
public class BulkService {
    private final ElasticsearchOperations elasticsearchOperations;
    @Autowired
    public BulkService(ElasticsearchOperations elasticsearchOperations) {
        this.elasticsearchOperations = elasticsearchOperations;
    }
    // 批量索引文檔
    public void bulkIndex(List<User> users) {
        elasticsearchOperations.bulkIndex(users, IndexCoordinates.of("users"));
    }
    // 批量刪除文檔
    public void bulkDelete(List<String> ids) {
        List<DeleteQuery> deleteQueries = ids.stream()
            .map(id -> {
                DeleteQuery deleteQuery = new DeleteQuery();
                deleteQuery.setId(id);
                return deleteQuery;
            })
            .collect(Collectors.toList());
        elasticsearchOperations.bulkDelete(deleteQueries, User.class, IndexCoordinates.of("users"));
    }
}

// 推薦的代碼組織結(jié)構(gòu)
com.example
├── entity/          // 實(shí)體類
├── repository/      // 倉庫接口
├── service/         // 業(yè)務(wù)邏輯
├── controller/      // 控制器
└── config/          // 配置類

@Service
public class UserService {
    private final UserRepository userRepository;
    @Autowired
    public UserService(UserRepository userRepository) {
        this.userRepository = userRepository;
    }
    public User getUserById(String id) {
        try {
            return userRepository.findById(id)
                .orElseThrow(() -> new EntityNotFoundException("User not found"));
        } catch (ElasticsearchException e) {
            throw new RuntimeException("Error querying Elasticsearch", e);
        }
    }
}

management:
  endpoints:
    web:
      exposure:
        include: health,info,metrics,prometheus
  endpoint:
    health:
      show-details: always
logging:
  level:
    org.elasticsearch.client: debug