亚洲激情专区-91九色丨porny丨老师-久久久久久久女国产乱让韩-国产精品午夜小视频观看

溫馨提示×

溫馨提示×

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

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

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

琼结县| 白城市| 塔城市| 延川县| 文成县| 山阴县| 韶关市| 新竹市| 平邑县| 迁西县| 奉节县| 兴安盟| 伊川县| 蒲城县| 土默特右旗| 太和县| 邹城市| 托克逊县| 庄河市| 晋宁县| 阿克陶县| 巢湖市| 萝北县| 乐安县| 永泰县| 浑源县| 阳高县| 新营市| 新龙县| 岑溪市| 东安县| 津市市| 新河县| 萨迦县| 宝山区| 嘉义县| 濮阳县| 阿克| 昌邑市| 彰武县| 西峡县|