如何仅连接到特定的 cassandra 节点

Question

我在同一个数据中心有两个 docker cassandra 容器节点充当 node1 和 node2。

我的目标是让我的 java 应用程序始终连接到 node1，并且我的临时手动查询应该只从 node2 返回（不应该有任何节点间数据通信）

通常我可以使用 cqlsh 在 container1 或 container2 上执行读/写查询。如果我使用 cqlsh 在 container1 上触发一些查询，它是否总是从同一个容器（node1）返回数据，或者它也可能在内部路由到另一个节点？

我知道协调节点会与对等节点进行数据请求，如果 RF=2 和 2 节点集群会发生什么情况，协调节点本身是否能够提供数据？

这里，RF=2，节点=2，一致性=ONE

Answer 1

我之前已经设置了集群来将 OLTP 与 OLAP 分开。这样做的方法是将您的节点分成不同的逻辑数据中心。

所以 node1 应该在 cassandra-rackdc.properties 中将其本地数据中心放在“dc1”中。

dc=dc1
rack=r1

同样，node2 应该放入它自己的数据中心，“dc2”。

dc=dc2
rack=ra

那么您的键空间定义将如下所示：

CREATE KEYSPACE stackoverflow
  WITH REPLICATION={'class':'NetworkTopologyStrategy','dc1':'1','dc2':'1'};

我的目标是让我的 java 应用程序始终连接到 node1

在您的 Java 代码中，您应该指定“dc1”作为您的默认数据中心，就像我在此示例中所做的那样：

String dataCenter = "dc1";

Builder builder = Cluster.builder()
                .addContactPoints(nodes)
                .withQueryOptions(new QueryOptions().setConsistencyLevel(ConsistencyLevel.LOCAL_ONE))
                .withLoadBalancingPolicy(new TokenAwarePolicy(
                                            new DCAwareRoundRobinPolicy.Builder()
                                            .withLocalDc(dataCenter).build()))
                .withPoolingOptions(options);

这将使您的 Java 应用程序“粘”到数据中心“dc1”中的所有节点，或者在本例中仅为 node1。同样，当您 cqlsh 进入 node2 时，您的即席查询应该“粘”到“dc2”中的所有节点。

注意：在此配置中，您没有高可用性。如果 node1 出现故障，您的应用将不会跳转到 node2。