<dependency>
	<groupId>com.101tec</groupId>
	<artifactId>zkclient</artifactId>
	<version>0.9</version>
</dependency>

public class Test001 {
    private static final String ADDRES = "127.0.0.1:2181";
    private static final int TIMAOUT = 5000;
    //計(jì)數(shù)器
    private static CountDownLatch countDownLatch = new CountDownLatch(1);
    public static void main(String[] args) throws IOException, InterruptedException, KeeperException {
        //zk核心節(jié)點(diǎn)+事件通知
        //節(jié)點(diǎn)路徑和界定啊value
        /**
         * 參數(shù)一：連接地址
         * 參數(shù)二：zk超時(shí)時(shí)間
         * 參數(shù)三：事件通知
         */
        //1、創(chuàng)建zk鏈接
        ZooKeeper zooKeeper = new ZooKeeper(ADDRES, TIMAOUT, new Watcher() {
            @Override
            public void process(WatchedEvent watchedEvent) {
                Event.KeeperState state = watchedEvent.getState();
                if(state == Event.KeeperState.SyncConnected){
                    System.out.println("zk鏈接成功");
                    countDownLatch.countDown(); //計(jì)數(shù)器減 1
                }
            }
        });
        //計(jì)數(shù)器結(jié)果必須是為0 才能繼續(xù)執(zhí)行
        System.out.println("zk正在等待連接");
        countDownLatch.await();
        System.out.println("開(kāi)始創(chuàng)建我們的連接");
        //2、創(chuàng)建我們的節(jié)點(diǎn)
        /**
         * 參數(shù)一：路徑名稱
         * 參數(shù)二：節(jié)點(diǎn)value
         * 參數(shù)三：節(jié)點(diǎn)權(quán)限acl
         * 蠶食四：節(jié)點(diǎn)類型 臨時(shí)和永久
         */
        String s = zooKeeper.create("/kaico/one", "hello,boy".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL_SEQUENTIAL);
        System.out.println(s);
        zooKeeper.close();
    }
}

public class Test002 {
    private static final String ADDRES = "127.0.0.1:2181";
    private static final int TIMAOUT = 5000;
    //計(jì)數(shù)器
    private static CountDownLatch countDownLatch = new CountDownLatch(1);
    public static void main(String[] args) throws IOException, InterruptedException, KeeperException, NoSuchAlgorithmException {
        /**
         * 參數(shù)一：連接地址
         * 參數(shù)二：zk超時(shí)時(shí)間
         * 參數(shù)三：事件通知
         */
        //1、創(chuàng)建zk鏈接
        ZooKeeper zooKeeper = new ZooKeeper(ADDRES, TIMAOUT, new Watcher() {
            @Override
            public void process(WatchedEvent watchedEvent) {
                Event.KeeperState state = watchedEvent.getState();
                if(state == Event.KeeperState.SyncConnected){
                    System.out.println("zk鏈接成功");
                    countDownLatch.countDown(); //計(jì)數(shù)器減 1
                }
            }
        });
        //計(jì)數(shù)器結(jié)果必須是為0 才能繼續(xù)執(zhí)行
        System.out.println("zk正在等待連接");
        countDownLatch.await();
        System.out.println("開(kāi)始創(chuàng)建我們的連接");
        //創(chuàng)建賬號(hào) admin 可以實(shí)現(xiàn)讀寫操作
        Id admin = new Id("digest", DigestAuthenticationProvider.generateDigest("admin:admin123"));
        ACL acl1 = new ACL(ZooDefs.Perms.ALL, admin);
        //創(chuàng)建賬號(hào) guest 只允許做讀操作
        Id guest = new Id("digest", DigestAuthenticationProvider.generateDigest("guest:guest123"));
        ACL acl2 = new ACL(ZooDefs.Perms.READ, guest);
        ArrayList<ACL> acls = new ArrayList<>();
        acls.add(acl1);
        acls.add(acl2);
        //2、創(chuàng)建我們的節(jié)點(diǎn)
        /**
         * 參數(shù)一：路徑名稱
         * 參數(shù)二：節(jié)點(diǎn)value
         * 參數(shù)三：節(jié)點(diǎn)權(quán)限acl
         * 蠶食四：節(jié)點(diǎn)類型 臨時(shí)和永久
         */
        String s = zooKeeper.create("/kaico/acl", "hello,boy".getBytes(), acls, CreateMode.PERSISTENT);
        System.out.println(s);
        zooKeeper.close();
    }
}

