有時根據需求，幾臺伺服器需要從一個WEB介面或者資料庫獲得同樣的資源，因為不能同時獲取，就涉及到了資源排程演算法

一種資源排程邏輯是：

1.程式節點啟動時到zookeeper上註冊一個“臨時+序號”的znode，並監聽父節點。

2.獲取父節點下所有的程式子節點，比較序號的大小。

3.序號最小的獲取到“鎖”，去訪問資源，訪問完後，刪除自己的節點，相當於釋放鎖，並且重新註冊一個新的子節點。

4.其他程式節點會收到事件通知，則可以去zk上獲取鎖。

上虛擬碼：

//getConnect()  獲取連線
//registerLock(/lock/app.emphemeral_sequential)   註冊鎖
 
//getLock(){獲取子節點；比較自己的序號是否是最小的，如果是，則返回鎖獲取成功}
//訪問資源
//releaseLock(){刪除自己的子節點，並建立一個新的子節點}

//監聽器
process(){getLock(0}

上原始碼：

public class DistributedClientLock {
    

    // 會話超時
    private static final int SESSION_TIMEOUT = 2000;
    // zookeeper叢集地址
    private String hosts = "mini1:2181,mini2:2181,mini3:2181
 
";
    private String groupNode = "locks";
    private String subNode = "sub";
    private boolean haveLock = false;

    private ZooKeeper zk;
    // 記錄自己建立的子節點路徑
    private volatile String thisPath;

    /**
     * 連線zookeeper
     */
    public void connectZookeeper() throws Exception {
        zk = new
 
 ZooKeeper(hosts, SESSION_TIMEOUT, new Watcher() {
            public void process(WatchedEvent event) {
                try {

                    // 判斷事件型別，此處只處理子節點變化事件
                    if (event.getType() == EventType.NodeChildrenChanged && event.getPath().equals("/" + groupNode)) {
                        //獲取子節點，並對父節點進行監聽
                        List<String> childrenNodes = zk.getChildren("/" + groupNode, true);
                        String thisNode = thisPath.substring(("/" + groupNode + "/").length());
                        // 去比較是否自己是最小id
                        Collections.sort(childrenNodes);
                        if (childrenNodes.indexOf(thisNode) == 0) {
                            //訪問共享資源處理業務，並且在處理完成之後刪除鎖
                            doSomething();
                            
                            //重新註冊一把新的鎖
                            thisPath = zk.create("/" + groupNode + "/" + subNode, null, Ids.OPEN_ACL_UNSAFE,
                                    CreateMode.EPHEMERAL_SEQUENTIAL);
                        }
                    }
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        });

        // 1、程式一進來就先註冊一把鎖到zk上
        thisPath = zk.create("/" + groupNode + "/" + subNode, null, Ids.OPEN_ACL_UNSAFE,
                CreateMode.EPHEMERAL_SEQUENTIAL);

        // wait一小會，便於觀察
        Thread.sleep(new Random().nextInt(1000));

        // 從zk的鎖父目錄下，獲取所有子節點，並且註冊對父節點的監聽
        List<String> childrenNodes = zk.getChildren("/" + groupNode, true);

        //如果爭搶資源的程式就只有自己，則可以直接去訪問共享資源 
        if (childrenNodes.size() == 1) {
            doSomething();
            thisPath = zk.create("/" + groupNode + "/" + subNode, null, Ids.OPEN_ACL_UNSAFE,
                    CreateMode.EPHEMERAL_SEQUENTIAL);
        }
    }

    /**
     * 處理業務邏輯，並且在最後釋放鎖
     */
    private void doSomething() throws Exception {
        try {
            System.out.println("gain lock: " + thisPath);
            Thread.sleep(2000);
            // do something
        } finally {
            System.out.println("finished: " + thisPath);
            
            zk.delete(this.thisPath, -1);
        }
    }

    public static void main(String[] args) throws Exception {
        DistributedClientLock dl = new DistributedClientLock();
        dl.connectZookeeper();
        Thread.sleep(Long.MAX_VALUE);
    }

    
}