EhCache磁盘持久化 - 坚持一个任意对象

问题描述:

我想使用EhCache来坚持磁盘上的对象,所以下次我将运行我的应用程序,它会从它加载。在他们的文档,存在一种使用PersistentCacheManager类这样做下面的例子:EhCache磁盘持久化 - 坚持一个任意对象

PersistentCacheManager persistentCacheManager = CacheManagerBuilder.newCacheManagerBuilder().with(CacheManagerBuilder.persistence(new File(getStoragePath(), "myData"))).withCache("persistent-cache", CacheConfigurationBuilder.newCacheConfigurationBuilder(Long.class, String.class, 
ResourcePoolsBuilder.newResourcePoolsBuilder().disk(10, MemoryUnit.MB, true))).build(true); 
persistentCacheManager.close(); 

的例子能正常工作,但对我的问题,如果是,CacheConfigurationBuilder对象定义键和值硬编码到的类长和字符串。我想坚持仲裁课的实例,而不是预先定义哪些实例。另外,例如,CacheConfigurationBuilder不会采用Object.class或HashMap.class。

如何使用EhCache在磁盘上坚持一个任意实例类?

+0

按照[文档](http://www.ehcache.org/apidocs/3.0.3/org/ehcache/config/builders /CacheConfigurationBuilder.html#newCacheConfigurationBuilder-java.lang.Class-java.lang.Class-org.ehcache.config.Builder-)键和值可以是任何类型 - 示例使用Long和String,但这并不意味着你只能使用这些类型! – alfasin

+0

类型Object或HashMap导致运行时异常,表明该类型不可调整。 –

+0

然后使用可序列化的类型;) – alfasin

Ehcache可以取任何键或值。默认情况下,它要求它们必须是可序列化的。否则,它无法知道如何将它存储在磁盘或磁盘上。

HashMap是可序列化的,所以你不会从中得到警告。 Map不是。所以你会得到一个警告,但如果实现实际上是可序列化的,它仍然可以工作。

但是,如果你确实存储了一个对象而不是可序列化的,你确实会得到一个异常。解决方案是指定一个键和/或值序列化程序,告诉Ehcache如何存储任何你想要的。完整的文档是there

现在我们来看一个例子。您需要缓存的课程MyClass

public class MyClass { 
    private String value; 

    public MyClass(String value) { 
    this.value = value; 
    } 

    public String getValue() { 
    return value; 
    } 

    @Override 
    public boolean equals(Object o) { 
    if(this == o) { return true; } 
    if(o == null || getClass() != o.getClass()) { return false; } 
    MyClass myClass = (MyClass) o; 
    return Objects.equals(value, myClass.value); 
    } 

    @Override 
    public int hashCode() { 
    return value != null ? value.hashCode() : 0; 
    } 
} 

而且一个测试,确保它的工作。

@Test 
public void test() { 
    try(CacheManager persistentCacheManager = 
     newCacheManagerBuilder() 
      .withCache("test-cache", 
      newCacheConfigurationBuilder(Integer.class, MyClass.class, 
       newResourcePoolsBuilder().offheap(1, MemoryUnit.MB))) 
      .withSerializer(MyClass.class, MySerializer.class) 
      .build(true)) { 

    Cache<Integer, MyClass> cache = persistentCacheManager.getCache("test-cache", Integer.class, MyClass.class); 
    cache.put(1, new MyClass("test")); 
    MyClass actual = cache.get(1); 
    assertEquals("test", actual.getValue()); 
    } 

} 

您的序列化器将是这样的:

public class MySerializer implements Serializer<MyClass> { 

    public MySerializer(ClassLoader unused) { 
    } 

    @Override 
    public ByteBuffer serialize(MyClass object) throws SerializerException { 
    try(ByteArrayOutputStream bout = new ByteArrayOutputStream(); ObjectOutputStream oout = new ObjectOutputStream(bout)) { 
     oout.writeUTF(object.getValue()); 
     oout.flush(); 
     return ByteBuffer.wrap(bout.toByteArray()); 
    } catch (IOException e) { 
     throw new SerializerException(e); 
    } 
    } 

    @Override 
    public MyClass read(ByteBuffer binary) throws ClassNotFoundException, SerializerException { 
    try(ObjectInputStream oin = new ObjectInputStream(new ByteBufferInputStream(binary))) { 
     return new MyClass(oin.readUTF()); 
    } catch (IOException e) { 
     throw new SerializerException(e); 
    } 
    } 

    @Override 
    public boolean equals(MyClass object, ByteBuffer binary) throws ClassNotFoundException, SerializerException { 
    return object.equals(read(binary)); 
    } 

} 
+0

您能否详细说明答案的最后部分,关于不可序列化的对象的存储,并且可能给出一个代码示例? –

+0

这里是一个例子 – Henri