如何解决将 springboot java RestHighLevelClient 连接到 aws elasticsearch
配置:
private static final String HOST = "search-qas-sam-zxbalglrksamjfcazl3zmkiiq7.ap-south-1.es.amazonaws.com";
private static final int PORT = 443; // tries 9200,9300,80
private static final String PROTOCOL = "https";
@Bean
public RestHighLevelClient client() {
final CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
credentialsProvider.setCredentials(AuthScope.ANY,new UsernamePasswordCredentials("myusername","mypassword"));
RestClientBuilder builder = RestClient.builder(new HttpHost( HOST,PORT,PROTOCOL))
.setHttpClientConfigCallback(new RestClientBuilder.HttpClientConfigCallback() {
@Override
public HttpAsyncclientBuilder customizeHttpClient(HttpAsyncclientBuilder httpClientBuilder) {
return httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider);
}
});
当连接到我本地机器上的 ElasticSearch 时,它运行在 localhost 和端口 9200 上。
但是当尝试连接到 AWS 时,它给出了以下错误:
Caused by: org.springframework.data.elasticsearch.client.noreachableHostException: Host 'localhost:9200'
此外,如果我在浏览器中打开我的 AWS ElasticSearch,其状态显示为:
{
"name" : "asjsbsghjmnkl1f05283a21d38yh9ij","cluster_name" : "5583974864:qas","cluster_uuid" : "8wWV8ujji9kbzg","version" : {
"number" : "7.10.2","build_flavor" : "oss","build_type" : "tar","build_hash" : "unkNown","build_date" : "2021-04-21T04:22:10.395481Z","build_snapshot" : false,"lucene_version" : "8.7.0","minimum_wire_compatibility_version" : "6.8.0","minimum_index_compatibility_version" : "6.0.0-beta1"
},"tagline" : "You KNow,for Search"
}
将 spring-boot
2.4.5 与 spring-data-elasticsearch
一起使用:
implementation ('org.springframework.data:spring-data-elasticsearch') {
exclude group: 'org.apache.lucene'
}
在发布之前,我尝试了以下方法:
- Better Elasticsearch client to connect AWS Elasticsearch from JAVA Spring-boot
- How to talk to aws elasticsearch service using elastic java client?
但它们都不起作用。
解决方法
有两种选择:
- Java 配置:
@Configuration
@EnableElasticsearchRepositories(basePackages = "com.arun.elasticsearch.repository")
@ComponentScan(basePackages = { "com.arun.elasticsearch.service" })
public class ElasticSearchConfig {
private static final String HOST = "aws_host"; // localhost
private static final int PORT = 443; // 9092
private static final String PROTOCOL = "https"; // http
@Bean
public RestHighLevelClient client() {
final CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
credentialsProvider.setCredentials(AuthScope.ANY,new UsernamePasswordCredentials("UserName","Password"));
RestClientBuilder builder = RestClient.builder(new HttpHost( HOST,PORT,PROTOCOL))
.setHttpClientConfigCallback(new RestClientBuilder.HttpClientConfigCallback() {
@Override
public HttpAsyncClientBuilder customizeHttpClient(HttpAsyncClientBuilder httpClientBuilder) {
return httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider);
}
});
}
- Spring yml:
elasticsearch:
rest:
uris: https://MyHost:9200
username: arun
password: mypassword
,
请查看 Spring Data Elasticsearch 文档,尤其是关于
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。