将 springboot java RestHighLevelClient 连接到 aws elasticsearch

编程问答 2022-04-30

问题描述

配置：

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'
}

在发布之前，我尝试了以下方法：

但它们都不起作用。

解决方法

有两种选择：

  1. 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);
                    }
                });
    }
  1. Spring yml：
elasticsearch:
  rest:
    uris: https://MyHost:9200
    username: arun
    password: mypassword
,

请查看 Spring Data Elasticsearch 文档，尤其是关于

amazon-elasticsearchjavajavaresthighlevelclientspring-data-elasticsearch