为 Axon Sagas 启用 Ehcache 缓存

Question

我的目标是使用 newCacheManagerBuilder() API 创建 2 个缓存并将它们存储在堆外

我的理解是我需要一个用于 Saga 实例的缓存和一个用于关联的缓存。首先，我正在初始化缓存管理器。

    @Bean
    @Scope(ConfigurableBeanFactory.SCOPE_SINGLETON)
    public CacheManager cacheManager() {
        CacheManager cacheManager =  CacheManagerBuilder.newCacheManagerBuilder().build();
        cacheManager.init();
        return cacheManager;
    }

    @Bean
    public org.ehcache.Cache<String, MySaga> sagaEhcache(CacheManager cacheManager) {
        return cacheManager.createCache("sagaEhcache",
            CacheConfigurationBuilder.newCacheConfigurationBuilder(
                String.class,
                MySaga.class,
                ResourcePoolsBuilder.newResourcePoolsBuilder().offheap(sagaCacheOffHeapMb, MemoryUnit.MB)
            ).build()
        );
    }

    @Bean
    public org.ehcache.Cache<String, AssociationValue> sagaAssocEhcache(CacheManager cacheManager) {
        return cacheManager.createCache("sagaAssocEhcache",
            CacheConfigurationBuilder.newCacheConfigurationBuilder(
                String.class,
                AssociationValue.class,
                ResourcePoolsBuilder.newResourcePoolsBuilder().offheap(sagaAssocCacheOffHeapMb, MemoryUnit.MB)
            ).build()
        );
    }

上述映射是否正确：String/MySaga 和 String/AssociationValue ？

Answer 1

Axon Framework 使用缓存适配器的概念将缓存用于CachingSagaStore 或CachingEventSourcingRepository 之类的东西。 两者都需要 Cache 的 Axon 实现，可以遍历它以允许您使用 JCacheAdapter 或 EhCacheAdapter。 当您使用 EhCache 时，您需要在设置中使用 EhCacheAdapter。

但是，您的设置有一个缺点。 您正在使用org.ehcache，因此是版本 3。但是 Axon Framework 使用 net.sf.ehcache，因此是版本 2。 因此，除非有某种机制可以将 EhCache 版本 3 恢复到版本 2，否则您现在需要在应用程序中实际降级 EhCache 版本。

---

更新

如 cmets 所示，您已经实现了自己的 EhCacheAdapter 以支持带有 Axon 框架的最新版本的 EhCache。因此，这给您留下了以下问题：

上述映射是否正确：String/MySaga 和 String/AssociationValue？

检查CachingSagaStore 实现，您可以看到CacheEntry<S> 用于Saga，Set<String> 用于关联。通用 S 代表 Saga 实现，因此在您的示例中为 MySaga。

---

更新 2

对于使用 Axon Framework 和 EhCache 版本 2 的示例项目，您可以查看Axon Trader 应用程序。