Datastax Java 驱动程序不连接，如果缺少一个主机

java cassandra datastax

2022-09-04 21:08:55

如果我没有记错的话，可以连接到Cassandra集群，知道集群中至少有一个节点，然后可以发现其他节点。

假设我有三个节点（1，2和3），我像这样连接到这些节点：

Cluster.builder().addContactPoints("1,2,3".split(",")).build();

然后，例如，如果节点 3 出现故障，并且无法解析 IP，则这行代码将抛出一个，如文档中所述：IllegalArgumentException

@throws IllegalArgumentException if no IP address for at least one of {@code addresses} could be found

为什么有人想要这种行为？我的意思是，如果其中一个节点关闭，我希望应用程序能够运行，因为Cassandra仍然工作正常。

我已经检查了这个Cassandra Java驱动程序：多少个联系点是合理的？但这并没有回答我的问题，因为它没有说任何关于主机的事情，而不是无法访问。

我应该如何处理这个问题？也许在另一个版本的java驱动程序中更改了这一点？我目前正在使用cassandra-driver-core-3.0.3

答案 1

此验证只是为了确保所有提供的主机都可以解析，它甚至不会检查Cassandra服务器是否在每个主机上运行。因此，这基本上是为了确保您在提供主机时没有做任何拼写错误，因为实际上它并不假设提供无法解析的主机可能是一个正常的用例。

作为您情况下的解决方法（主机已从DNS条目中删除），您可以简单地显式调用方法addContactPoint（字符串地址），而不是使用（在幕后简单地调用每个提供的地址）并自己管理异常。addContactPoints(String... addresses)addContactPoint(String address)

代码可能如下所示：

Cluster.Builder builder = Cluster.builder();
// Boolean used to check if at least one host could be resolved
boolean found = false;
for (String address : "1,2,3".split(",")) {
    try {
        builder.addContactPoint(address);
        // One host could be resolved
        found = true;
    } catch (IllegalArgumentException e) {
        // This host could not be resolved so we log a message and keep going
        Log.log(
            Level.WARNING, 
            String.format("The host '%s' is unknown so it will be ignored", address)
        );
    }
}
if (!found) {
    // No host could be resolved so we throw an exception
    throw new IllegalStateException("All provided hosts are unknown");
}
Cluster cluster = builder.build();

仅供参考：我刚刚创建了一个票证，以建议改进Java驱动程序 https://datastax-oss.atlassian.net/browse/JAVA-1334。

答案 2

正如Nick所提到的，它基于DNS解析，而不是Cassandra服务器运行状况。

如果从环境中删除主机的频率高于重新编译应用程序的频率，则应考虑不要将接触点烘焙到代码中，而是通过其他方式（环境变量、REST 服务、始终解析为一个活动种子的单个 DNS 名称等）将它们馈入。