public class Test003 {
    private static final String ADDRES = "127.0.0.1:2181";
    private static final int TIMAOUT = 5000;
    //計(jì)數(shù)器
    private static CountDownLatch countDownLatch = new CountDownLatch(1);
    public static void main(String[] args) throws IOException, InterruptedException, KeeperException, NoSuchAlgorithmException {
        /**
         * 參數(shù)一：連接地址
         * 參數(shù)二：zk超時(shí)時(shí)間
         * 參數(shù)三：事件通知
         */
        //1、創(chuàng)建zk鏈接
        ZooKeeper zooKeeper = new ZooKeeper(ADDRES, TIMAOUT, new Watcher() {
            @Override
            public void process(WatchedEvent watchedEvent) {
                Event.KeeperState state = watchedEvent.getState();
                if(state == Event.KeeperState.SyncConnected){
                    System.out.println("zk鏈接成功");
                    countDownLatch.countDown(); //計(jì)數(shù)器減 1
                }
            }
        });
        //計(jì)數(shù)器結(jié)果必須是為0 才能繼續(xù)執(zhí)行
        System.out.println("zk正在等待連接");
        countDownLatch.await();
        System.out.println("開(kāi)始創(chuàng)建我們的連接");
        //設(shè)置一下zookeeper 的賬號(hào)才有權(quán)限獲取內(nèi)容
        zooKeeper.addAuthInfo("digest", "guest:guest123".getBytes());
        //獲取節(jié)點(diǎn)的內(nèi)容
        byte[] data = zooKeeper.getData("/kaico/acl", null, new Stat());
        System.out.println(new String(data));
        zooKeeper.close();
    }
}

public class Test004 {
    private static final String ADDRES = "127.0.0.1:2181";
    private static final int TIMAOUT = 5000;
    //計(jì)數(shù)器
    private static CountDownLatch countDownLatch = new CountDownLatch(1);
    public static void main(String[] args) throws IOException, InterruptedException, KeeperException, NoSuchAlgorithmException {
        //1、創(chuàng)建zk 連接
        ZkClient zkClient = new ZkClient(ADDRES, TIMAOUT);
        String parentPath = "/kaico/jing";
        //2、監(jiān)聽(tīng)節(jié)點(diǎn)發(fā)生的變化，監(jiān)聽(tīng)子節(jié)點(diǎn)是否發(fā)生變化，如果發(fā)生變化都可以獲取到回調(diào)通知。
//        zkClient.subscribeChildChanges(parentPath, new IZkChildListener() {
//            @Override
//            public void handleChildChange(String s, List<String> list) throws Exception {
//                System.out.println("s:" + s + ",節(jié)點(diǎn)發(fā)生了變化");
//                list.forEach((t)->{
//                    System.out.println("子節(jié)點(diǎn)：" + t);
//                });
//            }
//        });
        //監(jiān)聽(tīng)節(jié)點(diǎn)的內(nèi)容是否發(fā)生變化或刪除
        zkClient.subscribeDataChanges(parentPath, new IZkDataListener() {
            @Override
            public void handleDataChange(String s, Object o) throws Exception {
                System.out.println("修改的節(jié)點(diǎn)為：" + s + "，修改之后的值：" + o);
            }
            @Override
            public void handleDataDeleted(String s) throws Exception {
                System.out.println("節(jié)點(diǎn)：" + s + "被刪除");
            }
        });
        //修改值內(nèi)容
        zkClient.writeData(parentPath, "666666666666666");
        while (true){
        }
//        zkClient.close();
    }
}

public interface Lock {
    /**
     * 獲取鎖
     */
    public void getLock();
    /**
     * 釋放鎖
     */
    public void unLock();
}

abstract class AbstractTemplzateLock implements Lock {
    @Override
    public void getLock() {
        // 模版方法 定義共同抽象的骨架
        if (tryLock()) {
            System.out.println(">>>" + Thread.currentThread().getName() + ",獲取鎖成功");
        } else {
            // 開(kāi)始實(shí)現(xiàn)等待
            waitLock();// 事件監(jiān)聽(tīng)
            // 重新獲取
            getLock();
        }
    }
    /**
     * 獲取鎖
     * @return
     */
    protected abstract boolean tryLock();
    /**
     * 等待鎖
     * @return
     */
    protected abstract void waitLock();
    /**
     * 釋放鎖
     * @return
     */
    protected abstract void unImplLock();
    @Override
    public void unLock() {
        unImplLock();
    }
}

