Apache Ignite集群Java瘦客户端数据分布不均问题求助

• 确保服务端与客户端亲和函数完全一致
  瘦客户端的分区感知映射器计算的分区必须和服务端缓存配置的AffinityFunction逻辑、参数完全匹配。如果服务端缓存没有配置对应的MyAffinityFunction，客户端计算的分区会和服务端实际分区映射不匹配，导致所有请求默认路由到同一个节点。
  服务端缓存配置示例：

  CacheConfiguration<Long, byte[]> cacheCfg = new CacheConfiguration<>("cacheName");
  cacheCfg.setAffinity(new MyAffinityFunction(1024)); // 分区数需与客户端传入的partitions参数一致
  ignite.getOrCreateCache(cacheCfg);
  

• 验证自定义亲和函数的分区分布逻辑
  检查MyAffinityFunction.partition(key)是否能将Key均匀映射到所有分区。可以编写测试代码，生成大量随机Long类型Key，统计每个分区的Key数量：

  MyAffinityFunction aff = new MyAffinityFunction(1024); // 替换为实际分区数
  Map<Integer, Integer> partitionStats = new HashMap<>();
  
  for (long key = 0; key < 10000; key++) {
      int partition = aff.partition(key);
      partitionStats.put(partition, partitionStats.getOrDefault(partition, 0) + 1);
  }
  
  // 输出分区分布情况，若某个分区占比过高，说明亲和函数逻辑有问题
  partitionStats.forEach((p, count) -> System.out.printf("分区%d: %d个Key%n", p, count));
  

• 确认分区感知功能真正生效
  开启客户端DEBUG日志，查看IgniteClientPartitionAwareness相关日志，确认客户端是否成功获取集群分区映射，以及是否根据计算的分区选择对应节点。同时检查客户端配置的节点地址是否全部有效，若只有一个节点能连接，所有请求都会发往该节点。

• 检查批量写入的路由逻辑
  确认Ignite 2.14.0瘦客户端的putAll操作是否支持按分区路由。可以查看服务端节点日志，观察批量写入请求是否分散到多个节点；如果所有批量请求都集中在一个节点，可能需要拆分批量为更小的批次，或者确认客户端是否支持批量操作的分区路由。

• 排查服务端缓存其他配置
  检查服务端缓存是否开启了强制路由的配置（如collocated属性），这类配置会导致请求集中到单一节点；同时确认backups配置是否合理（备份不影响主节点分布，但错误配置可能间接导致异常）。

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