java - 缓存条目过期后未调用EhCache CacheLoaderWriter.load()

我已经使用CacheLoaderWriter创建了简单的EhCache测试：

Cache<Long, BigInteger> cache = cacheManager.getCache("aCache3", Long.class, BigInteger.class);
assertEquals(cache.get(2L), BigInteger.ONE);
Thread.sleep(6000);
assertEquals(cache.get(2L), BigInteger.ONE); // fails here with null!=1

当键2L的缓存条目在睡眠后到期时，cache.get（2L）返回空值。在我看来，它应该首先调用CacheLoaderWriter.load（）方法以从SoR获取正确的值，然后将其返回。

您能否解释一下为什么会发生这种情况以及如何更改这种行为？是否还有其他配置选项，或者我缺少什么？

ehcache.xml：

<cache alias="aCache3" uses-template="default">
    <key-type>java.lang.Long</key-type>
    <value-type>java.math.BigInteger</value-type>
    <expiry><ttl unit="seconds">4</ttl></expiry>
    <loader-writer >
        <class >com.example.jeight.ehcache.MapCacheLoaderWriter</class>
    </loader-writer>
    <resources>
        <heap unit="entries">10</heap>
        <disk persistent="false" unit="MB">10</disk>
    </resources>

MapCacheLoaderWriter：

public class MapCacheLoaderWriter implements CacheLoaderWriter<Long, BigInteger> {

    private Logger LOGGER = LoggerFactory.getLogger(getClass());

    private Map<Long, BigInteger> map;

    public  MapCacheLoaderWriter() {
        map = new HashMap<>();
    }

    @Override
    public void delete(Long k) throws Exception { }

    @Override
    public void deleteAll(Iterable<? extends Long> ks) throws BulkCacheWritingException, Exception {    }

    @Override
    public BigInteger load(Long k) throws Exception {
        LOGGER.info("Cache load: " + k);
        if (!map.containsKey(k)) {
            BigInteger v = fib(k);
            map.put(k, v);
        }
        return map.get(k);
    }

    @Override
    public Map<Long, BigInteger> loadAll(Iterable<? extends Long> ks) throws BulkCacheLoadingException, Exception {
        Map<Long, BigInteger> result = new HashMap<>();
        for (Long k : ks) {
            load(k);
        }
        return result;
    }

    @Override
    public void write(Long k, BigInteger v) throws Exception {
        LOGGER.info("Cache write: " + k + " " + v);
        map.put(k, v);
    }

    @Override
    public void writeAll(Iterable<? extends Entry<? extends Long, ? extends BigInteger>> kvMap)
        throws BulkCacheWritingException, Exception {
        for (Entry<? extends Long, ? extends BigInteger> k : kvMap) {
            write(k.getKey(), k.getValue());
        }
    }

    private BigInteger fib(long k) {
       // some code returning a non-null value
    }
}

最佳答案

这是一个需要修复的错误-Ehcache中的filed it。

感谢您的举报！

唯一没有问题的方法是将缓存限制为单个层-如果可以使用较小的条目集，则为堆；如果可以在每个get上添加反序列化，则为磁盘。

关于java - 缓存条目过期后未调用EhCache CacheLoaderWriter.load()，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/40396653/