SpringBoot中ElasticSearch动态创建索引

在Spring Boot中，要动态创建ElasticSearch索引，你可以使用Elasticsearch RestTemplate。以下是一个简单的例子，展示了如何在Spring Boot应用程序中创建一个新的索引：

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.elasticsearch.core.ElasticsearchRestTemplate;
import org.springframework.stereotype.Service;
import java.time.LocalDate;
 
@Service
public class ElasticsearchIndexService {
 
    @Autowired
    private ElasticsearchRestTemplate restTemplate;
 
    public void createIndexIfNotExists(String indexName) {
        // 使用ElasticsearchRestTemplate检查索引是否存在
        boolean indexExists = restTemplate.indexOps(Object.class).exists();
 
        if (!indexExists) {
            // 创建索引
            restTemplate.indexOps(Object.class).create();
            // 也可以自定义索引设置
            // restTemplate.indexOps(Object.class).createWithSettings();
        }
    }
}

在这个例子中，ElasticsearchRestTemplate用于与Elasticsearch集群交互。createIndexIfNotExists方法检查指定的索引是否存在，如果不存在，则创建一个新索引。

注意：这个例子假设你已经配置了ElasticsearchRestTemplate并且可以在Spring Boot应用程序中自动装配。此外，Object.class是作为索引操作的类型参数传递的，它应该替换为你的实际实体类。

确保在调用createIndexIfNotExists方法之前，你已经设置了Elasticsearch节点的信息，例如通过配置文件或者在配置类中：

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.elasticsearch.client.ClientConfiguration;
import org.springframework.data.elasticsearch.client.RestClients;
import org.springframework.data.elasticsearch.config.ElasticsearchConfiguration;
 
@Configuration
public class ElasticsearchConfig {
 
    @Bean
    public ClientConfiguration clientConfiguration() {
        return ClientConfiguration.builder()
                .connectedTo("localhost:9200") // 替换为你的Elasticsearch节点
                .build();
    }
 
    @Bean
    public ElasticsearchRestTemplate elasticsearchRestTemplate(ClientConfiguration clientConfiguration) {
        return new ElasticsearchRestTemplate(RestClients.create(clientConfiguration));
    }
}

在这个配置类中，你需要提供正确的Elasticsearch节点地址。这样，ElasticsearchRestTemplate就可以自动配置并注入到ElasticsearchIndexService中，以便进行索引操作。