中文字幕av专区_日韩电影在线播放_精品国产精品久久一区免费式_av在线免费观看网站

溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

zk中怎么通過監聽讀取配置信息

發布時間:2021-06-21 14:54:31 來源:億速云 閱讀:160 作者:Leah 欄目:大數據

這期內容當中小編將會給大家帶來有關zk中怎么通過監聽讀取配置信息,文章內容豐富且以專業的角度為大家分析和敘述,閱讀完這篇文章希望大家可以有所收獲。

import com.alibaba.fastjson.JSON;
import com.google.common.collect.Maps;
import lombok.extern.slf4j.Slf4j;
import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.WatchedEvent;
import org.apache.zookeeper.Watcher;
import org.apache.zookeeper.ZooDefs;
import org.apache.zookeeper.ZooKeeper;
import org.apache.zookeeper.data.Stat;

import java.io.IOException;
import java.util.Map;
import java.util.concurrent.ConcurrentMap;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.atomic.AtomicInteger;

@Slf4j
public class ZkClientWatcher implements Watcher {

    private static final String CONNECT_ADDRESS = "10.10.136.114:2181,10.10.136.114:2182,10.10.136.114:2183";
    private static final int SESSION_TIMEOUT = 2000;
    public static final int MAX = 3;
    private static String CONFIG_PATH = "/application-config";
    private static ZooKeeper zk;
    private static CountDownLatch countDownLatch = new CountDownLatch(1);
    private static ConcurrentMap<String, String> oldConfig = Maps.newConcurrentMap();
    private static ConcurrentMap<String, String> newConfig = Maps.newConcurrentMap();

    private static AtomicInteger count = new AtomicInteger(1);

    public void createConnection(String connectAddres, int sessionTimeOut) throws InterruptedException {
        try {
            zk = new ZooKeeper(connectAddres, sessionTimeOut, this);
            log.info("zk connecting...");
        } catch (IOException e) {
            e.printStackTrace();
        } finally {

        }
    }

    public boolean createPath(String path, String data) {
        try {
            if (null == zk.exists(path, true)) {
                zk.create(path, data.getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);
                log.info("node create success");
            }
        } catch (Exception e) {
            e.printStackTrace();
            return false;
        }
        return true;
    }


    @Override
    public void process(WatchedEvent event) {

        Event.KeeperState keeperState = event.getState();
        Event.EventType eventType = event.getType();
        String path = event.getPath();
        log.info("process:{},keeperState:{},eventType:{},path:{}", keeperState, eventType, path);
        if (Event.KeeperState.SyncConnected == keeperState) {

            if (Event.EventType.None == eventType) {
                log.info("now status is None");

            } else if (Event.EventType.NodeCreated == eventType) {
                log.info("now status is nodeCreated,path:{}", path);
            } else if (Event.EventType.NodeDataChanged == eventType) {
                log.info("now status is nodedataChanged:{}", path);
                try {
                    newConfig = JSON.parseObject(zk.getData(path, true, new Stat()), ConcurrentMap.class);
                    log.info("newConfig is {}", newConfig);
                    count.getAndIncrement();
                    if (count.get() > MAX) {
                        countDownLatch.countDown();
                    }
                } catch (Exception e) {
                    log.error("get data from zk occur exception", e);
                }

            } else if (Event.EventType.NodeDeleted == eventType) {
                log.info("now status is node deleted:{}", path);
            }
        }
    }

    public static void main(String[] args) throws Exception {

        ZkClientWatcher watcher = new ZkClientWatcher();
        watcher.createConnection(CONNECT_ADDRESS, SESSION_TIMEOUT);
        createPathAndInitData(watcher);
        getOldConfig();
        countDownLatch.await();
        log.info("test complete!config has changed 3 times");
    }

    /**
     * 第一次獲取配置信息
     *
     * @throws Exception
     */
    private static void getOldConfig() throws Exception {
        oldConfig = JSON.parseObject(zk.getData(CONFIG_PATH, true, new Stat()), ConcurrentMap.class);
        log.info("oldConfig is {}", oldConfig);
    }

    /**
     * 創建path設置初始值
     *
     * @param watcher
     */
    private static void createPathAndInitData(ZkClientWatcher watcher) {
        Map<String, String> maps = Maps.newConcurrentMap();
        maps.put("spring.data.status.start", "true");
        maps.put("switch", "on");
        maps.put("startTime", "2019-10-24 12:00:00");
        maps.put("coder", "1024");
        watcher.createPath(CONFIG_PATH, JSON.toJSONString(maps));
    }
}

上述就是小編為大家分享的zk中怎么通過監聽讀取配置信息了,如果剛好有類似的疑惑,不妨參照上述分析進行理解。如果想知道更多相關知識,歡迎關注億速云行業資訊頻道。

向AI問一下細節

免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。

zk
AI

云南省| 新和县| 广丰县| 澎湖县| 朔州市| 英超| 道孚县| 石台县| 庆阳市| 台东市| 曲周县| 东山县| 重庆市| 海安县| 昌江| 景泰县| 阳新县| 通渭县| 三门峡市| 锦屏县| 射洪县| 双峰县| 上思县| 井研县| 江阴市| 秦安县| 潮安县| 泰宁县| 淮阳县| 峡江县| 文化| 翁源县| 宜良县| 皋兰县| 军事| 新源县| 庆城县| 大荔县| 西吉县| 观塘区| 黄冈市|