3.7. 热 Rod Java 客户端事务

服务器中的缓存还必须是事务处理，客户端才会参与 JTA 事务。

需要以下服务器配置，否则只进行事务回滚：

例如：

<replicated-cache name="hotrodReplTx">
  <locking isolation="REPEATABLE_READ"/>
  <transaction mode="NON_XA" locking="PESSIMISTIC"/>
</replicated-cache>

热 Rod 事务有自己的恢复机制。

事务的 RemoteCache 会根据缓存进行配置。例外是事务的超时，它是全局的，因为单个事务可以与多个 RemoteCaches 交互。

以下示例演示了如何为缓存 my-cache 配置事务 RemoteCache ：

org.infinispan.client.hotrod.configuration.ConfigurationBuilder cb = new org.infinispan.client.hotrod.configuration.ConfigurationBuilder();
//other client configuration parameters
cb.transactionTimeout(1, TimeUnit.MINUTES);
cb.remoteCache("my-cache")
   .transactionManagerLookup(GenericTransactionManagerLookup.getInstance())
   .transactionMode(TransactionMode.NON_XA);

有关配置参数的文档，请参阅配置 Builder 和 RemoteCache ConfigurationBuilder Javadoc。

您还可以使用属性文件配置 Java Hot Rod 客户端，如下例所示：

infinispan.client.hotrod.cache.my-cache.transaction.transaction_manager_lookup = org.infinispan.client.hotrod.transaction.lookup.GenericTransactionManagerLookup
infinispan.client.hotrod.cache.my-cache.transaction.transaction_mode = NON_XA
infinispan.client.hotrod.transaction.timeout = 60000

TransactionMode 控制 RemoteCache 如何与 TransactionManager 交互。

在 Data Grid 配置和客户端设置中，事务模式都相同。将以下模式与客户端搭配使用，请参阅服务器的 Data Grid 配置模式：

事务使用键的初始值来检测冲突。

例如，当事务开始时，"k" 的值为 "v"。在准备阶段，事务从服务器获取"k"以读取值。如果值已更改，事务会回滚以避免冲突。

forceReturnValue 参数控制 RemoteCache 的写入操作，并帮助避免冲突。它有以下值：

以下事务提供了一个示例，其中 forceReturnValue 参数可以防止出现冲突的写入操作：

RemoteCache<String, String> cache = ...
TransactionManager tm = ...

tm.begin();
cache.put("k", "v1");
tm.commit();

RemoteCache<String, String> cache = ...
TransactionManager tm = ...

tm.begin();
cache.put("k", "v2");
tm.commit();

在这个示例中，TX1 和 TX2 并行执行。"k"的初始值为 "v"。

以下事务包括 cache.get （） 操作，以便在执行 cache.put （） 操作前读取 "k" 的值：

RemoteCache<String, String> cache = ...
TransactionManager tm = ...

tm.begin();
cache.get("k");
cache.put("k", "v1");
tm.commit();

RemoteCache<String, String> cache = ...
TransactionManager tm = ...

tm.begin();
cache.get("k");
cache.put("k", "v2");
tm.commit();

在前面的示例中，TX1 和 TX2 都是读取密钥，因此 forceReturnValue 参数不会生效。一个事务提交，另一个回滚。但是 cache.get （） 操作需要额外的服务器请求。如果您不要求服务器请求的 cache.put （） 操作返回值效率低下。

以下示例演示了如何使用在 RemoteCacheManager 中配置的 TransactionManager 和 TransactionMode ：

//Configure the transaction manager and transaction mode.
org.infinispan.client.hotrod.configuration.ConfigurationBuilder cb = new org.infinispan.client.hotrod.configuration.ConfigurationBuilder();
cb.remoteCache("my-cache")
    .transactionManagerLookup(RemoteTransactionManagerLookup.getInstance())
    .transactionMode(TransactionMode.NON_XA);

RemoteCacheManager rcm = new RemoteCacheManager(cb.build());

//The my-cache instance uses the RemoteCacheManager configuration.
RemoteCache<String, String> cache = rcm.getCache("my-cache");

//Return the transaction manager that the cache uses.
TransactionManager tm = cache.getTransactionManager();

//Perform a simple transaction.
tm.begin();
cache.put("k1", "v1");
System.out.println("K1 value is " + cache.get("k1"));
tm.commit();