使用 Java 客户端和 X-Pack/HTTPS 连接到 ElasticSearch Cloud 5.x

Question

是否可以使用 X-Pack 通过 HTTPS 连接到 ElasticSearch？改用证书后，自己的连接方式就不行了。我对使用证书没问题，但我需要知道从哪里获得证书或将密钥上传到云实例，但我无法在任何地方找到信息。我也没有从论坛或 IRC 中的任何人那里得到任何答复。

有人成功过吗？启动 5.x 实例时不再有警告，所以我认为这是可能的，但我不知道该怎么做。我还被告知我无法再启动 2.4.1 实例并且只有 2.4.2 可用（到目前为止太不稳定）所以我有点无法启动可用实例。

更新

有人告诉我不需要证书，因为正在使用 public CA。但是，我仍然无法弄清楚如何连接到 5.1.1 实例。

Settings settings = Settings.builder()
            .put("transport.ping_schedule", "5s")
            .put("cluster.name", "<cluster_id>")
            .put("xpack.security.transport.ssl.enabled", "true")
            .put("xpack.security.user", "elastic:<password_from_cluster_creation>")
            .build();

    String hostname = "<cluster_id>.us-east-1.aws.found.io";
    TransportClient client = new PreBuiltXPackTransportClient(settings)
        .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName(hostname), 9343));

我在这里做错了什么？我收到一条错误消息，指出节点不可用。

Exception in thread "main" NoNodeAvailableException[None of the configured nodes are available: [{#transport#-1}{xlhZqKBCQniYrN4OWzByFQ}{<cluster_id>.us-east-1.aws.found.io}{<id_address>:9343}]]

我也试过创建一个具有 transport_client 角色的用户，但还是一样的错误。

更新 2

我尝试了此处的示例代码，但仍然无法正常工作。

https://github.com/elastic/found-shield-example/blob/master/src/main/java/org/elasticsearch/cloud/transport/example/TransportExample.java

这是一个您可以用来测试的实例。等我弄清楚问题再销毁。

更新 3

我发现了问题并销毁了测试集群。在下面找到解决方案。

Answer 1

在 ES 论坛上与人们讨论后，我终于让它工作了。当您运行遇到连接问题时，这里有一些提示：

1) 您可能没有在 header 中添加它，因为文档中没有提到它

.put("request.headers.X-Found-Cluster", clusterName)

2) 如果仍然无效，请使用此处的示例代码验证您的主机名是否正确以及您是否拥有正确的凭据

https://github.com/elastic/found-shield-example#running

3) 如果您尝试运行 Eclipse 中的示例代码，请在您运行之前替换 ${cluster.name} 否则它不会工作。

希望这可以帮助人们节省一些时间来解决连接问题。连接到 ES 5.x 与 2.x 一样简单。问题是文档不清晰，没有link sample client

Answer 2

我之前遇到过同样的问题，我使用以下配置解决了它

所需的依赖项：

(transport和x-pack-transport应该有相同版本的elasticsearch 5.5.3)

<dependencies>
    <dependency>
        <groupId>org.springframework.data</groupId>
        <artifactId>spring-data-elasticsearch</artifactId>
        <version>3.0.5.RELEASE</version>
    </dependency>
    <dependency>
        <groupId>org.elasticsearch.client</groupId>
        <artifactId>transport</artifactId>
        <version>5.5.3</version>
    </dependency>
    <!--add the x-pack jar as a dependency-->
    <dependency>
        <groupId>org.elasticsearch.client</groupId>
        <artifactId>x-pack-transport</artifactId>
        <version>5.5.3</version>
    </dependency>
</dependencies>

<repositories>
    <!-- add the elasticsearch repo -->
    <repository>
        <id>elasticsearch-releases</id>
        <url>https://artifacts.elastic.co/maven</url>
        <releases>
            <enabled>true</enabled>
        </releases>
        <snapshots>
            <enabled>false</enabled>
        </snapshots>
    </repository>
</repositories>

Java 配置：

@Value("${elasticsearch.cluster.url}")
private String elasticsearchClusterUrl;

@Value("${elasticsearch.cluster.port}")
private int elasticsearchClusterPort;

@Value("${elasticsearch.cluster.name}")
private String elasticsearchClusterName;

@Value("${elasticsearch.cluster.credentials}")
private String elasticsearchCredentials;

@Bean
public TransportClient elasticsearchClient()
        throws Exception {

    Settings settings = Settings.builder()
            .put("cluster.name", elasticsearchClusterName)
            .put("request.headers.X-Found-Cluster", elasticsearchClusterName)
            .put("xpack.security.transport.ssl.enabled", true)
            .put("xpack.security.user", elasticsearchCredentials)
            .build();

    return new PreBuiltXPackTransportClient(settings)
            .addTransportAddress(new InetSocketTransportAddress(new InetSocketAddress(elasticsearchClusterUrl, elasticsearchClusterPort)));
}

application.yml:

elasticsearch:
  index: dev_index
  cluster:
    name: 2083ddf0fbf5a3b1f0c50ff257ded077
    url: 2083ddf0fbf5a3b1f0c50ff257ded077.eu-west-1.aws.found.io
    port: 9343
    credentials: elastic:pass

使用 Java 客户端和 X-Pack/HTTPS 连接到 ElasticSearch Cloud 5.x

Connecting to ElasticSearch Cloud 5.x with Java Client and X-Pack/HTTPS

java

elasticsearch

https

certificate

xpack

更新

更新 2

更新 3