如果缺少一个主机,则Datastax Java Driver无法连接

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驱动程序:有多少接触点是合理的？ 但这并没有回答我的问题,因为它没有说出任何关于主机的信息,而无法达到.

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

Answer 1

此验证仅用于确保可以解析所有提供的主机,甚至不检查每台主机上是否正在运行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.