@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();
    //開啟連接
    client.start();
}

@Test
public void testCreate1() throws Exception {
    //基本創(chuàng)建
    CreateBuilder createBuilder = client.create();
    //創(chuàng)建時(shí)不指定數(shù)據(jù)，會將當(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)類型，默認(rèn)的類型是持久化
    //CreateMode是枚舉類型
    createBuilder.withMode(CreateMode.EPHEMERAL).forPath("/app3");
}

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

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

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

    //查詢節(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)注冊監(jiān)聽器

    //創(chuàng)建NodeCache對象
    final NodeCache nodeCache = new NodeCache(client, "/app1");
    //注冊監(jiān)聽
    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));
        }
    });
    //開啟監(jiān)聽，如果為true，則開啟則開啟監(jiān)聽，加載緩沖數(shù)據(jù)
    nodeCache.start(true);
}

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

    //綁定監(jiān)聽器
    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)聽子節(jié)點(diǎn)的數(shù)據(jù)變更，并且得到變更后的數(shù)據(jù)

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

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

    //開啟
    pathChildrenCache.start();
}

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

    //注冊監(jiān)聽
    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);
        }
    });

    //開啟
    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ù)庫的票數(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();
        //開啟連接
        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();
    }
}