如何使用Datastax Java Driver识别Cassandra集群中的宕机节点

一、识别集群宕机节点的实现方式 #

驱动内置了完整的节点健康检测能力，不需要自行实现心跳逻辑，有两种常用方式获取宕机节点信息：

• 主动查询元数据
  你可以随时通过CqlSession实例获取最新的集群元数据，遍历节点状态筛选出宕机节点：

// 适用于Datastax Java Driver 4.x版本
Metadata clusterMetadata = session.getMetadata();
for (Node node : clusterMetadata.getNodes().values()) {
    // 节点状态为DOWN即为宕机/不可达
    if (node.getState() == Node.State.DOWN) {
        System.out.printf("发现不可达节点：地址%s，所属数据中心%s%n", 
            node.getEndPoint(), node.getDatacenter());
    }
}

• 被动监听状态变更事件
  如果需要实时感知节点上下线，不需要轮询元数据，可以直接注册节点状态监听器，节点状态变更时驱动会主动触发回调逻辑，具体实现参考下文监听器部分。

二、元数据更新机制说明 #

驱动的核心元数据（包括节点状态、集群拓扑、Schema结构等）默认开启自动持续更新，不需要手动触发刷新，也不需要注册监听器才能拿到最新状态：

• 驱动内部会自动监听Cassandra集群的Gossip事件，同步节点上下线、拓扑变更等信息；
• 内置的心跳服务会定期检测所有节点的可达性，超过超时阈值无响应的节点会自动标记为DOWN，恢复响应后自动标记为UP；
• 你每次调用session.getMetadata()获取的都是驱动同步完成的最新元数据，不需要额外操作。

注册监听器的作用只是让你在元数据变更时收到主动通知，方便你做自定义的告警、业务逻辑调整等操作，不是元数据更新的必要条件。如果不需要感知实时变更，完全不需要注册任何监听器。

节点状态监听器注册示例 #

如果你需要实时感知节点状态变更，可以在初始化CqlSession的时候注册监听器：

CqlSession session = CqlSession.builder()
    // 注册节点状态监听器，继承NodeStateListenerBase可以只实现需要的回调方法
    .withNodeStateListener(new NodeStateListenerBase() {
        @Override
        public void onDown(Node node) {
            // 节点被标记为宕机时触发，可在此处添加告警逻辑
            System.out.printf("节点%s已宕机，请及时排查%n", node.getEndPoint());
        }

        @Override
        public void onUp(Node node) {
            // 节点恢复可用时触发
            System.out.printf("节点%s已恢复服务%n", node.getEndPoint());
        }

        @Override
        public void onAdd(Node node) {
            // 集群新增节点时触发
        }

        @Override
        public void onRemove(Node node) {
            // 集群移除节点时触发
        }
    })
    .build();

相关补充说明 #

• 以上实现针对4.x版本的Datastax Java Driver，3.x版本的API会有差异，核心逻辑一致。
• 节点心跳超时阈值可以通过配置项advanced.heartbeat.timeout自定义调整，默认值为30秒。
• 不需要自动更新元数据的场景可以手动关闭配置项metadata.enabled，一般不建议修改。

内容的提问来源于stack exchange，提问作者Manish Khandelwal