apache - 配置和使用原子数据结构的 Geode 区域和锁

Question

我目前正在使用 Spring Boot Starter 1.4.2.RELEASE 和 Geode Core 1.0.0(通过 Maven 进行孵化)，针对由 Geode Locator 和 2 个缓存节点组成的本地 Docker 配置。

我在这里查阅了文档:

http://geode.apache.org/docs/guide/developing/distributed_regions/locking_in_global_regions.html

我已经配置了一个cache.xml 文件以便与我的应用程序一起使用，如下所示:

<?xml version="1.0" encoding="UTF-8"?>
<client-cache
        xmlns="http://geode.apache.org/schema/cache"
        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
        xsi:schemaLocation="http://geode.apache.org/schema/cache
                        http://geode.apache.org/schema/cache/cache-1.0.xsd"
        version="1.0">
    <pool name="serverPool">
        <locator host="localhost" port="10334"/>
    </pool>
    <region name="testRegion" refid="CACHING_PROXY">
        <region-attributes pool-name="serverPool"
                scope="global"/>
    </region>
</client-cache>

在我的 Application.java 中，我通过以下方式将该区域公开为 bean:

@SpringBootApplication
public class Application {

    @Bean
    ClientCache cache() {
        return new ClientCacheFactory()
                .create();
    }

    @Bean
    Region<String, Integer> testRegion(final ClientCache cache) {
        return cache.<String, Integer>getRegion("testRegion");
    }

    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }

}

在我的“服务”DistributedCounter.java中:

@Service
public class DistributedCounter {

@Autowired
private Region<String, Integer> testRegion;

/**
 * Using fine grain lock on modifier.
 * @param counterKey {@link String} containing the key whose value should be incremented.
 */
public void incrementCounter(String counterKey) {
    if(testRegion.getDistributedLock(counterKey).tryLock()) {
        try {
            Integer old = testRegion.get(counterKey);
            if(old == null) {
                old = 0;
            }
            testRegion.put(counterKey, old + 1);
        } finally {
            testRegion.getDistributedLock(counterKey).unlock();
        }
    }
}

我已经使用 gfsh 配置了一个名为/testRegion 的区域 - 但是没有选项表明它的类型应该是“GLOBAL”，只有各种其他选项可用 - 理想情况下，这应该是一个持久的、复制的缓存尽管如此，以下命令:

create region --name=/testRegion --type=REPLICATE_PERSISTENT

使用方法:http://geode.apache.org/docs/guide/getting_started/15_minute_quickstart_gfsh.html在我的两个节点配置上很容易看到持久性和复制的功能。

但是，上面的 DistributedCounter 中的锁定不会导致任何错误 - 但当两个进程尝试获取同一“键”上的锁时它不起作用 - 第二个进程不会被阻止获取锁。 Gemfire 论坛中有一个早期的代码示例，它使用 DistributedLockService - 当前文档警告不要将其用于锁定区域条目。

用于支持原子增量长整型“映射”的细粒度锁定用例是否是受支持的用例？如果是，如何正确配置它？

Answer 1

DistributedLock 和 RegionDistributedLock 的 Region API 仅支持全局范围的 Region。这些 DistributedLock 仅在集群内的 DistributedLockService 名称(即 Region 的完整路径名)内具有锁定范围。例如，如果全局区域存在于某个服务器上，则该区域的 DistributedLock 只能在该服务器或该集群内的其他服务器上使用。

缓存客户端最初是分层缓存的一种形式，这意味着一个集群可以作为客户端连接到另一个集群。如果客户端创建了实际的全局区域，则客户端内的 DistributedLock 将仅在该客户端及其所属集群内具有范围。 DistributedLock 不会以任何方式传播到此类客户端所连接的服务器。

正确的方法是在服务器上存在的全局区域上编写利用 DistributedLock API 的函数。您可以将这些函数部署到服务器，然后从客户端在服务器上调用它们。

一般来说，避免使用全局区域，因为每个单独的 put 都会在服务器集群内获取一个 DistributedLock，这是一个非常昂贵的操作。

您可以通过在服务器上创建自定义 DistributedLockService 来对非全局区域执行类似的操作，然后使用函数来锁定/解锁需要在该集群内全局同步的代码。在这种情况下，区域(对于非全局区域)上的 DistributedLock 和 RegionDistributedLock API 将不可用，并且所有锁定都必须​​使用 DistributedLockService API 在服务器上的函数内完成。