JPA/Eclipselink @Cache失效忽略

Question

我目前正在评估JPA/Eclipselink作为我们目前非常丑陋的jdbc数据库访问的替代方案。情况如下：

多个客户端访问相同的数据库，有时编辑相同的数据。这些数据应该定期刷新，并且只能在短时间内缓存。从我的理解来看，@Cache注释应该完全是这样。虽然线程休眠我在数据库中改变一个值

... 
[EL Finest]: query: 2013-06-19 14:30:55.897--UnitOfWork(31211079)--Thread(Thread[main,5,main])--Execute query ReadAllQuery(referenceClass=Todo sql="SELECT ID, DESCRIPTION, SUMMARY FROM TODO") 
[EL Finest]: connection: 2013-06-19 14:30:55.907--ServerSession(7427424)--Connection(7633596)--Thread(Thread[main,5,main])--Connection acquired from connection pool [default]. 
[EL Fine]: sql: 2013-06-19 14:30:55.907--ServerSession(7427424)--Connection(7633596)--Thread(Thread[main,5,main])--SELECT ID, DESCRIPTION, SUMMARY FROM TODO 
[EL Finest]: connection: 2013-06-19 14:30:55.924--ServerSession(7427424)--Connection(7633596)--Thread(Thread[main,5,main])--Connection released to connection pool [default]. 
Query 1 read 
1: Todo [id=1, summary=s1, description=d1] 
1: Todo [id=2, summary=qwet, description=d2] 
[EL Finest]: query: 2013-06-19 14:31:25.932--UnitOfWork(31211079)--Thread(Thread[main,5,main])--Execute query ReadAllQuery(referenceClass=Todo sql="SELECT ID, DESCRIPTION, SUMMARY FROM TODO") 
[EL Finest]: connection: 2013-06-19 14:31:25.932--ServerSession(7427424)--Connection(7633596)--Thread(Thread[main,5,main])--Connection acquired from connection pool [default]. 
[EL Fine]: sql: 2013-06-19 14:31:25.932--ServerSession(7427424)--Connection(7633596)--Thread(Thread[main,5,main])--SELECT ID, DESCRIPTION, SUMMARY FROM TODO 
[EL Finest]: connection: 2013-06-19 14:31:25.934--ServerSession(7427424)--Connection(7633596)--Thread(Thread[main,5,main])--Connection released to connection pool [default]. 
Query 2 read 
1: Todo [id=1, summary=s1, description=d1] 
2: Todo [id=1, summary=s1, description=d1] 
true 
1: Todo [id=2, summary=qwet, description=d2] 
2: Todo [id=2, summary=qwet, description=d2] 
true 

：

下面的代码是基于JPA /的EclipseLink上Vogella

@Entity 
@Cache(expiry = 100) 
public class Todo { 
    @Id 
    @GeneratedValue(strategy = GenerationType.IDENTITY) 
    private Long id; 
    private String summary; 
    private String description; 
... getter/setter/toString omited 
} 

public static void main(String[] args) throws InterruptedException { 
     EntityManagerFactory factory = 
       Persistence.createEntityManagerFactory("mysql"); 
     EntityManager em = factory.createEntityManager(); 

     TypedQuery<Todo> q = em.createQuery("SELECT t FROM Todo t", Todo.class); 

     List<Todo> todoList = q.getResultList(); 
     System.out.println("Query 1 read"); 
     for (int i = 0; i < todoList.size(); i++) { 
      System.out.println("1: " + todoList.get(i)); 
     } 

     Thread.sleep(30000); 

     TypedQuery<Todo> q2 = 
       em.createQuery("SELECT t FROM Todo t", Todo.class); 
     // q2.setHint("javax.persistence.cache.storeMode", "REFRESH"); 

     List<Todo> todoList2 = q2.getResultList(); 
     System.out.println("Query 2 read"); 

     for (int i = 0; i < todoList.size(); i++) { 
      System.out.println("1: " + todoList.get(i)); 
      System.out.println("2: " + todoList2.get(i)); 
      System.out.println(todoList.get(i) == todoList2.get(i)); 
     } 
    } 

