Datastax Java 如果缺少一台主机，则驱动程序无法连接

Question

如果我没记错的话，可以连接到至少知道集群中的一个节点的 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 driver: how many contact points is reasonable? 但这并没有回答我的问题，因为它没有说明无法访问的主机。

我该如何处理？也许这在另一个版本的 java 驱动程序中有所改变？我目前正在使用 cassandra-driver-core-3.0.3

Answer 1

那里的文档只是关于 "resolving" 传入的联系点。因此将主机名转换为 IP 地址。如果您一开始就指定了 ip 地址，它们将不会被解析，只是检查有效性。如果您使用主机名，那么每个联系点都需要是可解析的。这并不意味着 cassandra 机器需要运行，只是对主机名 returns 任何 IP 地址的 DNS 查找。因此，如果您删除其中一个联系点的 DNS 条目并重新启动您的应用程序，就会出现问题。

Answer 2

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

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

Answer 3

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

作为您的解决方法（主机已从 DNS 条目中删除），您可以简单地显式调用方法 addContactPoint(String address) 而不是使用 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。

Datastax Java 如果缺少一台主机，则驱动程序无法连接

Datastax Java Driver does not connect if one host is missing

java

cassandra

datastax