如果我没有错,我们可以连接到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
发布于 2016-11-16 10:11:44
这种验证只是为了确保所有提供的主机都能被解析,它甚至不检查每台主机上是否运行着Cassandra服务器。因此,它基本上是为了确保您在提供主机时没有做任何键入操作,因为它实际上并不认为提供的主机不能被解决是一个正常的用例。
作为您的解决方案(主机已从DNS条目中删除),您可以简单地显式调用方法addContactPoint(String address),而不是使用addContactPoints(String... addresses) (场景后面的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:我刚刚创建了一张票据,以建议改进Java https://datastax-oss.atlassian.net/browse/JAVA-1334。
发布于 2016-11-15 20:51:16
正如Nick提到的,它基于DNS解析,而不是Cassandra服务器健康。
如果您比重新编译应用程序更频繁地从您的环境中删除主机,那么您应该考虑不要将您的联系人烘焙到代码中,而是通过其他一些方法(环境变量、REST服务、总是解析为一个活动种子的单个DNS名称等)将它们输入。
发布于 2016-09-28 21:36:41
那里的文档只是关于“解决”传入的联络点的问题。所以把主机名转换成ip地址。如果您首先指定ip地址,它们将不会被解析,只需检查有效性。如果您正在使用主机名,那么每个联系人都需要是可解析的。这并不意味着cassandra机器需要运行,只是主机名上的DNS查找返回任何ip地址。因此,如果您删除一个联系人的DNS条目并重新启动应用程序,情况就会中断。
https://stackoverflow.com/questions/39727744
复制相似问题