ZooKeeper 筆記(4) 實戰應用之【消除單點故障】

關鍵節點的單點故障(Single Point of Failure)在大型的架構中，往往是致命的。比如：SOA架構中，服務注冊中心(Server Register)統一調度所有服務，如果這個節點掛了，基本上整個SOA架構也就崩潰了，另外hadoop 1.x/2.x中的namenode節點，這是hdfs的核心節點，如果namenode宕掉，hdfs也就廢了。ZooKeeper的出現，很好的解決了這一難題，其核心原理如下：

1. 關鍵節點的運行實例（或服務器），可以跑多個，這些實例中的數據完全是相同的（即：對等設計），每個實例啟動后，向ZK注冊一個臨時順序節點，比如 /core-servers/server0000001, /core-servers/server0000002 ... ，最后的順序號是由ZK自動遞增的

2. 其它應用需要訪問1中的核心服務器里，可以事先約定好，從ZK的這些臨時節點中，挑選一個序號最小的節點，做為主服務器（即master）

3. 當master宕掉時，超過一定的時間閾值，臨時節點將由ZK自動刪除，這樣原來序列最小的節點也就沒了，客戶端應用按2中的約定找最小節點的服務器時，自動會找到原來次最小的節點，繼續充為master（老大掛了，老二頂上），即實現了故障轉換。如果原來出問題的master恢復了，重新加入ZK，由於順序號是一直遞增，重新加入后，它將做為備胎待命。

示例代碼如下：

上面是類圖，CoreServer類對應核心服務器，ClientServer類對應客戶端應用服務器，SPOFTest為單元測試類

CoreServer代碼：

package yjmyzz.test;

import org.I0Itec.zkclient.ZkClient;


public class CoreServer {

    private String hostName;

    public CoreServer(String hostName) {
        this.hostName = hostName;
    }

    public void start() {
        ZkClient zk = ZKUtil.getZkClient();
        if (!zk.exists(ZKUtil.CORE_SERVER_NODE_NAME)){
            zk.createPersistent(ZKUtil.CORE_SERVER_NODE_NAME);
        }
        zk.createEphemeralSequential(ZKUtil.CORE_SERVER_NODE_NAME + "/server", hostName);
        System.out.println(hostName + " is running...");

    }

    public String getHostName() {
        return hostName;
    }

}

ClientServer類：

package yjmyzz.test;

import org.I0Itec.zkclient.ZkClient;

import java.util.Arrays;
import java.util.List;

/**
 * Created by jimmy on 15/6/28.
 */
public class ClientServer {

    private String getCoreServer() {
        ZkClient zk = ZKUtil.getZkClient();
        List<String> servers = ZKUtil.getZkClient().getChildren(ZKUtil.CORE_SERVER_NODE_NAME);
        if (servers.size() <= 0) {
            return null;
        }
        for (String s : servers) {
            System.out.println(s);
        }
        Object[] arr = servers.toArray();
        Arrays.sort(arr);

        String data = zk.readData(ZKUtil.CORE_SERVER_NODE_NAME + "/" + arr[0].toString());
        System.out.println("node：" + arr[0].toString() + ", data:" + data);
        return data;
    }

    public void run(){
        System.out.println("客戶端應用運行中，正在調用：" + getCoreServer() + " 上的服務");
    }
}

SPOF測試類：

package yjmyzz.test;

import org.junit.Test;

import java.util.concurrent.TimeUnit;

/**
 * Created by jimmy on 15/6/28.
 */
public class SPOFTest {

    @Test
    public void startCoreServer1() throws InterruptedException {

        CoreServer server1 = new CoreServer("server1");
        server1.start();

        while (true) {
            TimeUnit.SECONDS.sleep(5);
        }

    }

    @Test
    public void startCoreServer2() throws InterruptedException {

        CoreServer server2 = new CoreServer("server2");
        server2.start();

        while (true) {
            TimeUnit.SECONDS.sleep(5);
        }

    }




    @Test
    public void testSPOF() throws InterruptedException {
        ClientServer clientServer = new ClientServer();
        clientServer.run();

        //此時，手動停止coreServer1
        TimeUnit.SECONDS.sleep(60);

        //再次運行
        clientServer.run();

    }


}

測試步驟：

1. 先啟用startCoreServer1()、startCoreServer2() 由於這二個方法中，最后用死循環阻止了程序退出，所以這二台server會一直運行下去，除非手動kill 進程

2. 再啟用testSPOF()，在45行這里可以打個斷點，進入斷點時，可以手動把startCoreServer1()對應的進程kill掉，即：模擬server1掛掉，然后繼續執行，觀察輸出。

 

運行結果：

zookeeper state changed (SyncConnected)
server0000000007
server0000000006
node：server0000000006, data:server1
客戶端應用運行中，正在調用：server1 上的服務
...
zookeeper state changed (SyncConnected)
server0000000007
Disconnected from the target VM, address: '127.0.0.1:64788', transport: 'socket'
node：server0000000007, data:server2
客戶端應用運行中，正在調用：server2 上的服務

 

-------------

從測試結果看，客戶端訪問的核心服務器，自動從server1切換到了server2上。