如何用Cassandra Java驱动确定本地节点及system.local查询响应节点？

1. SELECT * FROM system.local的响应节点 #

默认情况下，Cassandra Java驱动会使用配置的负载均衡策略（比如默认的DCAwareRoundRobinPolicy）将查询路由到集群中的任意可用节点，所以你的代码会随机拿到某个节点的host_id，而非本地节点的。

2. 无需硬编码获取本地节点的方法 #

有两种可靠的实现方式：

方式一：通过本地IP匹配集群节点 #

利用应用与Cassandra实例同机部署的特性，获取当前机器的IP地址，再与集群元数据中的节点地址（listen_address或broadcast_address）匹配：

import java.net.InetAddress;
import java.net.UnknownHostException;
import com.datastax.oss.driver.api.core.CqlSession;
import com.datastax.oss.driver.api.core.metadata.Node;

public static Node getLocalNode(CqlSession cqlSession) throws UnknownHostException {
    InetAddress localIp = InetAddress.getLocalHost();
    
    for (Node node : cqlSession.getMetadata().getNodes().values()) {
        // 优先匹配Cassandra的监听地址（listen_address）
        if (node.getListenAddress().equals(localIp)) {
            return node;
        }
        // 若监听地址是0.0.0.0（通配），匹配广播地址（broadcast_address）
        else if (node.getBroadcastAddress().isPresent() 
                 && node.getBroadcastAddress().get().equals(localIp)) {
            return node;
        }
    }
    return null;
}

方式二：强制将system.local查询发送到本地节点 #

如果需要通过system.local的host_id来匹配节点，必须确保查询只发送到本地节点，可通过SimpleStatement.setNode()显式指定目标：

import java.util.UUID;
import com.datastax.oss.driver.api.core.cql.Row;
import com.datastax.oss.driver.api.core.cql.SimpleStatement;
import com.datastax.oss.driver.api.core.metadata.Node;

public static Node getLocalNodeBySystemLocal(CqlSession cqlSession) throws UnknownHostException {
    // 先通过IP匹配拿到本地节点
    Node localNode = getLocalNode(cqlSession);
    if (localNode == null) {
        return null;
    }
    
    // 强制查询发送到本地节点
    SimpleStatement localQuery = SimpleStatement.newInstance("SELECT host_id FROM system.local")
            .setNode(localNode);
    Row row = cqlSession.execute(localQuery).one();
    
    if (row != null) {
        UUID localHostId = row.getUuid("host_id");
        return cqlSession.getMetadata().getNodes().get(localHostId);
    }
    return null;
}

补充说明 #

• 不要依赖默认负载均衡策略来路由system.local查询：这个表仅存储当前节点的本地信息，发送到其他节点会返回该节点的信息，而非你需要的本地节点数据。
• 若Cassandra配置了listen_address: 0.0.0.0，一定要用broadcast_address做匹配，因为此时listen_address不会是具体的机器IP。

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