SpringCloud-深度理解ElasticSearch

Spring Cloud 和 ElasticSearch 的整合可以通过使用Spring Data ElasticSearch来实现。以下是一个简单的例子，展示如何在Spring Boot应用中配置和使用ElasticSearch。

1. 添加依赖到你的pom.xml：

<dependencies>
    <!-- Spring Boot Elasticsearch 支持 -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
    </dependency>
 
    <!-- Elasticsearch客户端 -->
    <dependency>
        <groupId>org.elasticsearch.client</groupId>
        <artifactId>elasticsearch-rest-high-level-client</artifactId>
        <version>7.10.0</version>
    </dependency>
</dependencies>

2. 配置application.properties或application.yml：

spring:
  elasticsearch:
    rest:
      uris: "http://localhost:9200" # Elasticsearch 节点地址
      username: "user" # 用户名
      password: "pass" # 密码

3. 创建一个实体类：

@Document(indexName = "your_index_name")
public class YourEntity {
    @Id
    private String id;
    // 其他属性
}

4. 创建一个Repository接口：

public interface YourEntityRepository extends ElasticsearchRepository<YourEntity, String> {
    // 自定义查询方法
}

5. 使用Repository进行操作：

@Service
public class YourService {
 
    @Autowired
    private YourEntityRepository repository;
 
    public YourEntity save(YourEntity entity) {
        return repository.save(entity);
    }
 
    public List<YourEntity> searchByName(String name) {
        // 使用ElasticsearchQueryBuilder构建查询
        QueryBuilder queryBuilder = QueryBuilders.matchQuery("name", name);
        Iterable<YourEntity> searchResult = repository.search(queryBuilder);
        // 转换为List
        List<YourEntity> resultList = StreamSupport.stream(searchResult.spliterator(), false)
                .collect(Collectors.toList());
        return resultList;
    }
}

以上代码展示了如何在Spring Boot应用中配置和使用ElasticSearch。你需要替换YourEntity和your_index_name为你自己的实体类和索引名称，并且实现自定义的搜索方法。