今天繼續(xù)源碼分析，分析一下org.apache.zookeeper.server下的WatchManager類。

創(chuàng)新互聯(lián)公司10多年成都定制網(wǎng)頁設(shè)計服務(wù);為您提供網(wǎng)站建設(shè),網(wǎng)站制作,網(wǎng)頁設(shè)計及高端網(wǎng)站定制服務(wù),成都定制網(wǎng)頁設(shè)計及推廣,對砂巖浮雕等多個領(lǐng)域擁有多年的網(wǎng)站制作經(jīng)驗的網(wǎng)站建設(shè)公司。

WatcherManager類用于管理watchers和相應(yīng)的觸發(fā)器。

類的屬性

//watchTable表示從節(jié)點路徑到watcher集合的映射
    private final HashMap<String, HashSet<Watcher>> watchTable =
        new HashMap<String, HashSet<Watcher>>();
    //watch3Paths則表示從watcher到所有節(jié)點路徑集合的映射
    private final HashMap<Watcher, HashSet<String>> watch3Paths =
        new HashMap<Watcher, HashSet<String>>();

核心方法

1. size方法

size方法是同步的，因此在多線程環(huán)境下是安全的，其主要作用是獲取watchTable的大小，即遍歷watchTable的值集合，每個集合大小累加。

synchronized int size(){
        int result = 0;
        for(Set<Watcher> watches : watchTable.values()) {
            result += watches.size();
        }
        return result;
    }

2、addWatch方法

addWatch方法同樣是同步的，主要用來更新類里面的上面提到的兩個集合屬性。

synchronized void addWatch(String path, Watcher watcher) {
        //通過傳入的path（節(jié)點路徑）從watchTable獲取相應(yīng)的watcher集合
        HashSet<Watcher> list = watchTable.get(path);
        if (list == null) { //watcher是否為空，若為空
            // don't waste memory if there are few watches on a node
            // rehash when the 4th entry is added, doubling size thereafter
            // seems like a good compromise
            //新生成watcher集合，并將路徑path和此集合添加至watchTable中
            list = new HashSet<Watcher>(4);
            watchTable.put(path, list);
        }
        //將傳入的watcher添加至watcher集合，即完成了path和watcher添加至watchTable的步驟
        list.add(watcher);
        //通過傳入的watcher從watch3Paths中獲取相應(yīng)的path集合
        HashSet<String> paths = watch3Paths.get(watcher);
        if (paths == null) {// 判斷path集合是否為空，若為空
            // cnxns typically have many watches, so use default cap here
            //新生成path集合，并將watcher和paths添加至watch3Paths中
            paths = new HashSet<String>();
            watch3Paths.put(watcher, paths);
        }
        // 將傳入的path（節(jié)點路徑）添加至path集合，即完成了path和watcher添加至watch3Paths的步驟
        paths.add(path);
    }

3、removeWatcher

removeWatcher用作從watch3Paths和watchTable中中移除該watcher

synchronized void removeWatcher(Watcher watcher) {
        //從wach3Paths中移除watcher，并返回watcher對應(yīng)的path集合
        HashSet<String> paths = watch3Paths.remove(watcher);
        if (paths == null) {
            return;
        }
        for (String p : paths) {
            //從watcherTable中根據(jù)路徑取出相應(yīng)的watcher集合
            HashSet<Watcher> list = watchTable.get(p);
            if (list != null) {
                // 從list中移除該watcher
                list.remove(watcher);
                // 移除后list為空，則從watchTable中移出path
                if (list.size() == 0) {
                    watchTable.remove(p);
                }
            }
        }
    }

4、triggerWatch

該方法主要用于觸發(fā)watch事件，并對事件進(jìn)行處理。

Set<Watcher> triggerWatch(String path, EventType type) {
        return triggerWatch(path, type, null);
    }

    Set<Watcher> triggerWatch(String path, EventType type, Set<Watcher> supress) {
        // 根據(jù)事件類型、連接狀態(tài)、節(jié)點路徑創(chuàng)建WatchedEvent
        WatchedEvent e = new WatchedEvent(type,
                KeeperState.SyncConnected, path);
        HashSet<Watcher> watchers;
        synchronized (this) {
            // 從watcher表中移除path，并返回其對應(yīng)的watcher集合
            watchers = watchTable.remove(path);
            if (watchers == null || watchers.isEmpty()) {
                if (LOG.isTraceEnabled()) {
                    ZooTrace.logTraceMessage(LOG,
                            ZooTrace.EVENT_DELIVERY_TRACE_MASK,
                            "No watchers for " + path);
                }
                return null;
            }
            // 遍歷watcher集合
            for (Watcher w : watchers) {
                // 根據(jù)watcher從watcher表中取出路徑集合
                HashSet<String> paths = watch3Paths.get(w);
                if (paths != null) {
                                // 如果paths不為空，則移除傳入路徑path
                    paths.remove(path);
                }
            }
        }
        // 遍歷watcher集合
        for (Watcher w : watchers) {
            if (supress != null && supress.contains(w)) {
                continue;
            }
            // watcher進(jìn)行處理
            w.process(e);
        }
        return watchers;
    }

創(chuàng)新互聯(lián)www.cdcxhl.cn，專業(yè)提供香港、美國云服務(wù)器，動態(tài)BGP最優(yōu)骨干路由自動選擇，持續(xù)穩(wěn)定高效的網(wǎng)絡(luò)助力業(yè)務(wù)部署。公司持有工信部辦法的idc、isp許可證， 機房獨有T級流量清洗系統(tǒng)配攻擊溯源，準(zhǔn)確進(jìn)行流量調(diào)度，確保服務(wù)器高可用性。佳節(jié)活動現(xiàn)已開啟，新人活動云服務(wù)器買多久送多久。

分享題目：zookeeper（10）源碼分析-事件監(jiān)聽Watcher（3）-創(chuàng)新互聯(lián)
本文URL：http://chinadenli.net/article24/dgjhje.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供外貿(mào)建站、ChatGPT、靜態(tài)網(wǎng)站、網(wǎng)站收錄、虛擬主機、電子商務(wù)

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)