<?xml version="1.0" encoding="UTF-8"?> 
<persistence version="2.0" 
    xmlns="http://java.sun.com/xml/ns/persistence" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
    xsi:schemaLocation="http://java.sun.com/xml/ns/persistence http://java.sun.com/xml/ns/persistence/persistence_2_0.xsd"> 


    <persistence-unit name="mysql" transaction-type="RESOURCE_LOCAL"> 
     <provider>org.eclipse.persistence.jpa.PersistenceProvider</provider> 
     <exclude-unlisted-classes>false</exclude-unlisted-classes> 
     <properties> 
      <property name="javax.persistence.jdbc.password" value="" /> 
      <property name="javax.persistence.jdbc.user" value="root" /> 
      <property name="javax.persistence.jdbc.driver" value="com.mysql.jdbc.Driver" /> 
      <property name="javax.persistence.jdbc.url" value="jdbc:mysql://localhost:3306/test" /> 
      <property name="javax.persistence.ddl-generation" value="create-tables" /> 
      <property name="javax.persistence.logging.level" value="ALL" /> 
      <property name="eclipselink.logging.level" value="ALL"/> 
     </properties> 
    </persistence-unit> 
</persistence> 

运行PROGRAMM产生以下输出。我期望从数据库中获得新值，因为缓存中的值应该已过期。它似乎代码简单地忽略@Cache注释。我也尝试过其他各种设置，例如type = CacheType.NONE和alwaysRefresh = true，但没有任何改变。

当我添加storeMode-QueryHint时，查询总是刷新结果。这不完全是我想要的，似乎我需要将它添加到每个非常容易出错的查询中。但是，Cache注释被忽略仍然很奇怪。

我也尝试使用DescriptorCustomizer，但它也没有效果，尽管正在使用（用断点测试）。

public void customize(ClassDescriptor descriptor) { 
     descriptor.alwaysRefreshCache(); 
     descriptor.alwaysRefreshCacheOnRemote(); 
     descriptor.disableCacheHits(); 
     descriptor.disableCacheHitsOnRemote(); 
    } 

更新：

有些话我开发的系统。它是读取/写入我们的主数据的模块。因此，例如，在同一用户的内存中存在两次用户对象时，感觉不对。另外，在我测试了@ReadOnly注解之后，我注意到@Cache注释的isolation参数似乎可行，但仍然没有任何关于expire，alwaysrefresh等的信息。

Answer 1

您正在使用相同的EntityManager实例。缓存设置适用于共享缓存，而EntityManager需要将相同的对象保留在内存中，直到它被关闭或清除 - 否则简单的查找操作可能会清除正在运行的事务中的更改。获取新的EntityManager或清除现有的EntityManager会导致EntityManager根据需要转到共享缓存和/或数据库。

如果您确实需要在当前EM上下文中刷新对象，则必须显式调用em.refresh或使用查询提示，以便它知道要用数据库中的内容清除任何现有更改。

每个EM代表一个事务上下文，由于每个线程都应该有自己的EntityManager，因此应用程序中已经有多个实体副本。如果您依赖从EntityManager读取的特定实例并且始终反映当前的更改，那么您将遇到麻烦 - 它只能真正反映读取数据库时的内容。这就是为什么在必要时合并更改很重要，并且可能不是在应用程序中缓存对象的好主意 - 而是根据需要从EntityManagers访问它们。

如果您想要该对象并且没有进行更改，请将其标记为只读，这会将其从共享缓存而不是EM中提取出来，并反映缓存设置：http://wiki.eclipse.org/EclipseLink/UserGuide/JPA/Basic_JPA_Development/Caching/Shared_and_Isolated#Read-Only_Entities。如果实体被缓存在共享缓存中，这将成为您返回的实例，并且所有EM将返回相同的对象实例 - 由您的应用来管理实体本身的并发问题。