Wildfly - Infinispan 事务配置

Question

我正在使用带有 Infinispan (6.0.2) 的 Wildfly 8.2，并且我正在尝试将某个 Oracle 数据库表中的所有值缓存在 Infispan 缓存中。在大多数情况下，它似乎有效，但有时却无效。访问 cache.values() 时（这对于性能来说也可能不是一个好主意，但只是一个示例），它有时看起来是空的，有时它包含正确的值。因此，我认为事务的配置可能存在问题。当使 Infinispan 缓存非事务性时，问题就消失了。

访问缓存和数据库的服务是一个带有容器管理事务的 EJB bean。在初始化服务时，所有数据都从数据库加载（它不包含很多条目）。 根据what's new in ejb 3.2，应该可以在 EJB Singleton bean 中以事务方式访问数据库。

数据源和 Infinispan 缓存的配置是否正确？我可以在 Infinispan 中使用非 XA 数据源并期望它始终如一地工作吗？根据Infinispan doc，NON_XA表示Infinispan注册为Synchronization，应该没问题吧？

standalone-full.xml 中的缓存配置如下（删除<transaction mode="NON_XA" locking="PESSIMISTIC"/> 时问题消失，代价是没有事务缓存）：

        <cache-container name="cacheContainer" start="EAGER">
            <local-cache name="my_table_cache">
                <locking isolation="REPEATABLE_READ"/>
                <transaction mode="NON_XA" locking="PESSIMISTIC"/>
            </local-cache>
        </cache-container>

Oracle DS 定义如下

           <datasource jndi-name="java:jboss/datasources/myDataSource" pool-name="dataSource" enabled="true">
                <connection-url>jdbc:oracle:thin:@127.0.0.1:1523:orcl</connection-url>
                <driver>ojdbc7.jar</driver>
                <pool>
                    <max-pool-size>25</max-pool-size>
                </pool>
                <security>
                    <user-name>myuser</user-name>
                    <password>myuser</password>
                </security>
                <timeout>
                    <blocking-timeout-millis>5000</blocking-timeout-millis>
                </timeout>
            </datasource>

我的服务（dao 使用简单的 JDBC 操作，而不是 Hibernate 或类似的）

@Singleton
@ConcurrencyManagement(ConcurrencyManagementType.BEAN)
public class MyService {

@Resource(lookup = "java:jboss/infinispan/container/cacheContainer")
protected EmbeddedCacheManager cm;

protected Cache<String, MyEntity> cache;

@PostConstruct
private void init() {
    try {
        cache = getCache();
    } catch (SQLException ex) {
        log.fatal("could not initialize caches", ex);
        throw new IllegalStateException(ex);
    }
}

public Cache<String, MyEntity> getCache() {
    Cache<String, MyEntity> cache = cm.getCache(getCacheName(), true);
    fillCache(cache);
    return cache;
}

protected void fillCache(Cache<String, MyEntity> cache) {
    List<MyEntity> entities = myDao.getEntities();
    for (MyEntity e : entities) {
        cache.put(e.getKey, e);
    }
}

public MyEntity getEntity(String key) {
    return cache.get(key);
}
public void insert(MyEntity entity) {
    myDao.insert(entity);
    cache.put(entity.getKey(), entity);
}
public void debug() {
    log.debug(cache.values());
}
}

Answer 1

根据接受的答案，配置是正确的。 如果有人有类似的问题： 问题似乎是，像MyService.getEntity() 这样的读取方法之一在某些特定于应用程序的上下文中被非常频繁地调用（我不知道），因此使用乐观锁定和 READ_COMMITTED 而不是 REPEATABLE_READ 似乎可以使它像预计。

Answer 2

当使用 NON_XA 事务时，未能在缓存中提交 TX 可能会让事务提交，并且您不会收到任何告诉您缓存不一致的异常。

至于cache.values()，在 Infinispan 7.0 之前它只返回本地条目，但是在您的情况下这无关紧要 - 使用本地缓存，所有条目都是本地的。此操作的事务一致性应该保持。我看不出你的配置有什么问题。

一般来说，我建议在 Hibernate ORM 中使用 Infinispan 模块，而不是像您在此处显示的那样尝试自己进行缓存。