Hazelcast条目过期时备份未删除问题咨询

问题原因 #

Hazelcast 5.x 中，备份节点默认不会主动执行过期条目清理逻辑——仅当备份节点晋升为主节点后，才会启动自身的过期检查任务。而你是事后为已存在的条目动态设置TTL，主节点清理过期条目后，若删除操作未同步到备份节点（比如元数据同步延迟、主节点清理通知未送达），就会导致备份节点保留已过期的无效条目。当原主节点崩溃，备份节点升为主节点时，这些过期条目会被恢复，引发业务问题。

另外，主节点的过期清理默认是10秒周期触发，若清理不及时也可能加剧该问题。

解决方案 #

1. 用带TTL参数的set方法同步条目更新 #

避免单独调用setTTL操作，改用带TTL参数的set方法更新条目，确保主节点将包含TTL信息的条目完整同步到备份节点：

// 用户断开连接时执行此操作，确保TTL同步到备份
sessionMap.set(userId, sessionObject, 30, TimeUnit.SECONDS);

相比单独设置TTL，该操作能更可靠地同步条目元数据到备份节点，避免过期状态不一致。

2. 开启备份节点的过期检查 #

Hazelcast 5.1+支持开启备份节点的主动过期检查，通过Map配置启用该功能：

hz.getConfig().addMapConfig(new MapConfig("session_map")
        .setInMemoryFormat(InMemoryFormat.OBJECT)
        .setBackupCount(1)
        .setAsyncBackupCount(0)
        .setStatisticsEnabled(true)
        // 开启备份节点的过期检查，主动清理过期条目
        .setBackupExpirationCheckEnabled(true));

开启后，备份节点会定期检查本地条目是否过期，主动清理无效的备份数据。

3. 缩短主节点的过期清理间隔 #

调整主节点的过期清理周期，确保过期条目能被及时清理并同步到备份：

// 全局设置主节点过期清理间隔（单位：秒）
hz.getConfig().setProperty("hazelcast.map.expiration.cleanup.interval.seconds", "5");

缩短间隔能减少主节点清理滞后带来的备份不一致问题。

4. 验证与监控 #

利用你已开启的Map统计功能，通过以下代码查看主备节点的条目状态：

LocalMapStats stats = sessionMap.getLocalMapStats();
System.out.println("过期条目数：" + stats.getExpiredEntryCount());
System.out.println("备份条目数：" + stats.getBackupEntryCount());

模拟节点崩溃场景，检查新主节点是否仍存在已过期的会话条目，验证修复效果。

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