时间戳

首页 > 解决方案 > Elasticsearch 休息客户端 http over https 问题

rest - Elasticsearch 休息客户端 http over https 问题

问题描述

我正在尝试以下 API，

@Autowire private final RestHighLevelClient restHighLevelClient;
var restClient = restHighLevelClient.getLowLevelClient();
    Response response = null;
    try {
      var request = new Request("GET", "/_cat/indices?v&format=json");
      response = restClient.performRequest(request);
    } catch (IOException e) {
      log.warn(e.toString(), e);
    }

    var entity = response.getEntity();
    if (entity != null) {
      log.info("content:" + IOUtils.toString(entity.getContent(), StandardCharsets.UTF_8));
    }

elasticsearch服务器在https上运行，这是创建客户端的bean

@Bean(destroyMethod = "close")
  public RestHighLevelClient client() {
    var connUri = URI.create(esClusterUrl);
    String[] auth = connUri.getUserInfo().split(":");

    var credentialsProvider = new BasicCredentialsProvider();
    credentialsProvider.setCredentials(
        AuthScope.ANY, new UsernamePasswordCredentials(auth[0], auth[1]));

    var builder =
        RestClient.builder(new HttpHost(connUri.getHost(), connUri.getPort()))
            .setHttpClientConfigCallback(
                httpClientBuilder ->
                    httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider));
    return new RestHighLevelClient(builder);

我得到的错误响应是

2021-04-11 21:13:07.822  WARN 40680 --- [           main] com.document.feed.util.ESMaintenance     : org.elasticsearch.client.ResponseException: method [GET], host [http://yew-739425389.eu-west-1.bonsaisearch.net:443], URI [/_cat/indices?v&format=json], status line [HTTP/1.1 400 Bad Request]
<html>
<head><title>400 The plain HTTP request was sent to HTTPS port</title></head>
<body>
<center><h1>400 Bad Request</h1></center>
<center>The plain HTTP request was sent to HTTPS port</center>
</body>
</html>

这几乎是自我解释的，这意味着我应该对服务器进行 https 调用，而我正在进行 http rest 调用。分辨率是多少？

标签： restelasticsearchsslhttpsresthighlevelclient

解决方案

通过在构建客户端时切换到 https 方案来解决。

var builder =
        RestClient.builder(new HttpHost(connUri.getHost(), connUri.getPort(), "https"))
            .setHttpClientConfigCallback(
                httpClientBuilder ->
                    httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider));
    return new RestHighLevelClient(builder);

推荐阅读