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

溫馨提示×

溫馨提示×

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

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

Ribbon中AvailabilityFilteringRule的作用是什么

發布時間:2021-06-21 15:12:02 來源:億速云 閱讀:395 作者:Leah 欄目:大數據

本篇文章給大家分享的是有關Ribbon中AvailabilityFilteringRule的作用是什么,小編覺得挺實用的,因此分享給大家學習,希望大家閱讀完這篇文章后可以有所收獲,話不多說,跟著小編一起來看看吧。

    Ribbon的版本是2.3.0.release.

                                 Ribbon中AvailabilityFilteringRule的作用是什么

                                                                             圖1

    AvailabilityFilteringRule繼承了PredicateBasedRule,這是因為使用到了AbstractServerPredicate.

    choose方法如下List-1, 輪循選一個,判讀是否滿足條件,如果滿足則返回,超過10次,則調用父類的choose方法選擇.

    List-1

public Server choose(Object key) {
    int count = 0;

    for(Server server = this.roundRobinRule.choose(key); count++ <= 10; server = this.roundRobinRule.choose(key)) {
        if (this.predicate.apply(new PredicateKey(server))) {
            return server;
        }
    }

    return super.choose(key);
}

    來看AvailabilityPredicate,如下List-2, apply方法返回true,需要滿足倆個條件,斷路器閉合,調用服務的并發請求數小于限制數

    List-2

public boolean apply(@Nullable PredicateKey input) {
    LoadBalancerStats stats = this.getLBStats();
    if (stats == null) {
        return true;
    } else {
        return !this.shouldSkipServer(stats.getSingleServerStat(input.getServer()));
    }
}

private boolean shouldSkipServer(ServerStats stats) {
    return CIRCUIT_BREAKER_FILTERING.get() && stats.isCircuitBreakerTripped() || stats.getActiveRequestsCount() >= (Integer)this.activeConnectionsLimit.get();
}

    List-1中10次之后還不滿足,則調用父類的choose方法,來看下PredicateBasedRule的choose實現,如下List-3

    List-3

public Server choose(Object key) {
    ILoadBalancer lb = this.getLoadBalancer();
    Optional<Server> server = this.getPredicate().chooseRoundRobinAfterFiltering(lb.getAllServers(), key);
    return server.isPresent() ? (Server)server.get() : null;
}

    chooseRoundRobinAfterFiltering中是如何實現的呢,如下List-4,

  1. 獲取所有的服務實例

  2. 遍歷服務列表,過濾掉不滿足條件的

  3. 在滿足條件的服務列表中,再進行RoundRibbon算法,選出服務

    List-4

public Optional<Server> chooseRoundRobinAfterFiltering(List<Server> servers, Object loadBalancerKey) {
    List<Server> eligible = this.getEligibleServers(servers, loadBalancerKey);
    return eligible.size() == 0 ? Optional.absent() : Optional.of(eligible.get(this.incrementAndGetModulo(eligible.size())));
}

public List<Server> getEligibleServers(List<Server> servers, Object loadBalancerKey) {
    if (loadBalancerKey == null) {
        return ImmutableList.copyOf(Iterables.filter(servers, this.getServerOnlyPredicate()));
    } else {
        List<Server> results = Lists.newArrayList();
        Iterator var4 = servers.iterator();

        while(var4.hasNext()) {
            Server server = (Server)var4.next();
            if (this.apply(new PredicateKey(loadBalancerKey, server))) {
                results.add(server);
            }
        }
        return results;
    }
}

    AvailabilityFilteringRule在RoundRibbon的基礎上,選擇滿足條件的服務,如果10次了還沒得到,則在滿足條件的服務列表中,再用RoundRibbon算法選擇.

以上就是Ribbon中AvailabilityFilteringRule的作用是什么,小編相信有部分知識點可能是我們日常工作會見到或用到的。希望你能通過這篇文章學到更多知識。更多詳情敬請關注億速云行業資訊頻道。

向AI問一下細節

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

AI

太原市| 衡东县| 务川| 岢岚县| 宁晋县| 乌拉特中旗| 鹰潭市| 肇州县| 乌海市| 墨玉县| 遂溪县| 横山县| 舞钢市| 石嘴山市| 竹北市| 都匀市| 凉山| 聂荣县| 靖宇县| 高尔夫| 普定县| 南汇区| 泰宁县| 资阳市| 图木舒克市| 巫溪县| 涪陵区| 陆良县| 恭城| 武安市| 柳林县| 承德市| 左权县| 肃宁县| 岐山县| 定结县| 德州市| 宝清县| 抚顺县| 肥乡县| 大理市|