java - 将 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'
}
在发布此之前,我尝试了以下方法:
- 更好的 Elasticsearch 客户端从 JAVA Spring-boot 连接 AWS Elasticsearch
- 如何使用弹性 java 客户端与 aws elasticsearch 服务通信?
但他们都没有工作。
解决方案
有两种选择:
- 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);
}
});
}
- 春天yml:
elasticsearch:
rest:
uris: https://MyHost:9200
username: arun
password: mypassword
推荐阅读
- c++ - 将int值附加到字符串?
- swift - 为什么打印我的对象的一个实例,使其陷入无限循环,并因错误 EXC_BAD_ACCESS 而崩溃?
- node.js - Firebase-admin 处理多种环境
- javascript - 如何计算来自选择下拉字段的值?
- azure-service-fabric - Azure 服务结构 - 实例 VS 副本
- mongodb - MongoDB 在事先不知道所有字段的情况下聚合字段
- java - Freemarker:访问模板中没有getter的公共字段
- c++ - 双嵌套for循环中的访问冲突写入位置
- node.js - 完整的复杂 json 对象 $http.post 到 node.js 失败
- java - 如何解决:第一次调用 OnCreate() 时,我无法从 Retrofit Concrete Class 中检索数据