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)); 
    } 
    } 
}