0

我正在使用ff4j-spring-boot-starterwithf4j-store-springjdbc来设置我的 ff4j 服务器。我所有的其他微服务都使用 ff4j 提供的端点来访问这个特性存储，并且响应以 JSON 格式返回。

由于数据不会经常更改，并且我们正在尝试保存不必要的数据库调用，因此我正在尝试在服务器上缓存我的功能存储。此外，如果功能标志 DB 已关闭（用于刷新/维护），我们仍然希望其他服务使用缓存中的这些值成功启动。

ff4j-store-ehcache我们在 pom.xml 中导入

        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.2.1.RELEASE</version>
    </parent>

    <properties>
        <java.version>1.8</java.version>
        <spring-cloud.version>Hoxton.RC2</spring-cloud.version>
        <ff4j.version>1.8.7</ff4j.version>
        <odbc.version>19.6.0.0.0</odbc.version>
    </properties>
    <dependency>
            <groupId>org.ff4j</groupId>
            <artifactId>ff4j-spring-boot-starter</artifactId>
            <version>${ff4j.version}</version>
        </dependency>

        <dependency>
            <groupId>org.ff4j</groupId>
            <artifactId>ff4j-store-springjdbc</artifactId>
            <version>${ff4j.version}</version>
        </dependency>

        <dependency>
            <groupId>org.ff4j</groupId>
            <artifactId>ff4j-web</artifactId>
            <version>${ff4j.version}</version>
        </dependency>

        <dependency>
            <groupId>org.ff4j</groupId>
            <artifactId>ff4j-store-ehcache</artifactId>
            <version>${ff4j.version}</version>
        </dependency>
        <dependency>
            <groupId>org.ff4j</groupId>
            <artifactId>ff4j-webapi-jersey2x</artifactId>
            <version>1.8.11</version>
        </dependency>
        <!-- FF4J dependencies - end -->

我们的 FeatureCacheProviderEhCache 实现在 FF4jConfig.java 中看起来像这样。

@ConditionalOnClass({​​​​ ConsoleServlet.class, FF4jDispatcherServlet.class }​​​​)
public class Ff4jConfig extends SpringBootServletInitializer {​​​​

    @Autowired
    private DataSource dataSource;

    @Bean
    public ServletRegistrationBean<FF4jDispatcherServlet> ff4jDispatcherServletRegistrationBean(
            FF4jDispatcherServlet ff4jDispatcherServlet) {​​​​
        ServletRegistrationBean<FF4jDispatcherServlet> bean = new ServletRegistrationBean<FF4jDispatcherServlet>(
                ff4jDispatcherServlet, "/web-console/*");
        bean.setName("ff4j-console");
        bean.setLoadOnStartup(1);
        return bean;
    }​​​​

    @Bean
    @ConditionalOnMissingBean
    public FF4jDispatcherServlet getFF4jDispatcherServlet() {​​​​
        FF4jDispatcherServlet ff4jConsoleServlet = new FF4jDispatcherServlet();
        ff4jConsoleServlet.setFf4j(getFF4j());
        return ff4jConsoleServlet;
    }​​​​

    @Bean
    public FF4j getFF4j() {​​​​
        FF4j ff4j = new FF4j();
        FF4JCacheManager cacheManager = new FeatureCacheProviderEhCache();
        ff4j.setPropertiesStore(new PropertyStoreSpringJdbc(dataSource));
        ff4j.setFeatureStore(new FeatureStoreSpringJdbc(dataSource));
        ff4j.setEventRepository(new EventRepositorySpringJdbc(dataSource));
        ff4j.cache(cacheManager);
        

        // Enable audit mode
        ff4j.audit(true);

        return ff4j;
    }​​​​

}​​​​

WebConsole 会在提交数据库更改后立即反映它们，并且似乎没有命中缓存或缓存正在其中存储任何数据。

我希望能够使用此缓存而无需每次查找都进入数据库。

