package org.springblade.es.config; import org.springframework.beans.factory.annotation.Value; import org.apache.http.HttpHost; import org.elasticsearch.client.RestClient; import org.elasticsearch.client.RestClientBuilder; import org.elasticsearch.client.RestHighLevelClient; import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; @Configuration @ConditionalOnProperty(value = "elasticsearch.enabled") public class ElasticsearchConfig { @Value("${elasticsearch.host}") private String elasticsearchHost; @Bean public RestHighLevelClient elasticsearchClient() { RestClientBuilder builder = RestClient.builder(new HttpHost(elasticsearchHost, 9200, "http")); return new RestHighLevelClient(builder); } }