EhCache 3.1.3持久性问题

Question

我在ehcache中存在持久性问题。缓存本身在第一次启动时工作正常，但当我重新启动tomcat servlet时，它不记得旧值。 这是我的初始化ehcache的代码。我没有使用任何XML。

import org.ehcache.Cache; 
import org.ehcache.PersistentCacheManager; 
import org.ehcache.Status; 
import org.ehcache.config.builders.CacheConfigurationBuilder; 
import org.ehcache.config.builders.CacheManagerBuilder; 
import org.ehcache.config.builders.ResourcePoolsBuilder; 
import org.ehcache.config.units.EntryUnit; 
import org.ehcache.config.units.MemoryUnit; 

PersistentCacheManager persistentCacheManager = 
    CacheManagerBuilder.newCacheManagerBuilder() 
      .with(CacheManagerBuilder.persistence("/cache")) 
      .withCache("test-cache", 
        CacheConfigurationBuilder.newCacheConfigurationBuilder(
          Integer.class, String.class, 
          ResourcePoolsBuilder.newResourcePoolsBuilder() 
            .heap(1, EntryUnit.ENTRIES) 
            .offheap(1, MemoryUnit.MB) 
            .disk(20, MemoryUnit.MB) 
        ) 
      ).build(true); 
Cache cache = persistentCacheManager.getCache("test-cache", Integer.class, String.class); 

log.info("Cache get 1 before putting: " + cache.get(1)); 
for(int i = 0; i< 1000; i++) { 
    cache.put(i,"Hello"); 
} 
log.info("Cache get 1 after putting: " + cache.get(1)); 

重新启动后，“前”日志语句的结果始终为空。

Answer 1

您需要将磁盘资源池声明为永久性的。它不是默认的。

.disk(20, MemoryUnit.MB, true) 

然后您的测试完美地工作。

完整的代码，包括关闭高速缓存管理器：

import org.ehcache.Cache; 
import org.ehcache.PersistentCacheManager; 
import org.ehcache.config.units.EntryUnit; 
import org.ehcache.config.units.MemoryUnit; 
import org.slf4j.Logger; 
import org.slf4j.LoggerFactory; 

import static org.ehcache.config.builders.CacheConfigurationBuilder.*; 
import static org.ehcache.config.builders.CacheManagerBuilder.*; 
import static org.ehcache.config.builders.ResourcePoolsBuilder.*; 

public class Main { 

    private static final Logger log = LoggerFactory.getLogger(Main.class); 

    public static void main(String[] args) { 
    try(PersistentCacheManager persistentCacheManager = 
     newCacheManagerBuilder() 
      .with(persistence("cache")) 
      .withCache("test-cache", 
       newCacheConfigurationBuilder(
        Integer.class, String.class, 
        newResourcePoolsBuilder() 
         .heap(1, EntryUnit.ENTRIES) 
         .offheap(1, MemoryUnit.MB) 
         .disk(20, MemoryUnit.MB, true) 
       ) 
      ).build(true)) { 
     Cache cache = persistentCacheManager.getCache("test-cache", Integer.class, String.class); 

     log.info("Cache get 1 before putting: " + cache.get(1)); 
     for (int i = 0; i < 1000; i++) { 
     cache.put(i, "Hello"); 
     } 
     log.info("Cache get 1 after putting: " + cache.get(1)); 
    } 
    } 
}