Zookeeper-服務(wù)注冊與發(fā)現(xiàn)

最近在學習zookeeper，作為一個分布式協(xié)調(diào)服務(wù)全庸，它的用途挺多秀仲，服務(wù)注冊與發(fā)現(xiàn)、分布式鎖壶笼、集群選舉神僵、配置中心等。今天我先通過一個demo實現(xiàn)zookeeper的服務(wù)注冊與發(fā)現(xiàn)功能

思路

zookeeper服務(wù)注冊與發(fā)現(xiàn)
  • 將產(chǎn)品服務(wù)的信息注冊到zookeeper的節(jié)點上
  • 然后獲取到節(jié)點上的信息并存儲起來（本文存到List）
  • Watcher機制監(jiān)控List里數(shù)據(jù)的變化并更新數(shù)據(jù) （假如產(chǎn)品服務(wù)2掛了通過監(jiān)聽機制將其移出）

  • 利用輪詢或者hash等算法去獲取List里的數(shù)據(jù)供訂單服務(wù)調(diào)用（負載均衡）


    zk節(jié)點

注冊服務(wù)

獲取到zookeeper的實例并創(chuàng)建根節(jié)點和子節(jié)點覆劈，子節(jié)點為臨時順序節(jié)點保礼，用于保存服務(wù)對應的ip

package com.ooliuyue.product.zk;

import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.ZooDefs;
import org.apache.zookeeper.ZooKeeper;
import org.apache.zookeeper.data.Stat;


/**
 * @Auther: ly
 * @Date: 2019/4/19 11:53
 */

public class ServiceRegister {

    private  static final String BASE_SERVICE = "/service";
    private  static final String SERVICE_NAME = "/product";

