|
@@ -27,19 +27,19 @@ public class ElasticSearchClientConfig {
|
|
|
@Configuration
|
|
|
public class ElasticSearchConfig {
|
|
|
//注入IOC容器
|
|
|
- @Bean
|
|
|
- public ElasticsearchClient elasticsearchClient() throws Exception {
|
|
|
- RestClientBuilder builder = RestClient.builder(new HttpHost("es-cn-em93o8856000ho9e7.public.elasticsearch.aliyuncs.com", 9200, "http"));
|
|
|
- CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
|
|
|
- credentialsProvider.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials("elastic", "Xiaoshi221101"));
|
|
|
- SSLContext sslContext = SSLContextBuilder.create()
|
|
|
- .loadTrustMaterial(new TrustSelfSignedStrategy())
|
|
|
- .build();
|
|
|
- builder.setHttpClientConfigCallback(f -> f.setDefaultCredentialsProvider(credentialsProvider).setSSLContext(sslContext).setSSLHostnameVerifier(new NoopHostnameVerifier()));
|
|
|
- RestClient client =builder.build();
|
|
|
- ElasticsearchTransport transport = new RestClientTransport(client,new JacksonJsonpMapper());
|
|
|
- return new ElasticsearchClient(transport);
|
|
|
- }
|
|
|
+// @Bean
|
|
|
+// public ElasticsearchClient elasticsearchClient() throws Exception {
|
|
|
+// RestClientBuilder builder = RestClient.builder(new HttpHost("es-cn-em93o8856000ho9e7.public.elasticsearch.aliyuncs.com", 9200, "http"));
|
|
|
+// CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
|
|
|
+// credentialsProvider.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials("elastic", "Xiaoshi221101"));
|
|
|
+// SSLContext sslContext = SSLContextBuilder.create()
|
|
|
+// .loadTrustMaterial(new TrustSelfSignedStrategy())
|
|
|
+// .build();
|
|
|
+// builder.setHttpClientConfigCallback(f -> f.setDefaultCredentialsProvider(credentialsProvider).setSSLContext(sslContext).setSSLHostnameVerifier(new NoopHostnameVerifier()));
|
|
|
+// RestClient client =builder.build();
|
|
|
+// ElasticsearchTransport transport = new RestClientTransport(client,new JacksonJsonpMapper());
|
|
|
+// return new ElasticsearchClient(transport);
|
|
|
+// }
|
|
|
// @Bean
|
|
|
// public ElasticsearchClient elasticsearchClient() throws Exception {
|
|
|
// RestClientBuilder builder = RestClient.builder(new HttpHost("47.101.137.223", 9200, "http"));
|
|
@@ -64,18 +64,18 @@ public class ElasticSearchClientConfig {
|
|
|
// return new ElasticsearchClient(transport);
|
|
|
// }
|
|
|
//
|
|
|
-// @Bean
|
|
|
-// public ElasticsearchClient elasticsearchClient() throws Exception {
|
|
|
-// RestClientBuilder builder = RestClient.builder(new HttpHost("es-cn-em93o8856000ho9e7.elasticsearch.aliyuncs.com", 9200, "http"));
|
|
|
-// CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
|
|
|
-// credentialsProvider.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials("elastic", "Xiaoshi221101"));
|
|
|
-// SSLContext sslContext = SSLContextBuilder.create()
|
|
|
-// .loadTrustMaterial(new TrustSelfSignedStrategy())
|
|
|
-// .build();
|
|
|
-// builder.setHttpClientConfigCallback(f -> f.setDefaultCredentialsProvider(credentialsProvider).setSSLContext(sslContext).setSSLHostnameVerifier(new NoopHostnameVerifier()));
|
|
|
-// RestClient client =builder.build();
|
|
|
-// ElasticsearchTransport transport = new RestClientTransport(client,new JacksonJsonpMapper());
|
|
|
-// return new ElasticsearchClient(transport);
|
|
|
-// }
|
|
|
+ @Bean
|
|
|
+ public ElasticsearchClient elasticsearchClient() throws Exception {
|
|
|
+ RestClientBuilder builder = RestClient.builder(new HttpHost("es-cn-em93o8856000ho9e7.elasticsearch.aliyuncs.com", 9200, "http"));
|
|
|
+ CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
|
|
|
+ credentialsProvider.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials("elastic", "Xiaoshi221101"));
|
|
|
+ SSLContext sslContext = SSLContextBuilder.create()
|
|
|
+ .loadTrustMaterial(new TrustSelfSignedStrategy())
|
|
|
+ .build();
|
|
|
+ builder.setHttpClientConfigCallback(f -> f.setDefaultCredentialsProvider(credentialsProvider).setSSLContext(sslContext).setSSLHostnameVerifier(new NoopHostnameVerifier()));
|
|
|
+ RestClient client =builder.build();
|
|
|
+ ElasticsearchTransport transport = new RestClientTransport(client,new JacksonJsonpMapper());
|
|
|
+ return new ElasticsearchClient(transport);
|
|
|
+ }
|
|
|
}
|
|
|
}
|