首页 文章

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

提问于
浏览 次
10

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

假设我有三个节点（1,2和3），我连接到这样的节点：

Cluster.builder().addContactPoints("1,2,3".split(",")).build();

然后，如果节点3例如关闭，并且无法解析IP，则此行代码将抛出_822526_，如文档中所述：

@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?，但这并没有回答我的问题，因为它没有't say anything about hosts than can' t可以访问 .

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

java cassandra datastax

3 回答

  • 7

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

    作为您的情况下的解决方法（主机已从DNS条目中删除），您可以简单地调用方法addContactPoint(String address)而不是使用 addContactPoints(String... addresses) （在场景后面只为每个提供的地址调用 addContactPoint(String address) ）并自己管理异常 .

    The code could be something like this:

    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();

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

    回复于
  • 2

    正如Nick所说，它基于DNS解析，而不是Cassandra服务器 Health .

    如果您比重新编译应用程序更频繁地从环境中删除主机，那么您应该考虑不将您的联系点烘焙到代码中，而是通过其他方式（环境变量，REST服务，单个DNS名称）将它们提供给它们 . 总是解决一个活的种子等） .

    回复于
  • 0

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

    回复于

相关问题