接着上面的一篇关于Spring Cloud之Open Feign调用流程和源码分析，解析feign在rpc调用的时候lb的组成及底层工作流程。
1.是如何加载到spring中的呢？了解spring boot加载jar包原理的应该知道，spring boot通过spi机制加载我们需要扩展的类,即在spring.factories 配置j类的全限定名称的形式。对于不太了解springboot的spi机制的同学，可以查看我的这篇jdk、springboot、dubbospi机制对比。LoadBalancerAutoConfiguration加载LoadBalancerRetryProperties(负载均衡器的是否开启重试)和LoadBalancerClient。
负载均衡器的是否开启重试配置类：
@ConfigurationProperties("spring.cloud.loadbalancer.retry")
public class LoadBalancerRetryProperties {
//...
}2.@LoadBalanced的RestTemplate Bean添加了一个LoadBalancerInterceptor拦截器，而这个拦截器的作用就是对请求的URI进行转换获取到具体应该请求哪个服务实例。通过LoadBalancerClient执行具体的请求发送，通过默认的方法（默认策略）选取服务器。
配置类配置loadBalancerInterceptor拦截器：
LoadBalancerAutoConfiguration
@Bean
@ConditionalOnMissingBean
public RestTemplateCustomizer restTemplateCustomizer(final RetryLoadBalancerInterceptor loadBalancerInterceptor) {
return (restTemplate) -> {
List<ClientHttpRequestInterceptor> list = new ArrayList(restTemplate.getInterceptors());
list.add(loadBalancerInterceptor);
restTemplate.setInterceptors(list);
};
}
}拦截器获取调用服务名称：
LoadBalancerInterceptor
public ClientHttpResponse intercept(final HttpRequest request, final byte[] body, final ClientHttpRequestExecution execution) throws IOException {
URI originalUri = request.getURI();
String serviceName = originalUri.getHost();
Assert.state(serviceName != null, "Request URI does not contain a valid hostname: " + originalUri);
return (ClientHttpResponse)this.loadBalancer.execute(serviceName, this.requestFactory.createRequest(request, body, execution));
}LoadBalancerClient配置的默认路由策略（轮询）：
RibbonLoadBalancerClient
protected Server getServer(ILoadBalancer loadBalancer) {
return loadBalancer == null ? null : loadBalancer.chooseServer("default");
}3.从 RibbonLoadBalancerClient 代码可以看出，实际负载均衡的是通过 ILoadBalancer 来实现的，默认采用了ZoneAwareLoadBalancer来实现负载均衡器；
RibbonLoadBalancerClient
public <T> T execute(String serviceId, LoadBalancerRequest<T> request) throws IOException {
ILoadBalancer loadBalancer = this.getLoadBalancer(serviceId);
Server server = this.getServer(loadBalancer);
if (server == null) {
throw new IllegalStateException("No instances available for " + serviceId);
} else {
RibbonLoadBalancerClient.RibbonServer ribbonServer = new RibbonLoadBalancerClient.RibbonServer(serviceId, server, this.isSecure(server, serviceId), this.serverIntrospector(serviceId).getMetadata(server));
return this.execute(serviceId, ribbonServer, request);
}
}
lb的类图
BaseLoadBalancer：
一个负载均衡器的基本实现，其中有一个任意列表，可以将服务器设置为服务器池。
可以设置一个ping来确定服务器的活力。
在内部，该类维护一个“all”服务器列表，以及一个“up”服务器列表，并根据调用者的要求使用它们。
通过动态的获取服务器的候选列表的负载平衡器。
可以通过筛选标准来传递服务器列表，以过滤不符合所需条件的服务器。
用于测量区域条件的关键指标是平均活动请求，它根据每个rest客户机和每个区域聚合。这是区域内未完成的请求总数除以可用目标实例的数量(不包括断路器跳闸实例)。当在坏区上缓慢发生超时时，此度量非常有效。
该负载均衡器将计算并检查所有可用区域的区域状态。如果任何区域的平均活动请求已达到配置的阈值，则该区域将从活动服务器列表中删除。如果超过一个区域达到阈值，则将删除每个服务器上活动请求最多的区域。一旦去掉最坏的区域，将在其余区域中选择一个区域，其概率与其实例数成正比。服务器将使用给定的规则从所选区域返回。对于每个请求，将重复上述步骤。也就是说，每个与区域相关的负载平衡决策都是实时做出的，最新的统计数据可以帮助进行选择。
RibbonClient默认的连接超时、读取内容超时是1s：
public class RibbonClientConfiguration {
public static final int DEFAULT_CONNECT_TIMEOUT = 1000;
public static final int DEFAULT_READ_TIMEOUT = 1000;
@RibbonClientName
private String name = "client";
@Autowired
private PropertiesFactory propertiesFactory;
} RibbonClientConfiguration
@Bean
@ConditionalOnMissingBean
public ILoadBalancer ribbonLoadBalancer(IClientConfig config, ServerList<Server> serverList, ServerListFilter<Server> serverListFilter, IRule rule, IPing ping, ServerListUpdater serverListUpdater) {
return (ILoadBalancer)(this.propertiesFactory.isSet(ILoadBalancer.class, this.name) ? (ILoadBalancer)this.propertiesFactory.get(ILoadBalancer.class, config, this.name) : new ZoneAwareLoadBalancer(config, rule, ping, serverList, serverListFilter, serverListUpdater));
}其中new ZoneAwareLoadBalancer(config, rule, ping, serverList, serverListFilter, serverListUpdater) 代码包含了lb使用到的所有组件，下面会一一说明。
public class DefaultClientConfigImpl implements IClientConfig {
public static final Boolean DEFAULT_PRIORITIZE_VIP_ADDRESS_BASED_SERVERS;
public static final String DEFAULT_NFLOADBALANCER_PING_CLASSNAME = "com.netflix.loadbalancer.DummyPing";
public static final String DEFAULT_NFLOADBALANCER_RULE_CLASSNAME = "com.netflix.loadbalancer.AvailabilityFilteringRule";
public static final String DEFAULT_NFLOADBALANCER_CLASSNAME = "com.netflix.loadbalancer.ZoneAwareLoadBalancer";
public static final boolean DEFAULT_USEIPADDRESS_FOR_SERVER;
public static final String DEFAULT_CLIENT_CLASSNAME = "com.netflix.niws.client.http.RestClient";
public static final String DEFAULT_VIPADDRESS_RESOLVER_CLASSNAME = "com.netflix.client.SimpleVipAddressResolver";
public static final String DEFAULT_PRIME_CONNECTIONS_URI = "/";
//...
}5.Rule分类：
rule的类图
6.ping, serverList, serverListFilter, serverListUpdater组件介绍；
定义如何 “ping” 服务器以检查其是否存活；
ping的类图
ServerList
定义获取所有的服务实例清单。
serverList的类图
ServerListFilter
允许根据过滤配置动态获得的具有所需特性的候选服务器列表。
ServerListFilter类图
ServerListUpdater
用于执行动态服务器列表更新。
serverListUpdater类图