如果一个主机丢失,Datastax Java驱动程序不会连接

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

假设我有三个节点(1,2和3),我连接到这些节点,如下所示：

.Cluster.builder()addContactPoints( “1,2,3” .split( “”))构建();

然后,如果节点3例如下降,并且IP无法解析,则该行代码将抛出一个IllegalArgumentException,如文档中所述：

@throws IllegalArgumentException,如果没有找到至少一个{@code地址}的IP地址

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

我已经检查了这个Cassandra Java driver: how many contact points is reasonable?
但是这并不能回答我的问题,因为它不能说任何关于主机的问题,因为它不能达到目的.

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

解决方法

此验证只是为了确保所有提供的主机都可以解决,甚至不检查Cassandra服务器是否在每个主机上运行.所以它基本上是确保你在提供主机时没有做任何打字错误,因为它并不认为这是正常的用例来提供一个无法解析的提供的主机.

作为您的情况(主机已从DNS条目中删除)的解决方法,您可以直接调用方法addContactPoint(String address)而不是使用addContactPoints(String …地址)(其中后面的场景简单地为每个提供的地址调用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,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();

FYI：我刚刚创建了一个机票来提出Java驱动程序https://datastax-oss.atlassian.net/browse/JAVA-1334的改进.