如果我没有错,可以连接到一个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的改进.