当单个客户端节点出现故障时，Elasticsearch 客户端不会获取结果

Question

我们有一个非常标准的弹性搜索设置，有 3 个主节点、6 个数据节点和 3 个客户端节点。这是我们从 Java 应用程序连接到 Elasticsearch 客户端的连接代码。

    Settings settings = Settings.settingsBuilder()
            .put("cluster.name", configuration.getString("clusterName"))
            .put("client.transport.sniff", false)
            .put("client.transport.ping_timeout", "5s")
            .build();

    TransportClient client = TransportClient.builder().settings(settings).build();

    for (String hostname : (Collection<String>)configuration.get("hostnames")){
        try {
            client = client.addTransportAddresses(
                    new InetSocketTransportAddress(InetAddress.getByName(hostname), 9300)
            );
            break;
        } catch (UnknownHostException e) {
            e.printStackTrace();
        }
    }

我们目前在主机名列表中有三个不同的主机。但是，只要此主机名列表中的单个客户端出现故障，此 Elasticsearch 传输客户端就会停止响应。我已经浏览了 Elasticsearch 站点上的传输客户端文档，并且还尝试查看他们的 Github 问题，据此，每当一个节点出现故障时，只有 elasticsearch 应该将其从节点列表中删除并继续与其他节点合作，但在我们的情况下，事情只是分解。任何人都知道可能是什么问题？ 我们现在使用的是 elasticsearch 2.4.3。

Answer 1

在添加单个节点后，您似乎正在中断循环。尝试删除 break 语句：

for (String hostname : (Collection<String>)configuration.get("hostnames")){
        try {
            client = client.addTransportAddresses(
                    new InetSocketTransportAddress(InetAddress.getByName(hostname), 9300)
            );
        } catch (UnknownHostException e) {
            e.printStackTrace();
        }
    }