Ribbon负载均衡原理

负载均衡原理"/>

Ribbon负载均衡原理

一、先看下流程图

备注：红色后面都为拦截器的逻辑，主要是加载配置文件【LoadBalancerAutoConfiguration】，对发送http请求的RestTemplate进行包装拦截，逻辑拦在拦截器里面。

二、LoadBalancerAutoConfiguration

负载均衡用到配置类：LoadBalancerAutoConfiguration

LoadBalancerAutoConfiguration主要做2个事情。1、生成Bean: LoadBalancerInterceptor  拦截器
2、生成Bean: RestTemplateCustomizer   这个是RestTemplate的包装对象，里面拿到上面生成的拦截器，
然后把拦截器添加到RestTemplate里面去。restTemplate每次执行方法请求时，都会调用【intercept方法】执行拦截，
在intercept方法里面，通过【服务名】获取了该服务对应的【负载均衡器ILoadBalancer】的实例对象，
然后调用该实例的chooseServer方法获取一个具体【服务实例】，然后发送http请求服务提供者。

三、LoadBalancerClient

在Ribbon中有个非常重要的组件LoadBalancerClient，它是【负载均衡的客户端】，通过LoadBalancerClient的方法，
我们只需要传一个【服务名】，那么LoadBalancerClient就会根据【服务名】返回对应的【负载均衡器】而LoadBalancerClient是一个接口，真正的实现类正是RibbonLoadBalancerClient，逻辑都在choos方法里面，
先通过【服务Id】拿到ILoadBalancer，这个也叫【负载均衡器】下面看下ILoadBalancer【负载均衡器】：ILoadBalancer的实现类有ZoneAwareLoadBalancer，
主要包含以下2个内容
1、里面的allServerList列表已经缓存了所有的服务列表，
2、里面还有个属性IRule，这个就是真正负载均衡算法的核心当负载均衡器调用chooseServer方法时，会通过负载均衡算法IRule，返回哪一个具体的Server，这个就是我们最终要调用的服务Ip+端口。ILoadBalancer接口定义了Ribbon中核心的两项内容，【服务获取】与【服务选择】，
可以说ILoadBalancer是Ribbon中最重要的一个组件，它起到了承上启下的作用，既要连接 Eureka获取服务地址，
又要调用IRule利用负载均衡算法选择服务

服务获取

Ribbon在选择之前需要获取服务列表，而Ribbon本身不具有服务发现的功能，
所以需要借助Eureka来解决获取服务列表的问题, 其实在获取实例的过程中，
1、先他得到一个EurekaClient的实例，然后借助EurekaClient的服务发现功能，来获取服务的实例列表。
2、在获取了实例信息后，判断服务的状态如果为UP，那么最终将它加入serverList中。在获取得到serverList后，会进行缓存操作。首先进入BaseLoadBalancer的setServerList方法，
里面会往下面2个缓存赛数据，将拉取的serverList赋值给缓存列表allServerList。 protected volatile List<Server> allServerList = Collections.synchronizedList(new ArrayList<Server>());
protected volatile List<Server> upServerList = Collections.synchronizedList(new ArrayList<Server>());Ribbon从Eureka中得到了服务列表，缓存在本地List后，存在一个问题，如何保证在调用服务的时候服务仍然处于可用状态，
也就是说应该如何解决缓存列表脏读问题？在默认负载均衡器ZoneAwareLoadBalancer#setupPingTask方法中，里面创建了一个定时任务，使用ping的方式判断服务是否可用。怎么ping的呢，不是判断网络通不通，这个ping只是他的方法这么叫，实际上还是通过查询EurekaServer返回服务的状态来判断。
因为本地的serverList为缓存值，可能与eureka中不同，所以从eureka中去查询该实例的状态，
如果eureka里面显示该实例状态为UP，就返回true，说明服务可用。
通过调用EurekaServer的接口，获取到服务的状态列表后，进行循环，如果状态改变，加入到changedServers中，
并且把所有可用服务加入newUpList，最终更新upServerList中缓存值除了使用ping的方式去检测服务是否在线外，Ribbon还使用了别的方式来更新服务列表。使用了定时调度线程池调用了PollingServerListUpdater#start方法，来进行更新服务操作Ribbon为了解决服务列表的脏读现象，采用了两种手段：
1、更新列表  （定时任务）
2、ping机制 （定时任务）更新机制和ping机制功能基本重合，并且在ping的时候不能执行更新，在更新的时候不能运行ping，所以很难检测到ping失败的情况。

负载均衡算法

Ribbon默认使用的是ZoneAvoidanceRule，也叫【区域亲和】负载均衡算法，优先调用一个zone区间中的服务，
并使用轮询算法。当然，也可以由我们自己实现IRule接口，重写其中的choose方法来实现自己的负载均衡算法，然后通过@Bean的方式注入到spring容器中。
当然也可以将不同的服务应用不同的IRule策略，这里需要注意的是，Spring cloud的官方文档中提醒我们，
如果多个微服务要调用不同的IRule，那么创建出IRule的配置类不能放在ComponentScan的目录下面，
这样所有的微服务都会使用这一个策略。

总结

综上所述，在Ribbon的负载均衡中，大致可以分为以下几步：
1、拦截请求，通过请求中的url地址，截取服务名称
2、通过LoadBalancerClient获取ILoadBalancer
3、使用Eureka获取服务列表
4、通过IRule负载均衡策略选择具体服务
5、ILoadBalancer通过IPing及定时更新机制来维护服务列表
6、重构该url地址，最终调用HttpURLConnection发起请求了解了整个调用流程后，我们更容易明白为什么Ribbon叫做客户端的负载均衡。与nginx服务端负载均衡不同，
1、nginx在使用反向代理具体服务的时候，调用端不知道都有哪些服务。
2、Ribbon在调用之前，已经知道有哪些服务可用，直接通过本地负载均衡策略调用即可。
而在实际使用过程中，也可以根据需要，结合两种方式真正实现高可用。