# ribbon-spring-boot-starter ## ribbon客戶端負載均衡 > ribbon客戶端負載均衡: 消費方從注冊中心上獲取接口調用地址列表，客戶端實現負載均衡算法(輪詢，隨機，hash一致性，權重)等原理獲取接口地址列表，采用算法規則獲取選擇一個接口地址，并發起遠程調用 ## 負載均衡主要組件  | 組件 | 作用 | | --- | --- | | ILoadBalancer | 定義一系列的操作接口，比如選擇服務實例 | | IRule| 算法策略，內置算法策略來為服務實例的選擇提供服務| | ServerList| 負責服務實例信息的獲取，可以獲取配置文件中的，也可以從注冊中心獲取| | ServerListFilter| 過濾掉某些不想要的服務實例信息| | ServerListUpdater| 更新本地緩存的服務實例信息| | IPing| 對已有的服務實例進行可用性檢查，保證選擇的服務都是可用的| ## 規則接口   ## 默認規則   ## 自定義規則  ## 替換自定義規則    ## 自定義過濾規則  ### 默認規則返回false時    #### 在上面`choose`函數中調用的`chooseRoundRobinAfterFiltering`方法先通過內部定義的`getEligibleServers`函數來獲取備選的實例清單（實現了過濾），由于MetadataAwarePredicate返回了false,返回的清單為空，則用`Optional.absent()`來表示不存在   ### 默認規則返回true時  #### 在上面`choose`函數中調用的`chooseRoundRobinAfterFiltering`方法先通過內部定義的`getEligibleServers`函數來獲取備選的實例清單（實現了過濾），由于MetadataAwarePredicate返回了true ，以線性輪詢的方式從備選清單中獲取一個實例。 ``` // 線性輪詢 private int incrementAndGetModulo(int modulo) { for (;;) { int current = nextIndex.get(); int next = (current + 1) % modulo; if (nextIndex.compareAndSet(current, next)) return current; } } ``` ## 總結： 在了解了整體邏輯之后，我們來詳細看看實現過濾功能的`getEligibleServers`函數。從源碼上看，它的實現結構非常簡單清晰，通過遍歷服務清單，使用`this.apply`方法來判斷實例是否需要保留，是就添加到結果列表中。 ## Predicate 介紹 ### Predicate 流程處理 #### `chooseRoundRobinAfterFiltering` 內部的細節 ``` @Override public Server choose(Object key) { ILoadBalancer lb = getLoadBalancer(); // 過濾之后循環選擇server Optional<Server> server = getPredicate().chooseRoundRobinAfterFiltering(lb.getAllServers(), key); if (server.isPresent()) { return server.get(); } else { return null; } } ```  #### `getEligibleServers`函數來獲取備選的實例清單 ``` @Override public List<Server> getEligibleServers(List<Server> servers, Object loadBalancerKey) { // 先調用抽象類過濾 List<Server> result = super.getEligibleServers(servers, loadBalancerKey); // 再進行過濾 Iterator<AbstractServerPredicate> i = fallbacks.iterator(); while (!(result.size() >= minimalFilteredServers && result.size() > (int) (servers.size() * minimalFilteredPercentage)) && i.hasNext()) { AbstractServerPredicate predicate = i.next(); result = predicate.getEligibleServers(servers, loadBalancerKey); } return result; } ```  #### 通過遍歷服務清單   #### 使用`this.apply`方法來判斷實例是否需要保留，是就添加到結果列表中     以上是Predicate 流程處理細節， 下面將要介紹的兩個策略就是基于此抽象策略實現，只是它們使用了不同的`Predicate`實現來完成過濾邏輯以達到不同的實例選擇效果。