一、思路圖展示

Paste_Image.png

二、思路解析

我們都知道Zookeeper的節(jié)點(diǎn)有兩種類型，分別是持久節(jié)點(diǎn)和臨時(shí)節(jié)點(diǎn)。臨時(shí)節(jié)點(diǎn)有個(gè)特性，就是如果注冊這個(gè)節(jié)點(diǎn)的機(jī)器失去連接(通常是宕機(jī))，那么這個(gè)節(jié)點(diǎn)會(huì)被zookeeper刪除。選主過程就是利用這個(gè)特性，在服務(wù)器啟動(dòng)的時(shí)候，去zookeeper特定的一個(gè)目錄下注冊一個(gè)臨時(shí)節(jié)點(diǎn)(這個(gè)節(jié)點(diǎn)作為master，誰注冊了這個(gè)節(jié)點(diǎn)誰就是master)，注冊的時(shí)候，如果發(fā)現(xiàn)該節(jié)點(diǎn)已經(jīng)存在，則說明已經(jīng)有別的服務(wù)器注冊了(也就是有別的服務(wù)器已經(jīng)搶主成功)，那么當(dāng)前服務(wù)器只能放棄搶主，作為從機(jī)存在。同時(shí)，搶主失敗的當(dāng)前服務(wù)器需要訂閱該臨時(shí)節(jié)點(diǎn)的刪除事件，以便該節(jié)點(diǎn)刪除時(shí)(也就是注冊該節(jié)點(diǎn)的服務(wù)器宕機(jī)了或者網(wǎng)絡(luò)斷了之類的)進(jìn)行再次搶主操作。選主的過程，其實(shí)就是簡單的爭搶在Zookeeper注冊臨時(shí)節(jié)點(diǎn)的操作，誰注冊了約定的臨時(shí)節(jié)點(diǎn)，誰就是master。所有服務(wù)器同時(shí)會(huì)在servers節(jié)點(diǎn)下注冊一個(gè)臨時(shí)節(jié)點(diǎn)（保存自己的基本信息），以便于應(yīng)用程序讀取當(dāng)前可用的服務(wù)器列表。

三、如何使用

<dependency>
<groupId>org.apache.curator</groupId>
<artifactId>curator-recipes</artifactId>
<version>2.9.0</version>
</dependency>

通過以上分析我們不難看出，其實(shí)想要實(shí)現(xiàn)這個(gè)簡單的選舉過程其實(shí)是很難的，那么我們下面將借助Curator來實(shí)現(xiàn)想要的功能。

public class MasterSelectTest {

    public static void main(String[] args) throws Exception {
        String masterPath = "/master_path";
        CuratorFramework client = CuratorFrameworkFactory.builder().connectString("127.0.0.1:2181").sessionTimeoutMs(5000).connectionTimeoutMs(10000).retryPolicy(retryPolicy).namespace("text").build();  
        client.start();
        /**
         * 該實(shí)例封裝了所有Master選舉相關(guān)的邏輯，包括所有和Zookeeper服務(wù)器交互的過程，其中Master_select代表一個(gè)Master選舉的一個(gè)
         * 根節(jié)點(diǎn)，表明本次Master選舉都是在該節(jié)點(diǎn)下進(jìn)行的。
         * 在創(chuàng)建LeaderSelector實(shí)例的時(shí)候，還會(huì)傳入一個(gè)監(jiān)聽器:LeaderSelectorListenerAdapter。這需要開發(fā)人員自行實(shí)現(xiàn)。Curator
         * 會(huì)在成功獲取Master權(quán)利時(shí)候回調(diào)該監(jiān)聽器。
         */
        LeaderSelector leaderSelector = new LeaderSelector(client, master_path, new LeaderSelectorListener() {

            @Override
            public void stateChanged(CuratorFramework client, ConnectionState stat) {

            }
            /**
             *  成為Master角色 
             *  完成Master操作，釋放Master權(quán)利
             *  成為Master角色
             */
            @Override
            public void takeLeadership(CuratorFramework client) throws Exception {
                System.out.println("成為Master");
                Thread.sleep(3000);
                List<String> path = client.getChildren().forPath(masterPath);
                System.out.println(path);
                System.out.println("完成Master操作，釋放Master權(quán)利");
            }
        });
        leaderSelector.autoRequeue();
        leaderSelector.start();
    }
}