Apache Ignite 2.4复制模式下CacheStoreFactory未全节点触发的问题

首先得明确：Ignite 的 CacheStore 设计初衷是作为缓存与底层持久化存储的桥梁，默认情况下无论缓存是分区还是复制模式，只会有一个节点执行 Store 的写操作——这是为了避免多节点重复写入共享持久化层（比如数据库）造成数据冲突或冗余。你看到的单条日志是 Ignite 的默认行为，哪怕用了复制模式，它也只会选一个节点（通常是发起操作的节点）来触发 Store。

如果你的需求是让每个节点的 Store 逻辑都被触发（比如每个节点需要更新本地存储、执行本地业务逻辑），可以用以下两种方案实现：

方案一：利用本地缓存事件监听器（推荐） #

放弃依赖 CacheStore 的默认触发机制，改用本地事件监听——每个节点订阅自己缓存的条目变更事件，事件触发时执行你的存储逻辑。这种方式天然适配复制模式，每个节点都会处理自己的缓存变更：

// 每个节点启动时执行这段代码
var ignite = Ignition.Start(yourIgniteCfg);
var cache = ignite.GetOrCreateCache<int, string>(yourCacheCfg);

// 注册本地监听器，监听条目创建/更新事件
cache.LocalListen((evt) =>
{
    // 处理创建事件
    if (evt is CacheEntryCreatedEvent<int, string> createdEvt)
    {
        var key = createdEvt.Key;
        var value = createdEvt.Value;
        Console.WriteLine($"Node {ignite.GetCluster().LocalNode.Id} executing store for key {key}");
        // 调用你原来 CacheStore 中的写逻辑，比如：
        // CustomStore.Write(key, value);
    }
    // 处理更新事件
    else if (evt is CacheEntryUpdatedEvent<int, string> updatedEvt)
    {
        var key = updatedEvt.Key;
        var newValue = updatedEvt.Value;
        Console.WriteLine($"Node {ignite.GetCluster().LocalNode.Id} executing store update for key {key}");
        // CustomStore.Update(key, newValue);
    }
    return true; // 返回true保持监听
}, CacheEntryEventType.Created, CacheEntryEventType.Updated);

这样每次执行 cache.Put，所有节点都会收到本地的缓存变更事件，各自触发存储逻辑，就能看到你预期的多条日志了。

方案二：通过集群广播手动触发（适合特殊场景） #

如果你一定要复用原有的 CacheStoreFactory，可以在执行 Put 后，通过 Ignite 的集群广播机制，让每个节点主动调用自己的 Store：

// 执行缓存写入
int key = 1;
string value = "test";
cache.Put(key, value);

// 广播到所有节点，触发各自的 Store 逻辑
ignite.GetCluster().Broadcast(() =>
{
    var localIgnite = Ignition.GetIgnite();
    var localCache = localIgnite.GetCache<int, string>(yourCacheName);
    var entry = localCache.GetEntry(key);
    
    if (entry != null)
    {
        // 获取当前节点的 Store 实例并执行写操作
        var store = yourCacheCfg.CacheStoreFactory.Create();
        store.Write(new[] { new CacheEntry<int, string>(key, entry.Value) });
        Console.WriteLine($"Node {localIgnite.GetCluster().LocalNode.Id} executed store via broadcast");
    }
});

⚠️ 注意：这种方式要考虑一致性问题——必须确保 Put 操作成功后再执行广播，否则可能出现缓存与存储不一致；同时广播会带来额外的性能开销，不适合高频写入场景。

关键注意点 #

如果你的 Store 逻辑是写入共享数据库，方案一的事件监听会导致多节点重复写，这可能违反数据一致性原则，这种场景下还是应该用 Ignite 默认的单节点 Store 机制。只有当你需要每个节点执行本地专属逻辑时，才推荐上述方案。

内容的提问来源于stack exchange，提问作者sa.he