<!-- zookeeper支持 -->
<dependency>
   <groupId>org.apache.zookeeper</groupId>
   <artifactId>zookeeper</artifactId>
   <version>3.6.4</version>
</dependency>
<!-- curator-recipes -->
<dependency>
   <groupId>org.apache.curator</groupId>
   <artifactId>curator-recipes</artifactId>
   <version>5.5.0</version>
</dependency>
<!-- curator-framework -->
<dependency>
   <groupId>org.apache.curator</groupId>
   <artifactId>curator-framework</artifactId>
   <version>5.5.0</version>
</dependency>

import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.retry.ExponentialBackoffRetry;

public class CuratorExample {
    public static void main(String[] args) {
        // 創(chuàng)建 CuratorFramework 實例
        CuratorFramework client = CuratorFrameworkFactory.builder()
                .connectString("127.0.0.1:2181") // ZooKeeper 地址
                .sessionTimeoutMs(5000)
                .connectionTimeoutMs(3000)
                .retryPolicy(new ExponentialBackoffRetry(1000, 3))
                .build();

        // 啟動客戶端
        client.start();

        System.out.println("CuratorFramework 已啟動");

        // 關(guān)閉客戶端
        client.close();
    }
}

import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.retry.ExponentialBackoffRetry;
import org.apache.curator.framework.recipes.locks.InterProcessMutex;

import java.util.concurrent.TimeUnit;

public class DistributedLockExample {
    public static void main(String[] args) throws Exception {
        // 初始化 CuratorFramework
        CuratorFramework client = CuratorFrameworkFactory.builder()
                .connectString("127.0.0.1:2181")
                .retryPolicy(new ExponentialBackoffRetry(1000, 3))
                .build();
        client.start();

        // 創(chuàng)建分布式鎖
        InterProcessMutex lock = new InterProcessMutex(client, "/distributed-lock");

        // 嘗試獲取鎖
        if (lock.acquire(10, TimeUnit.SECONDS)) {
            try {
                System.out.println("成功獲取鎖，執(zhí)行任務(wù)...");
                Thread.sleep(5000); // 模擬任務(wù)
            } finally {
                lock.release();
                System.out.println("鎖已釋放");
            }
        } else {
            System.out.println("未能獲取鎖");
        }

        client.close();
    }
}

import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.retry.ExponentialBackoffRetry;
import org.apache.curator.framework.recipes.leader.LeaderSelector;
import org.apache.curator.framework.recipes.leader.LeaderSelectorListenerAdapter;

public class LeaderElectionExample {
    public static void main(String[] args) throws InterruptedException {
        CuratorFramework client = CuratorFrameworkFactory.builder()
                .connectString("127.0.0.1:2181")
                .retryPolicy(new ExponentialBackoffRetry(1000, 3))
                .build();
        client.start();

        // 創(chuàng)建 LeaderSelector
        LeaderSelector leaderSelector = new LeaderSelector(client, "/leader-election", new LeaderSelectorListenerAdapter() {
            @Override
            public void takeLeadership(CuratorFramework client) throws Exception {
                System.out.println("成為 Leader，執(zhí)行任務(wù)...");
                Thread.sleep(3000); // 模擬任務(wù)
                System.out.println("任務(wù)完成，釋放 Leader 權(quán)限");
            }
        });

        leaderSelector.autoRequeue(); // 自動重新排隊參與選舉
        leaderSelector.start();

        Thread.sleep(Integer.MAX_VALUE); // 保持主線程運行
        client.close();
    }
}

import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.framework.recipes.cache.NodeCache;
import org.apache.curator.retry.ExponentialBackoffRetry;

public class NodeCacheExample {
    public static void main(String[] args) throws Exception {
        CuratorFramework client = CuratorFrameworkFactory.builder()
                .connectString("127.0.0.1:2181")
                .retryPolicy(new ExponentialBackoffRetry(1000, 3))
                .build();
        client.start();

        // 創(chuàng)建 NodeCache
        NodeCache nodeCache = new NodeCache(client, "/test-node");
        nodeCache.getListenable().addListener(() -> {
            System.out.println("節(jié)點數(shù)據(jù)變更，新的數(shù)據(jù)為：" + new String(nodeCache.getCurrentData().getData()));
        });

        nodeCache.start();

        // 創(chuàng)建節(jié)點并修改數(shù)據(jù)
        client.create().orSetData().forPath("/test-node", "initial-data".getBytes());
        Thread.sleep(1000);
        client.setData().forPath("/test-node", "updated-data".getBytes());

        Thread.sleep(5000); // 保持運行觀察結(jié)果
        client.close();
    }
}