Kubernetes跨Pod场景下Hazelcast IMap分布式锁不生效问题咨询

你遇到的跨Pod同时持锁、Management Center锁计数为0的问题，核心原因是锁操作未在统一的Hazelcast集群侧生效，按以下步骤排查修复即可：

• 先确认客户端真正接入同一个Hazelcast集群
  Kubernetes环境下最常见的配置错误是服务发现规则配置异常，导致两个微服务Pod的Hazelcast客户端要么各自启动了内嵌的独立Hazelcast节点，要么连到了互相隔离的集群节点。这种场景下lock()操作是在独立节点/本地进程内执行，两个Pod的锁完全不互通，自然会同时加锁成功，且Management Center统计不到锁数据。
  验证方式：在两个业务Pod中分别打印客户端获取到的集群成员列表，如果每个Pod返回的成员列表仅包含自身IP，即可确认是集群连通问题，重新校验K8s下的Hazelcast服务发现配置，确保两个Pod的客户端接入的是同一个跨节点集群即可。
• 关闭锁所用Map的近缓存配置
  如果给customers这个Map配置了近缓存（Near Cache），客户端会默认优先在本地JVM完成锁操作，不会同步锁状态到集群，跨节点完全不互斥。针对分布式锁场景使用的Map，必须显式关闭近缓存，参考配置如下：

  ClientConfig clientConfig = new ClientConfig();
  // 针对锁使用的Map单独配置
  MapConfig lockMapConfig = new MapConfig("customers");
  NearCacheConfig nearCacheConfig = new NearCacheConfig();
  // 关闭本地条目缓存，强制锁操作走集群同步
  nearCacheConfig.setCacheLocalEntries(false);
  lockMapConfig.setNearCacheConfig(nearCacheConfig);
  clientConfig.addMapConfig(lockMapConfig);
  

• 保证锁Key的序列化一致性
  如果传入lock()方法的Key是自定义对象，一旦两个Pod部署的服务版本中该对象的equals()、hashCode()实现不一致，或者序列化ID不匹配，集群侧会识别为两个完全不同的Key，自然会分别加锁成功。分布式锁场景建议统一使用String类型作为锁Key，从根源避免序列化兼容问题。
• 补全锁逻辑的异常兜底，避免状态异常
  你当前的代码缺少锁状态判断，加锁过程中如果抛出异常，finally块中的unlock可能误释放其他线程持有的锁；另外不要每次执行锁逻辑都新建HazelcastClient实例，该客户端是重量级对象，应作为全局单例在服务启动时初始化一次。修正后的参考代码如下：

  // 全局单例初始化Hazelcast客户端，不要重复创建
  HazelcastInstance client = HazelcastClient.newHazelcastClient(clientConfig);
  IMap<String, Object> customerMap = client.getMap("customers");
  boolean lockAcquired = false;
  try {
      // 建议设置合理的锁超时时间，避免服务宕机导致锁永久不释放
      customerMap.lock(lockKey, 30, TimeUnit.SECONDS);
      lockAcquired = true;
      // 执行业务逻辑
  } finally {
      // 仅当前线程真正持有锁时才执行释放
      if (lockAcquired && customerMap.isLocked(lockKey) && customerMap.isHeldByCurrentThread(lockKey)) {
          customerMap.unlock(lockKey);
      }
  }
  

修复完成后可直接验证：在Management Center查看customers Map的锁条目计数，加锁成功时计数会同步增加，此时另一个Pod发起的lock请求会阻塞直到锁释放，不会再出现同时持锁的问题。

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