3

我们尝试使用 infinispan 作为带有读锁的远程缓存。客户端正在使用“put”进行读取以获取密钥上的锁定,如 infinispan 文档中所述的悲观事务缓存部分“当 cache.put(k1,v1) 返回时,k1 被锁定并且没有其他事务在集群中的任何地方运行都可以写入它。仍然可以读取 k1。当事务完成(提交或回滚)时,k1 上的锁被释放。所以场景:

transactionManager.begin();
// read with put to acquire write lock
String value = getRemoteCache().get(key);
getRemoteCache().put(key, value);

// do smthing with the value

getRemoteCache().put(key, newValue);
transactionManager.commit();

远程缓存配置为带有悲观锁定的事务性:

   <local-cache name="default"> <locking isolation="REPEATABLE_READ" acquire-timeout="30000" concurrency-level="1000" striping="false"/>
        <transaction  mode="NON_XA" locking="PESSIMISTIC"/>
   </local-cache>

并且客户端正在使用配置访问 remoteCacheManager 作为 HOTROD 客户端:

  ConfigurationBuilder builder = new ConfigurationBuilder();
    // add more configurations ?
    builder.transaction().transactionManagerLookup(GenericTransactionManagerLookup.getInstance());
    builder.transaction().transactionMode(TransactionMode.NON_XA);
    builder.addServer().host(readServerHostConfiguration()).port(readServerPortConfiguration());
    return new RemoteCacheManager(builder.build(), true);

尽管客户端可以同时“使用 put 读取”一个值,但 Concurent 客户端在读取该值时并没有收到异常,而是稍后通过提交事务。这是预期的行为吗?

4

1 回答 1

4

是的。

如文档(Hot Rod Transaction)中所述,客户端上运行的事务具有乐观语义。只有在提交期间才会获取锁。

悲观锁定事务仅在嵌入式模式下有效。

于 2018-09-28T09:22:49.493 回答