master選舉使用場景及結構

　現在很多時候我們的服務需要7*24小時工作，假如一臺機器掛了，我們希望能有其它機器頂替它繼續工作。此類問題現在多采用master-salve模式，也就是常說的主從模式，正常情況下主機提供服務，備機負責監聽主機狀態，當主機異常時，可以自動切換到備機繼續提供服務(這里有點兒類似于數據庫主庫跟備庫，備機正常情況下只監聽，不工作)，這個切換過程中選出下一個主機的過程就是master選舉。

對于以上提到的場景，傳統的解決方式是采用一個備用節點，這個備用節點定期給當前主節點發送ping包，主節點收到ping包后會向備用節點發送應答ack，當備用節點收到應答，就認為主節點還活著，讓它繼續提供服務，否則就認為主節點掛掉了，自己將開始行使主節點職責。如圖1所示：

?

使用Zookeeper實現服務master選舉

? ? ? ? 在哨兵機制中 只能一個主 多個從！

使用zk可以實現之！

?

? 原理： 多個服務器在啟動時候，會在Zookeeper上創建相同的臨時節點，誰如果能夠創建成功，誰就為主！（節點保證唯一）

? ? ? ? ? ?如果主服務器宕機，會話連接斷開。臨時節點刪除。其他節點服務選舉開始

?

?

?

? ?

?創建項目：

pom文件： 注意springboot 整合 zk的包

<parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.0.0.RELEASE</version></parent><dependencies><dependency><groupId>com.101tec</groupId><artifactId>zkclient</artifactId><version>0.10</version><exclusions><exclusion><artifactId>slf4j-api</artifactId><groupId>org.slf4j</groupId></exclusion><exclusion><artifactId>log4j</artifactId><groupId>log4j</groupId></exclusion><exclusion><artifactId>slf4j-log4j12</artifactId><groupId>org.slf4j</groupId></exclusion></exclusions></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency></dependencies>　　

?后臺controller

package com.toov5.zkMaster;import org.springframework.beans.factory.annotation.Value; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController;@RestController public class IndexController {@Value("${server.port}")private String serverPort;@RequestMapping("getServerInfo")public String getServerInfo(){return "serverPort"+serverPort+(ElectionMaster.isSurvival? "選舉為主" :"選舉為從");}public static void main(String[] args) {//1,項目啟動的時候 在zk創建臨時節點//2，誰能夠創建成功誰就是主服務器//3,使用服務監聽節點是否被刪除，如果被刪。 重新開始創建節點 }}

啟動加載運行類

package com.toov5.zkMaster;import org.I0Itec.zkclient.IZkDataListener; import org.I0Itec.zkclient.ZkClient; import org.springframework.beans.factory.annotation.Value; import org.springframework.boot.ApplicationArguments; import org.springframework.boot.ApplicationRunner; import org.springframework.stereotype.Component;@Component public class MyApplicationRunner implements ApplicationRunner{private ZkClient zkClient = new ZkClient("192.168.91.5:2181");private String path = "/election";@Value("${server.port}")private String serverPort;//啟動后執行的方法public void run(ApplicationArguments args) throws Exception { //重寫這個方法System.out.println("項目啟動成功！"); //1,項目啟動的時候 在zk創建臨時節點 createEphemeral();//2，誰能夠創建成功誰就是主服務器//3,使用服務監聽節點是否被刪除，如果被刪。 重新開始創建節點zkClient.subscribeDataChanges(path, new IZkDataListener() {//返回節點如果被刪除后 返回通知public void handleDataDeleted(String arg0) throws Exception {//重新創建（選舉）System.out.println("開始重新選舉策略");createEphemeral();}public void handleDataChange(String arg0, Object arg1) throws Exception {// TODO Auto-generated method stub }});}private void createEphemeral(){try {zkClient.createEphemeral(path); System.out.println("serverport"+serverPort+",選舉成功！");ElectionMaster.isSurvival=true; //標志位true 單個jvm共享} catch (Exception e) {System.out.println("該節點已經存在");ElectionMaster.isSurvival=false;}}}

全局變量

package com.toov5.zkMaster;public class ElectionMaster {//服務器info信息 是否存活public static boolean isSurvival; //靜態的 標志下 服務器是否還存活 }

運行類

package com.toov5.zkMaster;public class ElectionMaster {//服務器info信息 是否存活public static boolean isSurvival; //靜態的 標志下 服務器是否還存活 }

yml：

server:port: 8088

　

運行，啟動兩個端口

一個主 一個從?

然后關掉主，重新選舉從（需要等待一段時間，強制關閉有延遲的）

?

?

?

　

?

?

?

?

?

? ??

?

轉載于:https://www.cnblogs.com/toov5/p/9905508.html

總結

以上是生活随笔為你收集整理的Zookeeper实现Master选举（哨兵机制）的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。