3.5. 带有集群缓存的异步通信

所有集群缓存模式都可以配置为在 < replicated-cache/>、< distributed-cache> 或 &lt; invalidation-cache/& gt; 元素中 使用与 mode="ASYNC" 属性的异步通信。

使用异步通信时，原始器节点不会从其他节点接收有关操作状态的任何确认，因此无法检查它是否在其他节点上成功。

我们不推荐异步通信，因为它们可能会导致数据不一致，因此结果很难考虑。然而，有时速度比一致性更重要，而对于这些情况，可以使用 选项。

Asynchronous API 允许您使用同步通信，但不阻止用户线程。

有一个注意事项：异步操作不会保留程序顺序。如果线程调用 cache.putAsync (k, v1); cache.putAsync (k, v2)，则最终值 k 可以是 v1 或 v2。与使用异步通信相比，最终的值不能是一个节点上的 v1，另一个节点上的 v2。

由于 Cache 接口扩展 java.util.Map，因此 放置（密钥、值） 和 remove (key) 等写入方法默认返回前面的值。

在某些情况下，返回值可能不正确：

事务缓存在 3 和 4 时返回正确的之前值。但是，事务缓存在分布式模式中也有一个 getcha:，则 read-committed 隔离级别也以可重复读取的形式实施。这意味着 "double-checked locking" 示例无法正常工作：

Cache cache = ...
TransactionManager tm = ...

tm.begin();
try {
   Integer v1 = cache.get(k);
   // Increment the value
   Integer v2 = cache.put(k, v1 + 1);
   if (Objects.equals(v1, v2) {
      // success
   } else {
      // retry
   }
} finally {
  tm.commit();
}

Cache cache = ...
TransactionManager tm = ...

tm.begin();
try {
   Integer v1 = cache.get(k);
   // Increment the value
   Integer v2 = cache.put(k, v1 + 1);
   if (Objects.equals(v1, v2) {
      // success
   } else {
      // retry
   }
} finally {
  tm.commit();
}

实施此操作的正确方法是使用 cache.getAdvancedCache （）.withFlags (Flag.FORCE_WRITE_LOCK).get (k)。

在具有最佳锁定的缓存中，写入也可以返回过时的值。写入偏移检查可能会避免过时的值。