0

我想使用 EhCache 将对象持久保存在磁盘上，因此下次我将运行我的应用程序时，它将从中加载。在他们的文档中，有以下示例使用 PersistentCacheManager 类来执行此操作：

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 对象定义硬编码为 Long 和 String 的键和值的类，对我来说是个问题。我想保留仲裁类的实例，而不是预定义哪些实例。此外，例如，CacheConfigurationBuilder 不会采用 Object.class 或 HashMap.class。

如何使用 EhCache 将任意实例类持久保存在磁盘上？

4

1 回答 1

2

Ehcache 可以采用任何键或值。默认情况下，它要求它们必须是可序列化的。否则，它不知道如何将其存储在堆外或磁盘上。

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

但是，如果您确实存储了一个不可序列化的对象，那么您确实会遇到异常。解决方案是指定一个键和/或一个值序列化程序，告诉 Ehcache 如何存储您想要的任何内容。完整的文档在那里。

现在让我们看一个例子。你是一个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));
  }

}
于 2017-08-13T23:26:09.553 回答