@Test
public void testConnect() {
    //重試策略
    ExponentialBackoffRetry retry = new ExponentialBackoffRetry(3000, 10);
    //第一種方式
    CuratorFramework client = CuratorFrameworkFactory.newClient("192.168.130.120:2181", 60 * 1000, 15 * 1000, retry);

    //第二種方式
    CuratorFramework client1 = CuratorFrameworkFactory.builder().connectString("192.168.130.120:2181")
        .sessionTimeoutMs(60 * 1000)
        .connectionTimeoutMs(15 * 1000)
        .retryPolicy(retry).namespace("hrbu").build();
    //開(kāi)啟連接
    client.start();
}

@Test
public void testCreate1() throws Exception {
    //基本創(chuàng)建
    CreateBuilder createBuilder = client.create();
    //創(chuàng)建時(shí)不指定數(shù)據(jù)，會(huì)將當(dāng)前客戶端ip存到里面
    createBuilder.forPath("/app1");
    //指定數(shù)據(jù)
    createBuilder.forPath("/app2", "hello".getBytes());
}

@Test
public void testCreate2() throws Exception {
    CreateBuilder createBuilder = client.create();

    //設(shè)置節(jié)點(diǎn)類(lèi)型，默認(rèn)的類(lèi)型是持久化
    //CreateMode是枚舉類(lèi)型
    createBuilder.withMode(CreateMode.EPHEMERAL).forPath("/app3");
}

@Test
public void testCreate3() throws Exception {
    CreateBuilder createBuilder = client.create();
    //創(chuàng)建多級(jí)節(jié)點(diǎn)，如果父節(jié)點(diǎn)不存在，則創(chuàng)建父節(jié)點(diǎn)。
    createBuilder.creatingParentContainersIfNeeded().forPath("/app4/app4_1");
}

@Test
public void testGet() throws Exception {
    //查詢(xún)數(shù)據(jù)
    byte[] bytes = client.getData().forPath("/app1");
    System.out.println(new String(bytes));

    //查詢(xún)子節(jié)點(diǎn)
    List<String> strings = client.getChildren().forPath("/app4");
    strings.forEach(System.out::println);

    //查詢(xún)節(jié)點(diǎn)狀態(tài)信息
    Stat stat = new Stat();
    client.getData().storingStatIn(stat).forPath("/app1");
    System.out.println(stat);
}

@Test
public void testSet() throws Exception {
    //修改數(shù)據(jù)
    client.setData().forPath("/app1","hrbu".getBytes());

    //根據(jù)版本修改
    int version  = 0;
    Stat stat = new Stat();
    client.getData().storingStatIn(stat).forPath("/app1");
    version = stat.getVersion();

    client.setData().withVersion(version).forPath("/app1", "HRBU".getBytes());
}

@Test
public void testDelete() throws Exception {
    //刪除單個(gè)節(jié)點(diǎn)
    client.delete().forPath("/app4/app4_1");

    //刪除帶有子節(jié)點(diǎn)的節(jié)點(diǎn)
    client.delete().deletingChildrenIfNeeded().forPath("/app4");

    //強(qiáng)制刪除
    client.delete().guaranteed().forPath("/app4");

    //回調(diào)
    client.delete().guaranteed().inBackground(new BackgroundCallback() {
        @Override
        public void processResult(CuratorFramework client, CuratorEvent event) throws Exception {
            System.out.println("執(zhí)行刪除操作");
        }
    }).forPath("/app4");

}

@Test
public void testNodeCache() throws Exception {
    //NodeCache:指定一個(gè)節(jié)點(diǎn)注冊(cè)監(jiān)聽(tīng)器

    //創(chuàng)建NodeCache對(duì)象
    final NodeCache nodeCache = new NodeCache(client, "/app1");
    //注冊(cè)監(jiān)聽(tīng)
    nodeCache.getListenable().addListener(new NodeCacheListener() {
        @Override
        public void nodeChanged() throws Exception {
            System.out.println("app1節(jié)點(diǎn)發(fā)生變化");

            //獲取修改節(jié)點(diǎn)后的數(shù)據(jù)
            byte[] data = nodeCache.getCurrentData().getData();
            System.out.println("變化后的節(jié)點(diǎn)："+new String(data));
        }
    });
    //開(kāi)啟監(jiān)聽(tīng)，如果為true，則開(kāi)啟則開(kāi)啟監(jiān)聽(tīng)，加載緩沖數(shù)據(jù)
    nodeCache.start(true);
}