我们还尝试使用 InMemoryCacheManager 作为 FeatureCacheProviderEhCache 的替代品，但结果相同。在这两种实现中，我们确实在我们的 Web 控制台上看到了清除缓存按钮。

另外，有没有更好的方法来测试我的 api 调用是否实际上是从缓存而不是从数据库中获取数据，而不必关闭数据库？

更新：在实现我们自己的 FeatureCacheProviderEhCache 并登录后，我尝试访问 api/ff4j 并且featureNames在该响应中输入为空。请参考日志：

METHOD=getCacheFeatures, LINENO=160, MSG=getCacheFeatures :: [ name = ff4jCacheFeatures status = STATUS_ALIVE eternal = false overflowToDisk = true maxEntriesLocalHeap = 10000 maxEntriesLocalDisk = 10000000 memoryStoreEvictionPolicy = LRU timeToLiveSeconds = 120 timeToIdleSeconds = 120 persistence = LOCALTEMPSWAP diskExpiryThreadIntervalSeconds = 120 cacheEventListeners: ; orderedCacheEventListeners:  maxBytesLocalHeap = 0 overflowToOffHeap = false maxBytesLocalOffHeap = 0 maxBytesLocalDisk = 0 pinned = false ]
METHOD=listCachedFeatureNames, LINENO=59, MSG=listCachedFeatureNames[]
METHOD=getCacheFeatures, LINENO=160, MSG=getCacheFeatures :: [ name = ff4jCacheFeatures status = STATUS_ALIVE eternal = false overflowToDisk = true maxEntriesLocalHeap = 10000 maxEntriesLocalDisk = 10000000 memoryStoreEvictionPolicy = LRU timeToLiveSeconds = 120 timeToIdleSeconds = 120 persistence = LOCALTEMPSWAP diskExpiryThreadIntervalSeconds = 120 cacheEventListeners: ; orderedCacheEventListeners:  maxBytesLocalHeap = 0 overflowToOffHeap = false maxBytesLocalOffHeap = 0 maxBytesLocalDisk = 0 pinned = false ]

这是 API 的响应

缓存已创建，但未在其中存储任何值。我正在按照第一个答案中所说的方式设置缓存。我的日志，当我打印 listCachedFeatures() 时，它也打印为空。我仍然无法featureNames在缓存中看到。我没有正确配置哪个部分？

4

1 回答 1

0

首先，我想确认您正确使用了缓存。ff4j.cache(cacheManager)是你想要做的。这就是正在发生的事情：

public FF4j cache(FF4JCacheManager cm) {
    FF4jCacheProxy cp = new FF4jCacheProxy(getFeatureStore(), getPropertiesStore(), cm);
    setFeatureStore(cp);
    setPropertiesStore(cp);
    return this;
}

  1. 当您通过 Web 控制台编辑功能或属性值时，FF4j知道需要逐出缓存并立即更新数据库（缓存将仅用于读取）。

  2. FeatureCacheProviderEhCache并InMemoryCacheManager以同样的方式工作。首先使用JSR107。这是个人喜好，也许使用 ehcache 你可以稍后切换到像 Terracotta 这样的分布式缓存。

  3. 如何知道只使用缓存而不使用数据库（读取时）？您可以使用 AOP 创建一个建议来装饰类FeatureCacheProviderEhCache，或者更基本地在项目中复制该类，使用适当的日志更新方法并将您的类用作 CacheManager。

  4. 您也可以考虑在微服务级别使用缓存（如果用 Java 实现），而不仅仅是在 Web 控制台中。如果这样做，您可以通过不执行 REST 调用来获取 JSON 来节省一些时间。

  5. EhCache 和 InMemory 缓存就像内存中的名称一样工作，这意味着 2 个微服务在缓存中可能有不同的值。如果你想在微服务之间进行一致的缓存（不是强制性的），你想使用分布式缓存，如 REDIS 或 HAZELCAST。

于 2021-04-09T20:30:32.113 回答