嵌入式分布式Infinispan集群：网络断开后缓存事件监听器失效

问题1：集群合并后随机节点监听器无报错停止工作的原因 #

1. 版本固有bug：Infinispan 12.1.4.Final存在集群合并场景下的监听器同步缺陷。当集群分裂为独立子集群后，每个节点会独立维护本地的监听器注册状态；合并过程中，节点间的监听器订阅信息未正确同步，导致其中一个节点的监听器订阅关系丢失，事件无法分发到该节点的监听器实例。
2. 视图变化时监听器绑定失效：标注@Listener(clustered = true)的集群监听器依赖稳定的集群视图。网络分区恢复触发合并后，JGroups通道更新集群视图，但Infinispan的事件分发组件未自动重新绑定监听器，导致监听器与事件总线的连接断开。由于内部异常被静默处理，没有报错日志输出。
3. 缓存状态重置的影响：集群合并时，Infinispan会执行缓存数据的合并与状态同步操作，部分场景下会重置缓存的事件分发上下文；而注解方式自动注册的监听器未被重新初始化，导致后续缓存事件无法触发监听器逻辑。

问题2：确保监听器正常运行的配置与注意事项 #

优先升级版本 #

Infinispan 12.x后续维护版本（如12.1.17.Final）及13.x+版本已修复集群合并时监听器注册丢失的已知问题，升级是最直接的解决方案。

手动管控监听器生命周期 #

通过监听集群视图变化事件，在合并完成后主动重新注册监听器，避免依赖自动注册的缺陷：

@Component
public class ClusterAwareListenerManager {
    private final CacheManager cacheManager;
    private final CacheEventListener cacheEventListener = new CacheEventListener();

    public ClusterAwareListenerManager(CacheManager cacheManager) {
        this.cacheManager = cacheManager;
        // 初始化时注册监听器
        registerListenerOnAllCaches();
    }

    @Listener
    public void onClusterViewChange(ViewChangedEvent event) {
        if (event.isMerge()) {
            // 合并完成后重新注册监听器
            unregisterListenerFromAllCaches();
            registerListenerOnAllCaches();
        }
    }

    private void registerListenerOnAllCaches() {
        cacheManager.getCacheNames().forEach(name -> 
            cacheManager.getCache(name).addListener(cacheEventListener)
        );
    }

    private void unregisterListenerFromAllCaches() {
        cacheManager.getCacheNames().forEach(name -> 
            cacheManager.getCache(name).removeListener(cacheEventListener)
        );
    }
}

优化集群合并相关配置 #

• 调整JGroups的MERGE3参数，缩短合并检测间隔，减少监听器状态不一致的时间窗口：

<MERGE3 min_interval="5000" max_interval="15000"/>

• 为Infinispan缓存配置合适的合并策略，确保合并过程中缓存状态快速稳定：

<!-- 在缓存配置中添加 -->
<merge-policy>REMOVE_ALL</merge-policy>

（注：合并策略需根据业务场景选择，REMOVE_ALL会清除冲突数据，适合对数据一致性要求高的场景）

增强日志排查能力 #

开启Infinispan事件通知与集群模块的DEBUG日志，便于定位监听器失效的具体原因：

logging.level.org.infinispan.notifications=DEBUG
logging.level.org.infinispan.cluster=DEBUG

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