您好,登錄后才能下訂單哦!
本篇文章給大家分享的是有關Ribbon中AvailabilityFilteringRule的作用是什么,小編覺得挺實用的,因此分享給大家學習,希望大家閱讀完這篇文章后可以有所收獲,話不多說,跟著小編一起來看看吧。
Ribbon的版本是2.3.0.release.
圖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,
獲取所有的服務實例
遍歷服務列表,過濾掉不滿足條件的
在滿足條件的服務列表中,再進行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的作用是什么,小編相信有部分知識點可能是我們日常工作會見到或用到的。希望你能通過這篇文章學到更多知識。更多詳情敬請關注億速云行業資訊頻道。
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。