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

創(chuàng)新互聯(lián)公司從2013年成立，先為三亞等服務(wù)建站，三亞等地企業(yè)，進(jìn)行企業(yè)商務(wù)咨詢服務(wù)。為三亞企業(yè)網(wǎng)站制作PC+手機(jī)+微官網(wǎng)三網(wǎng)同步一站式服務(wù)解決您的所有建站問題。

    Ribbon的版本是2.3.0.release.

                                                                             圖1

    AvailabilityFilteringRule繼承了PredicateBasedRule，這是因?yàn)槭褂玫搅薃bstractServerPredicate.

    choose方法如下List-1, 輪循選一個，判讀是否滿足條件，如果滿足則返回，超過10次，則調(diào)用父類的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，需要滿足倆個條件，斷路器閉合，調(diào)用服務(wù)的并發(fā)請求數(shù)小于限制數(shù)

    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次之后還不滿足，則調(diào)用父類的choose方法，來看下PredicateBasedRule的choose實(shí)現(xiàn)，如下List-3

    List-3

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

    chooseRoundRobinAfterFiltering中是如何實(shí)現(xiàn)的呢，如下List-4，

1. 獲取所有的服務(wù)實(shí)例

2. 遍歷服務(wù)列表，過濾掉不滿足條件的

3. 在滿足條件的服務(wù)列表中，再進(jìn)行RoundRibbon算法，選出服務(wù)

    List-4

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

public List getEligibleServers(List servers, Object loadBalancerKey) {
    if (loadBalancerKey == null) {
        return ImmutableList.copyOf(Iterables.filter(servers, this.getServerOnlyPredicate()));
    } else {
        List 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的基礎(chǔ)上，選擇滿足條件的服務(wù)，如果10次了還沒得到，則在滿足條件的服務(wù)列表中，再用RoundRibbon算法選擇.

以上就是Ribbon中AvailabilityFilteringRule的作用是什么，小編相信有部分知識點(diǎn)可能是我們?nèi)粘９ぷ鲿姷交蛴玫降?。希望你能通過這篇文章學(xué)到更多知識。更多詳情敬請關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。