java RestClientBuilder es 集群 鉴权

在Java中使用RestClientBuilder连接到Elasticsearch集群并进行鉴权，可以通过设置HttpHosts、RequestConfig以及添加相应的Header来实现。

以下是一个示例代码：

import org.apache.http.Header;

import org.apache.http.HttpHost;

import org.apache.http.auth.AuthScope;

import org.apache.http.auth.UsernamePasswordCredentials;

import org.apache.http.client.CredentialsProvider;

import org.apache.http.impl.client.BasicCredentialsProvider;

import org.elasticsearch.client.RestClient;

import org.elasticsearch.client.RestClientBuilder;

import org.elasticsearch.client.RestHighLevelClient;

import java.util.Collections;

public class ElasticsearchRestClient {

    public static void main(String[] args) throws Exception {

        final String elasticsearchUsername = "elastic";

        final String elasticsearchPassword = "changeme";

        final String elasticsearchHosts = "http://localhost:9200";

        // 创建CredentialsProvider

        CredentialsProvider credentialsProvider = new BasicCredentialsProvider();

        credentialsProvider.setCredentials(AuthScope.ANY,

                new UsernamePasswordCredentials(elasticsearchUsername, elasticsearchPassword));

        // 创建RestClientBuilder

        RestClientBuilder builder = RestClient.builder(new HttpHost(elasticsearchHosts, 9200, "http"))

                .setHttpClientConfigCallback(httpClientBuilder ->

                        httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider));

        // 创建高级RestClient

        RestHighLevelClient client = new RestHighLevelClient(builder);

        // 使用client进行操作...

        // 关闭client

        client.close();

    }

}

在这个示例中，我们首先创建了一个CredentialsProvider实例，并通过它添加了基本的身份验证信息。然后，我们使用RestClientBuilder并通过其setHttpClientConfigCallback方法设置了默认的CredentialsProvider。最后，我们创建了一个RestHighLevelClient实例，用于执行Elasticsearch相关操作。

请注意，这里的Elasticsearch集群地址、用户名和密码都是示例，您需要根据实际情况进行替换。