java - 如何将基于 Java 的 Cassandra 客户端连接到 Cassandra 集群，而不是特定节点？

Question

我正在尝试学习 Cassandra 并设置了一个 4 节点 Cassandra 集群。我已经使用 Hector 用 Ja​​va 编写了一个客户端，它目前连接到集群中的一个硬编码单个节点。理想情况下，我希望我的客户端连接到“集群”而不是特定节点……因此，如果 4 个节点中的任何一个出现故障，客户端仍将连接到某个节点。从客户端应用程序的角度来看，这究竟是如何工作的？我似乎找不到很好的解释。

目前我的Hector连接字符串，我需要在这里指定一个特定的节点:

Cluster c = getOrCreateCluster("Test Cluster", cassandraNode1:9160);

我的 Cassandra 节点都配置了我的 rpc_address: 0.0.0.0

Answer 1

如果将 CassandraHostConfigurator 传递给 getOrCreateCluster()，则可以将多个节点指定为逗号分隔的字符串:

  public CassandraHostConfigurator(String hosts) {
    this.hosts = hosts;
  }

  ...

  String[] hostVals = hosts.split(",");

  CassandraHost[] cassandraHosts = new CassandraHost[hostVals.length];
  ...