zookeeper分布式集群Curator的分布式整型int计数器SharedCount

import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.framework.recipes.shared.SharedCount;
import org.apache.curator.retry.ExponentialBackoffRetry;

public class DistributedCounterExample {
    private static final String ZOOKEEPER_ADDRESS = "localhost:2181";
    private static final String COUNTER_PATH = "/my_counter";

    public static void main(String[] args) throws Exception {
        CuratorFramework client = CuratorFrameworkFactory.newClient(ZOOKEEPER_ADDRESS, new ExponentialBackoffRetry(1000, 3));
        client.start();

        SharedCount sharedCount = new SharedCount(client, COUNTER_PATH, 0);
        sharedCount.start();

        // 增加计数器
        System.out.println("Current count: " + sharedCount.getCount());
        sharedCount.addListener((curatorFramework, event) -> {
            System.out.println("Count changed: " + sharedCount.getCount());
        });
        sharedCount.trySetCount(sharedCount.getCount() + 1);

        // 停止资源
        sharedCount.close();
        client.close();
    }
}