Datastax java-driver LoadBalancingPolicy

Question

我想了解如何使用 datastax java 驱动程序为 cassandra 中的大量批处理工作负载决定负载平衡策略。我有两个数据中心，我希望尽可能快、可靠地写入具有一致性 ONE 的集群。

我该如何选择负载平衡选项，我看到了 TokenAwarePolicy, LatencyAware, DCAware 。我可以全部使用吗？

谢谢 斯里瓦桑

Answer 1

java-driver 中的默认 LoadBalancingPolicy 应该非常适合这种情况。默认的 LoadBalancingPolicy 定义为（来自Policies）：

public static LoadBalancingPolicy defaultLoadBalancingPolicy() {
    return new TokenAwarePolicy(new DCAwareRoundRobinPolicy());
}

这将使您提供的联络点所在的数据中心的所有请求保持在本地，并将您的请求定向到具有您正在读取/插入的数据的副本（使用循环来平衡）。

您可以嵌套 LoadBalancingPolicies，因此如果您想使用所有这三个策略，您只需执行以下操作：

LoadBalancingPolicy policy = LatencyAwarePolicy
  .builder(new TokenAwarePolicy(new DCAwareRoundRobinPolicy()))
  .build();

Answer 2

如果你愿意使用一致性级别ONE，你并不关心使用哪个数据中心，所以没有必要使用DCAwareRoundRobinPolicy。如果您希望写入尽可能快，您希望最小化延迟，因此您应该使用LatencyAwarePolicy；在实践中，这通常会选择本地数据中心的节点，但如果它可能提供更好的性能，例如当本地节点过载时，将使用远程节点。您还希望最小化网络跳数，因此您希望使用写入的存储节点之一作为写入的协调器，因此您应该使用TokenAwarePolicy。您可以通过将一个策略传递给另一个的构造函数调用来将策略链接在一起。

很遗憾，Cassandra 驱动程序没有提供任何直接有用的基本策略供您用作LatencyAwarePolicy 或TokenAwarePolicy 的子策略；选择是DCAwareRoundRobinPolicy、RoundRobinPolicy 和WhiteListPolicy。但是，如果您使用RoundRobinPolicy 作为子策略，LatencyAwarePolicy 应该在前几次查询之后获取它需要的延迟信息。