使用 java 连接到 Secured Elastic Search

Question

我想连接我的安全ElasticSearch 并加载我的索引数据并将其存储在变量中。我在java 中找到了RestHighLevelClient，这有助于我连接弹性搜索。

这是代码：

import org.apache.http.HttpHost;
import org.elasticsearch.client.ElasticsearchClient;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestHighLevelClient;

public class ESConnect {
public static void main(String[] args){
    RestHighLevelClient client = new RestHighLevelClient(RestClient.builder(new HttpHost("localhost", 9200, "http")));
    System.out.println(client); 
}
}

Maven 依赖：

<dependency>
    <groupId>org.elasticsearch.client</groupId>
    <artifactId>elasticsearch-rest-high-level-client</artifactId>
    <version>7.5.2</version>
</dependency>

但我的ElasticSearch 受到username 和password 的保护。 Httphost 没有 username 和 password 参数。我找到了这个Secure connection using transport client。但是没有正确的答案来连接安全的ElasticSearch。所以我不知道如何使用 java 连接我的安全弹性搜索。接下来，我在ElasticSearch 中有一个名为football_data 的index。我想加载索引数据并将其存储在使用java 的变量中。帮助我连接到安全的elasticSearch 并使用java 加载索引数据。请为此提供一些解决方案。

Answer 1

由弹性搜索 docs 创建。你应该参考他们。现在执行以下操作...

final CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
credentialsProvider.setCredentials(AuthScope.ANY,
        new UsernamePasswordCredentials("user", "password"));

RestClientBuilder builder = RestClient.builder(new HttpHost("localhost", 9200))
        .setHttpClientConfigCallback(new RestClientBuilder.HttpClientConfigCallback() {
            @Override
            public HttpAsyncClientBuilder customizeHttpClient(HttpAsyncClientBuilder httpClientBuilder) {
                return httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider);
            }
        });

RestHighLevelClient client = new RestHighLevelClient(builder);

现在至于获取数据，您必须使用您想要的查询创建一个 searchRequest（如果数据超过 10000，我认为 Match 查询将使用滚动 api）。关注这个link。