|
@@ -14,6 +14,7 @@ import org.apache.http.impl.client.BasicCredentialsProvider;
|
|
|
import org.apache.http.ssl.SSLContextBuilder;
|
|
|
import org.elasticsearch.client.RestClient;
|
|
|
import org.elasticsearch.client.RestClientBuilder;
|
|
|
+import org.springframework.beans.factory.annotation.Value;
|
|
|
import org.springframework.context.annotation.Bean;
|
|
|
import org.springframework.context.annotation.Configuration;
|
|
|
|
|
@@ -21,17 +22,18 @@ import javax.net.ssl.SSLContext;
|
|
|
|
|
|
|
|
|
@Configuration
|
|
|
-public class ElasticSearchClientConfig {
|
|
|
+public class ElasticSearchClientConfig {
|
|
|
//配置RestHighLevelClient依赖到spring容器中待用
|
|
|
-
|
|
|
+ @Value("${ES.config}")
|
|
|
+ private String config;
|
|
|
@Configuration
|
|
|
public class ElasticSearchConfig {
|
|
|
//注入IOC容器
|
|
|
@Bean
|
|
|
public ElasticsearchClient elasticsearchClient() throws Exception {
|
|
|
- RestClientBuilder builder = RestClient.builder(new HttpHost("192.168.1.24", 9200, "https"));
|
|
|
+ RestClientBuilder builder = RestClient.builder(new HttpHost(config, 9200, "http"));
|
|
|
CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
|
|
|
- credentialsProvider.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials("elastic", "xiaoshi221101"));
|
|
|
+ credentialsProvider.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials("elastic", "Xiaoshi221101"));
|
|
|
SSLContext sslContext = SSLContextBuilder.create()
|
|
|
.loadTrustMaterial(new TrustSelfSignedStrategy())
|
|
|
.build();
|