    public static void register(String address,int port) {
        /**
         * 在zk創(chuàng)建根節(jié)點path,在根節(jié)點下創(chuàng)建臨時子節(jié)點用于存放服務(wù)ip和端口
         */
        try {
            String path = BASE_SERVICE + SERVICE_NAME;
            ZooKeeper zooKeeper = new ZooKeeper("127.0.0.1:2181",5000,(watchedEvent) -> {});
            System.out.println(zooKeeper);
            Thread.sleep(2000);
            Stat exists = zooKeeper.exists(BASE_SERVICE + SERVICE_NAME, false);
            //先判斷服務(wù)根路徑是否存在
            if (exists == null){
                zooKeeper.create(BASE_SERVICE + SERVICE_NAME,"".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
            }
            //將服務(wù)的ip和端口作為臨時帶序號的子節(jié)點
            String server_path = address+":"+port;
            zooKeeper.create(path + "/child",server_path.getBytes(),ZooDefs.Ids.OPEN_ACL_UNSAFE,CreateMode.EPHEMERAL_SEQUENTIAL);
            System.out.println("product服務(wù)注冊成功");
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

容器初始化的時候調(diào)用register(),給zk的子節(jié)點設(shè)置值（服務(wù)的url）

package com.ooliuyue.product.listen;

import com.ooliuyue.product.zk.ServiceRegister;

import javax.servlet.ServletContextEvent;
import javax.servlet.ServletContextListener;
import java.net.InetAddress;
import java.util.Properties;

/**
 * @Auther: ly
 * @Date: 2019/4/19 10:43
 */

public class InitListener implements ServletContextListener {

    @Override
    //容器初始化的時候會調(diào)用
    public void  contextInitialized(ServletContextEvent sce) {
        Properties properties = new Properties();
        try {
            properties.load(InitListener.class.getClassLoader().getResourceAsStream("application.properties"));
            //獲得IP
            String hostAddress = InetAddress.getLocalHost().getHostAddress();
            //獲得端口
            int port = Integer.valueOf(properties.getProperty("server.port"));
            ServiceRegister.register(hostAddress,port);

        } catch (Exception e) {
            e.printStackTrace();
        }


    }
    public void contextDestroyed(ServletContextEvent sce) {
    }

}

啟動服務(wù)，進行測試责语，前提需要啟動ZooKeeper


package com.ooliuyue.product.controller;

import com.ooliuyue.product.pojo.Product;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.servlet.http.HttpServletRequest;

/**
 * @Auther: ly
 * @Date: 2019/4/19 09:52
 */

@RequestMapping("/product")
@RestController
public class ProductController {

    @RequestMapping("/get/{id}")
    public Object getProduct(HttpServletRequest request, @PathVariable("id") String id){
        int localPort = request.getLocalPort();
        return new Product(id,"productName:" + localPort);
    }
}

兩個產(chǎn)品服務(wù)啟動成功



通過工具查看節(jié)點


服務(wù)發(fā)現(xiàn)

獲取zk節(jié)點上保存的服務(wù)信息并保存到一個List中炮障，watcher機制來監(jiān)控List中數(shù)據(jù)的變化

package com.ooliuyue.order.listener;

import com.ooliuyue.order.utils.LoadBalance;
import org.apache.zookeeper.Watcher;
import org.apache.zookeeper.ZooKeeper;
import javax.servlet.ServletContextEvent;
import javax.servlet.ServletContextListener;
import java.util.ArrayList;
import java.util.List;

/**
 * @Auther: ly
 * @Date: 2019/4/19 16:26
 */

public class InitListener implements ServletContextListener {

    private  static final String BASE_SERVICE = "/service";
    private  static final String SERVICE_NAME = "/product";
    private ZooKeeper zooKeeper;

    private void init(){
        try {
            //連接zk,獲得列表信息
            //watcher機制：監(jiān)控獲取到的服務(wù)列表的變化
            zooKeeper = new ZooKeeper("127.0.0.1:2181",5000,(watchedEvent) -> {
                if (watchedEvent.getType() == Watcher.Event.EventType.NodeChildrenChanged
                        && watchedEvent.getPath().equals(BASE_SERVICE+SERVICE_NAME)) {
                    System.out.println("***注冊到zk的服務(wù)信息發(fā)生變化***");
                    updateServerList();
                }
            });
            //第一次連接的時候要返回的列表
            updateServerList();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    private void updateServerList() {
        List<String> list = new ArrayList<>();
        try {
            List<String> children = zooKeeper.getChildren(BASE_SERVICE + SERVICE_NAME,true);
            for(String subNode : children) {
                byte[] data = zooKeeper.getData(BASE_SERVICE + SERVICE_NAME + "/" + subNode, false, null);
                String host  = new String(data,"utf-8");
                list.add(host);
            }
            //將獲取的服務(wù)端口和IP保存List中
            LoadBalance.SERVICE_LIST = list;
        } catch (Exception e) {
            e.printStackTrace();
        }
    }


    @Override
    public void  contextInitialized(ServletContextEvent sce) {
        init();
    }

    @Override
    public void contextDestroyed(ServletContextEvent sce) {
    }


}

通過實現(xiàn)一個隨機算法獲取到產(chǎn)品服務(wù)，供訂單服務(wù)調(diào)用（相當于負載）

package com.ooliuyue.order.utils;

import java.util.List;

/**
 * @Auther: ly
 * @Date: 2019/4/22 14:00
 */

public abstract class LoadBalance {

    public volatile static List<String> SERVICE_LIST;

    public abstract String chooseServiceHost();
}


package com.ooliuyue.order.utils;

import org.springframework.util.CollectionUtils;

import java.util.Random;

/**
 * @Auther: ly
 * @Date: 2019/4/22 14:02
 */

//實現(xiàn)了一個隨機的算法（隨機獲取訂單服務(wù)）
public class RandomLoadBalance extends LoadBalance {


    @Override
    public String chooseServiceHost() {
        String result = "";
        if (!CollectionUtils.isEmpty(SERVICE_LIST)) {
            int nextInt = new Random().nextInt(SERVICE_LIST.size());
            result = SERVICE_LIST.get(nextInt);
        }
        return result;
    }
}

測試調(diào)用結(jié)果

package com.ooliuyue.order.controller;

import com.ooliuyue.order.pojo.Order;
import com.ooliuyue.order.utils.LoadBalance;
import com.ooliuyue.order.utils.RandomLoadBalance;
import com.ooliuyue.product.pojo.Product;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;

/**
 * @Auther: ly
 * @Date: 2019/4/19 10:02
 */

@RequestMapping("/order")
@RestController
public class OrderController {

    @Resource
    private RestTemplate restTemplate;

    private LoadBalance loadBalance = new RandomLoadBalance();

    @RequestMapping("/get/{id}")
    public Object getOrder(HttpServletRequest request, @PathVariable("id") String id){
        //隨機獲取host
        String host = loadBalance.chooseServiceHost();
        Product product = restTemplate.getForObject("http://" + host + "/product/get/1", Product.class);
        return new Order(id,"ordername",product);

    }
}

發(fā)起多次請求坤候，會發(fā)現(xiàn)隨機調(diào)用其中一個服務(wù)


Watcher機制

刪除List中一個服務(wù)的信息


最后編輯于 ：
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 人面猴
    序言：七十年代末胁赢，一起剝皮案震驚了整個濱河市，隨后出現(xiàn)的幾起案子白筹，更是在濱河造成了極大的恐慌智末，老刑警劉巖，帶你破解...
    沈念sama閱讀 216,372評論 6贊 498
  • 死咒
    序言：濱河連續(xù)發(fā)生了三起死亡事件徒河，死亡現(xiàn)場離奇詭異吹害，居然都是意外死亡，警方通過查閱死者的電腦和手機虚青，發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 92,368評論 3贊 392
  • 救了他兩次的神仙讓他今天三更去死
    文/潘曉璐 我一進店門，熙熙樓的掌柜王于貴愁眉苦臉地迎上來螺男，“玉大人棒厘，你說我怎么就攤上這事∠滤恚” “怎么了？”我有些...
    開封第一講書人閱讀 162,415評論 0贊 353
  • 道士緝兇錄：失蹤的賣姜人
    文/不壞的土叔 我叫張陵，是天一觀的道長况鸣。 經(jīng)常有香客問我昔搂，道長，這世上最難降的妖魔是什么土辩？ 我笑而不...
    開封第一講書人閱讀 58,157評論 1贊 292
  • ?港島之戀（遺憾婚禮）
    正文 為了忘掉前任支救，我火速辦了婚禮，結(jié)果婚禮上拷淘，老公的妹妹穿的比我還像新娘各墨。我一直安慰自己，他們只是感情好启涯，可當我...
    茶點故事閱讀 67,171評論 6贊 388
  • 惡毒庶女頂嫁案：這布局不是一般人想出來的
    文/花漫 我一把揭開白布贬堵。 她就那樣靜靜地躺著恃轩，像睡著了一般。 火紅的嫁衣襯著肌膚如雪黎做。 梳的紋絲不亂的頭發(fā)上叉跛，一...
    開封第一講書人閱讀 51,125評論 1贊 297
  • 城市分裂傳說
    那天，我揣著相機與錄音蒸殿，去河邊找鬼筷厘。 笑死，一個胖子當著我的面吹牛伟桅，可吹牛的內(nèi)容都是我干的敞掘。 我是一名探鬼主播，決...
    沈念sama閱讀 40,028評論 3贊 417
  • 雙鴛鴦連環(huán)套：你想象不到人心有多黑
    文/蒼蘭香墨 我猛地睜開眼楣铁，長吁一口氣：“原來是場噩夢啊……” “哼玖雁！你這毒婦竟也來了？” 一聲冷哼從身側(cè)響起盖腕，我...
    開封第一講書人閱讀 38,887評論 0贊 274
  • 萬榮殺人案實錄
    序言：老撾萬榮一對情侶失蹤赫冬，失蹤者是張志新（化名）和其女友劉穎，沒想到半個月后溃列，有當?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體劲厌，經(jīng)...
    沈念sama閱讀 45,310評論 1贊 310
  • ?護林員之死
    正文 獨居荒郊野嶺守林人離奇死亡，尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點故事閱讀 37,533評論 2贊 332
  • ?白月光啟示錄
    正文 我和宋清朗相戀三年听隐，在試婚紗的時候發(fā)現(xiàn)自己被綠了补鼻。 大學時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
    茶點故事閱讀 39,690評論 1贊 348
  • 活死人
    序言：一個原本活蹦亂跳的男人離奇死亡雅任，死狀恐怖风范，靈堂內(nèi)的尸體忽然破棺而出，到底是詐尸還是另有隱情沪么，我是刑警寧澤硼婿，帶...
    沈念sama閱讀 35,411評論 5贊 343
  • ?日本核電站爆炸內(nèi)幕
    正文 年R本政府宣布，位于F島的核電站禽车，受9級特大地震影響寇漫，放射性物質(zhì)發(fā)生泄漏。R本人自食惡果不足惜殉摔，卻給世界環(huán)境...
    茶點故事閱讀 41,004評論 3贊 325
  • 男人毒藥：我在死后第九天來索命
    文/蒙蒙 一州胳、第九天 我趴在偏房一處隱蔽的房頂上張望。 院中可真熱鬧钦勘，春花似錦陋葡、人聲如沸。這莊子的主人今日做“春日...
    開封第一講書人閱讀 31,659評論 0贊 22
  • 一樁弒父案腐缤，背后竟有這般陰謀
    文/蒼蘭香墨 我抬頭看了看天上的太陽捌归。三九已至，卻和暖如春岭粤，著一層夾襖步出監(jiān)牢的瞬間惜索，已是汗流浹背。 一陣腳步聲響...
    開封第一講書人閱讀 32,812評論 1贊 268
  • 情欲美人皮
    我被黑心中介騙來泰國打工剃浇， 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留巾兆，地道東北人。 一個月前我還...
    沈念sama閱讀 47,693評論 2贊 368
  • 代替公主和親
    正文 我出身青樓虎囚，卻偏偏與公主長得像角塑，于是被迫代替她去往敵國和親。 傳聞我的和親對象是個殘疾皇子淘讥，可洞房花燭夜當晚...
    茶點故事閱讀 44,577評論 2贊 353