Redisson集群模式下RMapCache缓存过期事件监听问题解析

问题背景

在使用Redisson与AWS ElastiCache 7.0.7集群模式(2主2从)配合时，开发者在Kubernetes StatefulSet中部署的多个微服务实例通过RMapCache添加了过期监听器，但发现只有部分Pod能够接收到缓存过期事件通知。

问题现象

当多个Pod同时监听同一个RMapCache的过期事件时，预期是所有Pod都能收到过期通知，但实际只有部分Pod能够接收到这些事件。通过Redis命令行工具检查发现，PUBSUB SHARDNUMSUB和PUBSUB NUMSUB命令返回的订阅者数量不一致，表明部分实例可能使用了错误的订阅方式。

技术分析

深入研究发现，问题的根源在于Redisson的集群连接管理逻辑。具体来说：

1. 在ClusterConnectionManager中，Redisson会检测Redis集群是否支持分片
2. 当多个Redisson客户端同时初始化时，部分实例可能无法正确检测到分片支持
3. 这导致部分实例错误地使用了普通RedissonTopic而非RedissonShardedTopic进行订阅

关键点在于，从节点(slave nodes)会返回MOVED错误，这影响了分片支持的检测逻辑。当检测失败时，客户端会回退到非分片模式的订阅方式，从而导致部分实例无法接收到过期事件。

解决方案

Redisson项目维护者已确认并修复了此问题。修复的核心是正确处理从节点返回的MOVED错误，确保所有客户端都能正确检测到分片支持，从而统一使用RedissonShardedTopic进行订阅。

对于开发者而言，升级到包含此修复的Redisson版本即可解决问题。同时，这也提醒我们在使用分布式缓存时：

1. 要特别注意集群模式下的事件通知机制
2. 不同订阅方式在集群环境中的行为可能有差异
3. 主从架构可能对某些功能的实现有特殊影响

最佳实践

在使用Redisson的RMapCache过期监听功能时，建议：

1. 确保使用最新稳定版本的Redisson
2. 在集群环境中测试事件通知的可靠性
3. 监控订阅状态，确保所有实例都使用了正确的订阅方式
4. 对于关键业务场景，考虑添加额外的健康检查机制

这个问题展示了分布式系统中一个典型挑战：在集群环境下保持状态同步和行为一致性。通过理解底层机制，开发者可以更好地设计可靠的分布式应用。