如何通过API获取Hazelcast FencedLock的当前所有者成员？

1. 用FencedLock原生API直接获取 #

你用来做选主的FencedLock本身就提供了获取锁所有者的方法，这是最直接可靠的方式：

• 调用lock.getOwnerInfo()会返回LockOwnerInfo对象，通过它的getMember()方法就能拿到持有锁的节点实例，里面包含节点地址、UUID等所有你需要的成员信息。
• 代码示例：

// 假设你已经拿到了HazelcastInstance实例
FencedLock leaderLock = hazelcastInstance.getCPSubsystem().getLock("你的选主锁名称");
LockOwnerInfo ownerInfo = leaderLock.getOwnerInfo();
if (ownerInfo != null) {
    Member ownerMember = ownerInfo.getMember();
    String ownerOutput = String.format("current owner is : %s", ownerMember);
    // 把这个字符串传给Spring Actuator端点即可
}

如果当前没有节点持有锁，getOwnerInfo()会返回null，记得加判空处理。

2. 结合IScheduledExecutorService的补充思路 #

虽然你用IScheduledExecutorService实现了单节点任务执行，但通过执行器追踪执行节点不如直接从锁获取靠谱——毕竟任务可能处于等待调度状态，而锁的所有者才是真正的主节点。所以优先用上面的锁API方案。

3. Spring Actuator端点集成示例 #

自定义一个Actuator端点，注入Hazelcast实例，在端点方法里调用锁API就能输出你要的格式：

@Component
@Endpoint(id = "hazelcast-leader")
public class HazelcastLeaderEndpoint {

    private final HazelcastInstance hazelcastInstance;

    public HazelcastLeaderEndpoint(HazelcastInstance hazelcastInstance) {
        this.hazelcastInstance = hazelcastInstance;
    }

    @ReadOperation
    public String getCurrentLeader() {
        FencedLock leaderLock = hazelcastInstance.getCPSubsystem().getLock("你的选主锁名称");
        LockOwnerInfo ownerInfo = leaderLock.getOwnerInfo();
        if (ownerInfo != null) {
            return String.format("current owner is : %s", ownerInfo.getMember());
        }
        return "current owner is : none";
    }
}

启动应用后访问/actuator/hazelcast-leader，就能得到符合要求的输出。

注意点 #

• 要确保你的Hazelcast集群开启了CP子系统，因为FencedLock是CP组件，嵌入式集群需要在配置里显式启用。
• 锁的所有者变更时，getOwnerInfo()会实时返回最新节点信息，不用额外做缓存或刷新。

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