# 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`实现来完成过滤逻辑以达到不同的实例选择效果。