Cassandra Java驱动节点端点处理异常问题排查与配置咨询

1. 为何会出现两种节点表示形式？ #

Cassandra Java驱动的节点来源分两种场景：

• 初始配置的联系点：驱动解析主机名到IP后，默认会保留主机名作为端点的标识部分，所以显示为hostname/ip_address:9042。
• 集群拓扑发现的节点：如果Cassandra集群内部返回的节点信息是IP（比如节点的rpc_address配置为IP），驱动就会直接以IP作为端点，显示为/ip_address:9042。另外，若驱动多次解析同一主机名得到不同IP，或拓扑更新时节点信息来源不一致，也会出现重复节点的情况。

2. 仅IP表示的节点请求失败的原因？ #

大概率是以下场景导致：

• SSL证书验证不通过：如果集群启用SSL，且证书绑定的是主机名而非IP，用IP连接时SSL握手会因证书主体与IP不匹配失败，无法建立连接。
• 网络策略限制：部分环境防火墙规则基于主机名白名单，直接用IP访问会被拦截，导致连接无法建立。
• 连接池状态异常：IP节点的连接池若因之前的失败被标记为不可用，且没有配置重试机制，后续请求会直接抛出NodeUnavailableException。

3. 如何配置驱动始终保留主机名+IP的端点？ #

可以通过以下几种方式解决：

自定义端点解析器 #

实现EndPointResolver接口，让驱动解析主机名时始终保留主机名标识，关联对应的IP：

public class HostnamePreservingEndPointResolver implements EndPointResolver {
    @Override
    public CompletionStage<EndPoint> resolve(InetSocketAddress unresolvedAddress) {
        String hostname = unresolvedAddress.getHostString();
        return CompletableFuture.supplyAsync(() -> {
            try {
                InetAddress ip = InetAddress.getByName(hostname);
                return new DefaultEndPoint(
                    new InetSocketAddress(ip, unresolvedAddress.getPort()),
                    hostname
                );
            } catch (UnknownHostException e) {
                throw new CompletionException(e);
            }
        });
    }
}

然后在会话构建时注册该解析器：

CqlSession session = CqlSession.builder()
    .addContactPoint(InetSocketAddress.createUnresolved("cassandra-host", 9042))
    .withConfigLoader(DriverConfigLoader.programmaticBuilder()
        .withString(DefaultDriverOption.END_POINT_RESOLVER_CLASS, 
                    HostnamePreservingEndPointResolver.class.getName())
        .build())
    .build();

修改Cassandra集群配置 #

调整节点的cassandra.yaml，将rpc_address和broadcast_rpc_address设为主机名，这样集群返回的拓扑信息会包含主机名，驱动就会用hostname/ip_address:9042的形式表示节点。

配置驱动保留未解析的主机名 #

在驱动配置文件（如application.conf）中添加：

datastax-java-driver.basic.contact-points.resolution = unresolved

该配置让驱动不解析初始联系点的IP，直接保留主机名，后续拓扑发现也优先使用主机名关联IP。

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