zookeeper分布式集群Curator的分布式long型计数器DistributedAtomicLong

import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.framework.recipes.atomic.DistributedAtomicLong;
import org.apache.curator.retry.ExponentialBackoffRetry;
 
public class DistributedCounterExample {
    private static final String ZOOKEEPER_ADDRESS = "localhost:2181";
    private static final String COUNTER_PATH = "/distributed_counter";
 
    public static void main(String[] args) throws Exception {
        CuratorFramework client = CuratorFrameworkFactory.newClient(
                ZOOKEEPER_ADDRESS, new ExponentialBackoffRetry(1000, 3));
        client.start();
 
        DistributedAtomicLong counter = new DistributedAtomicLong(
                client, COUNTER_PATH, new ExponentialBackoffRetry(1000, 3));
 
        // 获取当前计数器的值
        System.out.println("Current counter value: " + counter.get().postValue());
 
        // 递增计数器
        System.out.println("Incremented counter value: " + counter.increment().postValue());
 
        // 关闭客户端
        client.close();
    }
}

这段代码演示了如何使用Curator的DistributedAtomicLong来创建和操作一个分布式计数器。首先，它创建了一个Curator客户端，并设置了重试策略。然后，它创建了一个DistributedAtomicLong实例，并指定了共享计数器的ZooKeeper路径。接下来，它获取了计数器的当前值并打印出来，然后递增了计数器的值，并再次打印出新的值。最后，它关闭了Curator客户端。这个例子简单地展示了如何使用Curator框架中的原子长整型计数器，这对于分布式系统中需要全局一致的计数器场景非常有用。