如何在Cassandra Java驱动v4中编程启用跨数据中心故障转移

和3.x版本内置的DCAwareRoundRobin策略逻辑不同，4.x版本驱动默认关闭跨DC访问能力，就算手动开启跨DC故障转移参数，同时代码中显式指定本地数据中心的场景下，驱动的连接和路由逻辑也完全按照极端灾备兜底设计，不会主动在正常状态下建立跨DC连接，具体流程如下：

核心处理逻辑 #

• 初始化阶段：驱动启动时只会使用传入的contact point节点发起首次连接，连接成功后拉取全集群拓扑，将所有节点按数据中心标签分组：和withLocalDatacenter("datacenter1")指定名称匹配的节点划入本地DC节点池，其余节点全部划入对应远程DC的节点元数据列表，这一步不会主动给远程节点建立连接。
  如果传入的contact point里混了属于其他DC的节点，驱动识别到DC标签不匹配后，也不会将其作为本地节点使用，仅会将其归入远程节点元数据。
• 正常运行阶段：只要本地DC存在任意可用节点，驱动只会和本地DC节点维持控制连接、业务请求连接池，所有读写请求、元数据同步、节点健康探测流量全部走本地节点。哪怕配置了dc-failover参数，这一阶段也不会主动和远程DC节点建立TCP连接，远程节点不会进入常规负载均衡的轮询列表，不会出现非预期的跨DC请求。
• 故障触发阶段：只有当驱动探测到本地DC所有节点全部不可达时，才会触发跨DC故障转移逻辑：按照配置的max-nodes-per-remote-dc数值，从每个远程DC中随机选取对应数量的节点建立连接，临时将这些节点纳入可用路由池，承接业务请求。
  故障转移期间驱动会持续探测本地DC节点状态，一旦检测到本地DC有任意节点恢复可达，会立刻断开所有远程DC的临时连接，将全部流量切回本地DC节点，恢复正常运行状态。

相关配置参考 #

官方提供的跨DC故障转移配置项如下：

Cross-datacenter failover is enabled with the following configuration option:
datastax-java-driver.advanced.load-balancing-policy.dc-failover {
  max-nodes-per-remote-dc = 2
}

常规业务初始化代码示例：

CqlSession session = CqlSession.builder()
    .addContactPoint(new InetSocketAddress("1.2.3.4", 9042))
    .addContactPoint(new InetSocketAddress("5.6.7.8", 9042))
    .withLocalDatacenter("datacenter1")
    .build();

注意事项 #

• 这个跨DC故障转移是极端灾备场景的兜底能力，不是跨DC负载分担方案：本地DC仅部分节点故障时，驱动只会把流量转发到剩下的健康本地节点，根本不会触发跨DC切流，更不会在正常运行时把请求轮询到远程节点。
• 如果代码中没有显式调用withLocalDatacenter()指定本地DC，驱动会将首次连接成功的contact point所属DC自动识别为本地DC，若contact point配置错误可能导致DC识别偏差，出现非预期跨DC流量。
• max-nodes-per-remote-dc参数建议配置为2-3即可，数值过大会在故障切流时对远程DC造成突增连接压力，反而影响灾备可用性。

内容的提问来源于stack exchange，提问作者prathyusha magam