1:ribbon是提供通过serviceId拜访服务的能力,而且提供了负载平衡能力。在springcloud外面,有2个主动配置加载类 LoadBalancerAutoConfiguration 和 RibbonAutoConfiguration。LoadBalancerAutoConfiguration次要实现对 RestTemplate 对象的负载平衡拜访,RibbonAutoConfiguration次要是对Ribbon所需组件的实例化。别离在springcloud-common 和 netflix-core 的 spring.foctories 文件里。
org.springframework.boot.autoconfigure.EnableAutoConfiguration=org.springframework.cloud.netflix.hystrix.HystrixAutoConfiguration,org.springframework.cloud.netflix.hystrix.security.HystrixSecurityAutoConfiguration,org.springframework.cloud.netflix.ribbon.RibbonAutoConfiguration,org.springframework.cloud.netflix.rx.RxJavaAutoConfiguration,org.springframework.boot.autoconfigure.EnableAutoConfiguration=org.springframework.cloud.client.CommonsClientAutoConfiguration,org.springframework.cloud.client.loadbalancer.LoadBalancerAutoConfiguration,org.springframework.cloud.client.serviceregistry.ServiceRegistryAutoConfiguration,
2:RibbonAutoConfiguration 次要是对Ribbon组件的实例化,其对应关系是:
IClientConfig --> DefaultClientConfigImpl
IRule --> ZoneAvoidanceRule
IPing --> DummyPing
ServerList --> ConfigurationBasedServerList
ServerListUpdater --> PollingServerListUpdater
ILoadBalancer --> ZoneAwareLoadBalancer
LoadBalancerClient --> RibbonLoadBalancerClient
同时,也会创立:SpringClientFactory 对象。
3:LoadBalancerAutoConfiguration 次要是对 RestTemplate 进行负载平衡配置。 其次要实现是创立拦截器 LoadBalancerInterceptor。而后对 RestTemplate 进行自定义配置,代码如下:
@Bean public SmartInitializingSingleton loadBalancedRestTemplateInitializer( final List<RestTemplateCustomizer> customizers) { return new SmartInitializingSingleton() { @Override public void afterSingletonsInstantiated() { for (RestTemplate restTemplate : LoadBalancerAutoConfiguration.this.restTemplates) { for (RestTemplateCustomizer customizer : customizers) { customizer.customize(restTemplate); } } } }; }@Configuration @ConditionalOnMissingClass("org.springframework.retry.support.RetryTemplate") static class LoadBalancerInterceptorConfig { @Bean public LoadBalancerInterceptor ribbonInterceptor( LoadBalancerClient loadBalancerClient, LoadBalancerRequestFactory requestFactory) { return new LoadBalancerInterceptor(loadBalancerClient, requestFactory); } @Bean @ConditionalOnMissingBean public RestTemplateCustomizer restTemplateCustomizer( final LoadBalancerInterceptor loadBalancerInterceptor) { return new RestTemplateCustomizer() { @Override public void customize(RestTemplate restTemplate) { List<ClientHttpRequestInterceptor> list = new ArrayList<>( restTemplate.getInterceptors()); list.add(loadBalancerInterceptor); restTemplate.setInterceptors(list); } }; } }
在下面的代码中,减少的拦截器类是:LoadBalancerInterceptor。 LoadBalancerClient 接口的实现类是:RibbonLoadBalancerClient。
4:在应用 RestTemplate 进行 POST, GET 申请的时候,最终执行的是 办法:LoadBalancerInterceptor#intercept。 在该办法里,调用办法:RibbonLoadBalancerClient#execute(String, LoadBalancerRequest<T>)
@Override public ClientHttpResponse intercept(final HttpRequest request, final byte[] body, final ClientHttpRequestExecution execution) throws IOException { final URI originalUri = request.getURI(); String serviceName = originalUri.getHost(); Assert.state(serviceName != null, "Request URI does not contain a valid hostname: " + originalUri); return this.loadBalancer.execute(serviceName, requestFactory.createRequest(request, body, execution)); }
5:在 execute 办法里,次要是 获取到负载均衡器,获取服务提供者的拜访门路,拜访
@Override public <T> T execute(String serviceId, LoadBalancerRequest<T> request) throws IOException { ILoadBalancer loadBalancer = getLoadBalancer(serviceId); //获取负载均衡器 Server server = getServer(loadBalancer); //获取服务拜访门路,包含IP端口 if (server == null) { throw new IllegalStateException("No instances available for " + serviceId); } RibbonServer ribbonServer = new RibbonServer(serviceId, server, isSecure(server, serviceId), serverIntrospector(serviceId).getMetadata(server)); return execute(serviceId, ribbonServer, request); //拜访服务 }
6:在 SpringClientFactory#getLoadBalancer 里,获取的是接口 ILoadBalancer 的实例。其实现是 结构Spring的上下文对象 AnnotationConfigApplicationContext, 而后加载配置类:RibbonClientConfiguration.
在RibbonClientConfiguration类里,会实例化 ZoneAwareLoadBalancer 对象。获取到 ILoadBalancer 的单例模式后,会缓存在内存外面。
public ILoadBalancer getLoadBalancer(String name) { return getInstance(name, ILoadBalancer.class); }protected AnnotationConfigApplicationContext getContext(String name) { if (!this.contexts.containsKey(name)) { synchronized (this.contexts) { if (!this.contexts.containsKey(name)) { this.contexts.put(name, createContext(name)); } } } return this.contexts.get(name); }@Bean @ConditionalOnMissingBean public ILoadBalancer ribbonLoadBalancer(IClientConfig config, ServerList<Server> serverList, ServerListFilter<Server> serverListFilter, IRule rule, IPing ping, ServerListUpdater serverListUpdater) { if (this.propertiesFactory.isSet(ILoadBalancer.class, name)) { return this.propertiesFactory.get(ILoadBalancer.class, config, name); } return new ZoneAwareLoadBalancer<>(config, rule, ping, serverList, serverListFilter, serverListUpdater); }
7:ZoneAwareLoadBalancer 会调用 ZoneAvoidanceRule 里的 choose() 办法。 该办法外面,通过负载均衡器里,获取所有的服务节点(IRule实例里的负载均衡器是在ZoneAwareLoadBalancer 实例化的时候设置的)。lb.getAllServers() 办法获取的是获取的缓存对象 allServerList。
@Override public Server choose(Object key) { ILoadBalancer lb = getLoadBalancer(); Optional<Server> server = getPredicate().chooseRoundRobinAfterFiltering(lb.getAllServers(), key); if (server.isPresent()) { return server.get(); } else { return null; } }
8:获取到服务列表后,ZoneAvoidanceRule 前面 应用 chooseRoundRobinAfterFiltering() 抉择服务,按照代码,应用的是循环算法抉择 Server
public Optional<Server> chooseRoundRobinAfterFiltering(List<Server> servers, Object loadBalancerKey) { List<Server> eligible = getEligibleServers(servers, loadBalancerKey); if (eligible.size() == 0) { return Optional.absent(); } return Optional.of(eligible.get(nextIndex.getAndIncrement() % eligible.size())); }
9:选定Server对象后,外面有拜访的实例的IP和端口信息。会应用 httpClient 对象拜访对象的节点。代码如下:
public LoadBalancerRequest<ClientHttpResponse> createRequest(final HttpRequest request, final byte[] body, final ClientHttpRequestExecution execution) { return new LoadBalancerRequest<ClientHttpResponse>() { @Override public ClientHttpResponse apply(final ServiceInstance instance) throws Exception { HttpRequest serviceRequest = new ServiceRequestWrapper(request, instance, loadBalancer); if (transformers != null) { for (LoadBalancerRequestTransformer transformer : transformers) { serviceRequest = transformer.transformRequest(serviceRequest, instance); } } return execution.execute(serviceRequest, body); } }; }