如何判断Hazelcast集群节点是否拥有指定Map Entry的所有权

核心前提说明 #

Hazelcast 的 MapInterceptor 拦截逻辑默认仅在对应条目所在的主分区所有者节点触发，备份节点不会执行拦截器代码，你当前的实现天然满足「仅在所有权节点执行一次」的需求，无需额外做所有权判断。
如果你的场景开启了备份节点执行拦截器的配置，或者需要手动做二次校验，可以参考下面的实现方案。

手动判断所有权实现 #

你可以通过Hazelcast的PartitionService获取指定key对应的分区所有者，和当前节点信息对比即可，补全后的代码如下：

// 需先将当前HazelcastInstance注入到拦截器实现类中
private final HazelcastInstance hazelcastInstance;

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

@Override
public Object interceptRemove(Object removedValue) {
    ApplicationSession session = (ApplicationSession) removedValue;
    // 从会话对象中获取存入IMap时使用的key（即会话ID）
    String sessionKey = session.getSessionId();

    PartitionService partitionService = hazelcastInstance.getPartitionService();
    Partition sessionPartition = partitionService.getPartition(sessionKey);
    Member currentNode = hazelcastInstance.getCluster().getLocalMember();

    // 仅当前节点是该会话条目的主所有者时才执行业务逻辑
    if (currentNode.equals(sessionPartition.getOwner())) {
        if (session.isExpired()) {
            // 执行登出事件审计逻辑
        }
        // 执行其他清理任务
    }

    return removedValue;
}

注意事项 #

• 备份节点执行拦截器的开关hazelcast.map.interceptor.execute-on-backups默认值为false，无特殊需求不需要开启，也不需要加上述所有权判断代码
• 建议审计、清理逻辑实现幂等，避免分区迁移、节点宕机等极端场景下出现重复执行的问题

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