Cassandra集群行键/分区节点位置查询工具咨询

嘿，针对你3节点、RF=2的Cassandra集群，完全有办法查到特定partition key或者row key对应的存储节点！下面是几个实用的工具和方法，都是Cassandra生态自带的，不用额外折腾第三方工具：

1. 最便捷的命令行工具：nodetool getendpoints #

这是Cassandra自带的原生工具，直接在集群任意节点的终端执行就行，用法非常直观：

nodetool getendpoints <你的键空间名称> <目标表名称> <partition key的值>

举个例子，如果你的键空间是user_data，表是user_profiles，要查partition key为bhupen_123的节点，就输入：

nodetool getendpoints user_data user_profiles bhupen_123

因为你的副本因子（RF）是2，这个命令会直接返回负责存储该partition的2个节点的IP地址或主机名。

2. 在cqlsh中通过CQL查询 #

如果你习惯用CQL交互环境（cqlsh），可以通过计算token值来定位节点：
首先，先算出目标partition key对应的token：

SELECT token(partition_key_column) FROM 你的键空间.你的表 WHERE partition_key_column = '目标值';

拿到token值后，查询system.peers（集群其他节点）和system.local（当前节点）表，找到包含该token范围的节点：

SELECT peer AS node_address FROM system.peers 
WHERE token >= <刚才算出的token值> AND token < <该token对应的下一个范围边界>
UNION
SELECT rpc_address AS node_address FROM system.local 
WHERE token >= <刚才算出的token值> AND token < <该token对应的下一个范围边界>;

这个方法需要你对Cassandra的token范围分配有基本了解，虽然不如nodetool直接，但适合在CQL环境里完成查询。

3. 开发场景：用Cassandra Driver获取节点信息 #

如果是在应用代码里需要动态获取节点信息，以Java Driver为例，可以通过TokenMap类来查询：

Cluster cluster = Cluster.builder().addContactPoint("集群任意节点IP").build();
Metadata metadata = cluster.getMetadata();
TokenMap tokenMap = metadata.getTokenMap();
// 根据partition key生成对应的token
Token token = TokenFactory.forSystemLocalPartitioner().toToken("目标partition key值");
// 获取该partition的所有副本节点
Set<Host> replicaHosts = tokenMap.getReplicas(metadata.getKeyspace("你的键空间名称").getName(), token);
// 遍历输出节点信息
for (Host host : replicaHosts) {
    System.out.println("副本节点地址：" + host.getAddress());
}
cluster.close();

这个方法适合在程序中动态获取节点，比如做自定义路由或者监控。

补充说明：因为你的RF=2，每个partition会在2个不同节点上存储副本，上面所有方法都会返回这两个节点的信息，完全符合你的集群配置需求。

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