作者 王勇

将es环境放到application.yml文件中

@@ -102,6 +102,11 @@ management: @@ -102,6 +102,11 @@ management:
102 shutdown: 102 shutdown:
103 enabled: true 103 enabled: true
104 104
  105 +es:
  106 + hostname: 192.168.37.139
  107 + port: 9200
  108 + scheme: http
  109 +
105 # 基础信息配置 110 # 基础信息配置
106 info: 111 info:
107 version: 1.0 112 version: 1.0
@@ -3,6 +3,7 @@ package com.sunyo.wlpt.message.bus.service.config; @@ -3,6 +3,7 @@ package com.sunyo.wlpt.message.bus.service.config;
3 import org.apache.http.HttpHost; 3 import org.apache.http.HttpHost;
4 import org.elasticsearch.client.RestClient; 4 import org.elasticsearch.client.RestClient;
5 import org.elasticsearch.client.RestHighLevelClient; 5 import org.elasticsearch.client.RestHighLevelClient;
  6 +import org.springframework.beans.factory.annotation.Value;
6 import org.springframework.context.annotation.Bean; 7 import org.springframework.context.annotation.Bean;
7 import org.springframework.context.annotation.Configuration; 8 import org.springframework.context.annotation.Configuration;
8 import org.springframework.data.elasticsearch.config.AbstractElasticsearchConfiguration; 9 import org.springframework.data.elasticsearch.config.AbstractElasticsearchConfiguration;
@@ -16,23 +17,24 @@ import org.springframework.data.elasticsearch.core.ElasticsearchRestTemplate; @@ -16,23 +17,24 @@ import org.springframework.data.elasticsearch.core.ElasticsearchRestTemplate;
16 @Configuration 17 @Configuration
17 public class ElasticSearchConfig extends AbstractElasticsearchConfiguration { 18 public class ElasticSearchConfig extends AbstractElasticsearchConfiguration {
18 19
19 - 20 + @Value("${es.hostname}")
20 private String hostname; 21 private String hostname;
21 22
  23 + @Value("${es.port}")
22 private Integer port; 24 private Integer port;
23 25
  26 + @Value("${es.scheme}")
24 private String scheme; 27 private String scheme;
25 28
26 29
27 @Override 30 @Override
28 @Bean 31 @Bean
29 -  
30 public RestHighLevelClient elasticsearchClient() 32 public RestHighLevelClient elasticsearchClient()
31 { 33 {
32 RestHighLevelClient client = new RestHighLevelClient( 34 RestHighLevelClient client = new RestHighLevelClient(
33 RestClient.builder( 35 RestClient.builder(
34 // 天生契合集群,有几个es环境,就 new HttpHost 几个,用,相隔 36 // 天生契合集群,有几个es环境,就 new HttpHost 几个,用,相隔
35 - new HttpHost("192.168.37.139", 9200, "http") 37 + new HttpHost(hostname, port, scheme)
36 ) 38 )
37 ); 39 );
38 return client; 40 return client;