public class ZkTemplzateImplLock extends AbstractTemplzateLock {
    //參數(shù)1 連接地址
    private static final String ADDRES = "192.168.212.147:2181";
    // 參數(shù)2 zk超時(shí)時(shí)間
    private static final int TIMEOUT = 5000;
    // 創(chuàng)建我們的zk連接
    private ZkClient zkClient = new ZkClient(ADDRES, TIMEOUT);
    /**
     * 共同的創(chuàng)建臨時(shí)節(jié)點(diǎn)
     */
    private String lockPath = "/lockPath";
    private CountDownLatch countDownLatch = null;
    @Override
    protected boolean tryLock() {
        // 獲取鎖的思想：多個(gè)jvm同時(shí)創(chuàng)建臨時(shí)節(jié)點(diǎn)，只要誰(shuí)能夠創(chuàng)建成功 誰(shuí)能夠獲取到鎖
        try {
            zkClient.createEphemeral(lockPath);
            return true;
        } catch (Exception e) {
//            // 如果創(chuàng)建已經(jīng)存在的話
//            e.printStackTrace();
            return false;
        }
    }
    @Override
    protected void waitLock() {
        // 1.使用事件監(jiān)聽(tīng) 監(jiān)聽(tīng)lockPath節(jié)點(diǎn)是否已經(jīng)被刪除，如果被刪除的情況下 有可以重新的進(jìn)入到獲取鎖的權(quán)限
        IZkDataListener iZkDataListener = new IZkDataListener() {
            @Override
            public void handleDataChange(String s, Object o) throws Exception {
            }
            @Override
            public void handleDataDeleted(String s) throws Exception {
                if (countDownLatch != null) {
                    countDownLatch.countDown();// 計(jì)數(shù)器變?yōu)?
                }
            }
        };
        zkClient.subscribeDataChanges(lockPath, iZkDataListener);
        // 2.使用countDownLatch等待
        if (countDownLatch == null) {
            countDownLatch = new CountDownLatch(1);
        }
        try {
            countDownLatch.await();// 如果當(dāng)前計(jì)數(shù)器不是為0 就一直等待
        } catch (Exception e) {
        }
        // 3. 如果當(dāng)前節(jié)點(diǎn)被刪除的情況下，有需要重新進(jìn)入到獲取鎖
        zkClient.unsubscribeDataChanges(lockPath, iZkDataListener);
    }
    @Override
    protected void unImplLock() {
        if (zkClient != null) {
            zkClient.close();
            System.out.println(Thread.currentThread().getName() + "，釋放了鎖>>>");
        }
    }
}

//main方法使用多線程測(cè)試分布式鎖
  public static void main(String[] args) {
//        OrderService orderService = new OrderService();
        for (int i = 0; i < 100; i++) {
            new Thread(new OrderService()).start();
        }
        // 單個(gè)jvm中多線程同時(shí)生成訂單號(hào)碼如果發(fā)生重復(fù) 如何解決 synchronized或者是lock鎖
        // 如果在多個(gè)jvm中同時(shí)生成訂單號(hào)碼如果發(fā)生重復(fù)如何解決
        // 注意synchronized或者是lock鎖 只能夠在本地的jvm中有效
        // 分布式鎖的概念
    }
//多線程run 方法
public class OrderService implements Runnable {
    private OrderNumGenerator orderNumGenerator = new OrderNumGenerator();
    private Lock lock = new ZkTemplzateImplLock();
    @Override
    public void run() {
        getNumber();
    }
    private void getNumber() {
        try {
            lock.getLock();
            Thread.sleep(50);
            String number = orderNumGenerator.getNumber();
            System.out.println(Thread.currentThread().getName() + ",獲取的number:" + number);
            // 如果zk超時(shí)了，有做數(shù)據(jù)庫(kù)寫的操作統(tǒng)一直接回滾
        } catch (Exception e) {

        } finally {
            lock.unLock();
        }
    }
    // ZkTemplzateImplLock父親 模版類 AbstractTemplzateLock 父親  Lock
}
//自動(dòng)生成訂單號(hào)的類
public class OrderNumGenerator {
    /**
     * 序號(hào)
     */
    private static int count;
    /**
     * 生成我們的時(shí)間戳 為訂單號(hào)碼
     * @return
     */
    public String getNumber() {
        SimpleDateFormat simpt = new SimpleDateFormat("yyyy-MM-dd-HH-mm-ss");
        try {
            Thread.sleep(30);
        } catch (Exception e) {
        }
        return simpt.format(new Date()) + "-" + ++count;
    }
}