@Test
public void testPathChildrenCache() throws Exception {
    //PathChildrenCache:監(jiān)聽(tīng)某個(gè)節(jié)點(diǎn)的所有子節(jié)點(diǎn)
    //創(chuàng)建監(jiān)聽(tīng)對(duì)象
    PathChildrenCache pathChildrenCache = new PathChildrenCache(client, "/hrbu", true);

    //綁定監(jiān)聽(tīng)器
    pathChildrenCache.getListenable().addListener(new PathChildrenCacheListener() {
        @Override
        public void childEvent(CuratorFramework curatorFramework, PathChildrenCacheEvent pathChildrenCacheEvent) throws Exception {
            System.out.println("子節(jié)點(diǎn)發(fā)生變化");
            System.out.println(pathChildrenCacheEvent);
            //監(jiān)聽(tīng)子節(jié)點(diǎn)的數(shù)據(jù)變更，并且得到變更后的數(shù)據(jù)

            //獲取類(lèi)型
            PathChildrenCacheEvent.Type type = pathChildrenCacheEvent.getType();

            //判斷類(lèi)型
            if (type.equals(PathChildrenCacheEvent.Type.CHILD_UPDATED)) {
                //獲取數(shù)據(jù)
                byte[] data = pathChildrenCacheEvent.getData().getData();
                System.out.println(new String(data));
            }
        }
    });

    //開(kāi)啟
    pathChildrenCache.start();
}

@Test
public void testTreeCache() throws Exception {
    //創(chuàng)建監(jiān)聽(tīng)器
    TreeCache treeCache = new TreeCache(client, "/");

    //注冊(cè)監(jiān)聽(tīng)
    treeCache.getListenable().addListener(new TreeCacheListener() {
        @Override
        public void childEvent(CuratorFramework curatorFramework, TreeCacheEvent treeCacheEvent) throws Exception {
            System.out.println("節(jié)點(diǎn)發(fā)生變化");
            System.out.println(treeCacheEvent);
        }
    });

    //開(kāi)啟
    treeCache.start();

}

package com.hrbu.curator;

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

import java.util.concurrent.TimeUnit;

public class Ticket12306 implements Runnable{

    private int tickets = 10;//數(shù)據(jù)庫(kù)的票數(shù)

    private InterProcessMutex lock ;


    public Ticket12306(){
        //重試策略
        RetryPolicy retryPolicy = new ExponentialBackoffRetry(3000, 10);
        CuratorFramework client = CuratorFrameworkFactory.builder()
                .connectString("8.130.32.75:2181")
                .sessionTimeoutMs(60 * 1000)
                .connectionTimeoutMs(15 * 1000)
                .retryPolicy(retryPolicy)
                .build();
        //開(kāi)啟連接
        client.start();
        lock = new InterProcessMutex(client,"/lock");
    }

    @Override
    public void run() {

        while(true){
            //獲取鎖
            try {
                lock.acquire(3, TimeUnit.SECONDS);
                if(tickets > 0){
                    System.out.println(Thread.currentThread()+":"+tickets);
                    Thread.sleep(100);
                    tickets--;
                }
            } catch (Exception e) {
                e.printStackTrace();
            }finally {
                //釋放鎖
                try {
                    lock.release();
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        }
    }
}

package com.hrbu.curator;
public class LockTest {
    public static void main(String[] args) {
        Ticket12306 ticket12306 = new Ticket12306();

        //創(chuàng)建客戶端
        Thread t1 = new Thread(ticket12306,"攜程");
        Thread t2 = new Thread(ticket12306,"飛豬");

        t1.start();
        t2.start();
    }
}