如果一个主机丢失,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条目中删除)的解决方法,您可以直接调用方法 代码可能是这样的: 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的改进. (编辑:李大同) 【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容! |