Ribbon 源码分析

Ribbon Debug 分析

1. 断点 LoadBalancerInterceptor

   1. LoadBalancerInterceptor 实现了 ClientHttpRequestInterceptor 接口，重写了其中的 intercept 方法，用来拦截请求；

   2. 获取原始的 uri 和 服务名，调用 LoadBalancerClient 中的 execute 方法；

2. 追踪 LoadBalancer 的实现 RibbonLoadBalancerClient

   1. 这里根据上面传入的服务名字作为服务的 ID去获取负载均衡器；

   2. 再根据负载均衡器去选择服务实例，继续执行 execute 方法。
      

3. 追踪 this.getServer 方法

   调用 loadBalancer.chooseServer 实现负载均衡，选择一个具体服务发起服务调用。
   

4. 进入 chooseServer 方法

   发现有三个实现类，进入第一个实现
   

5. 追踪 BaseLoadBalancer

   1. 这里调用 IRule 接口的 choose 方法选择服务实例；

   2. 进入 rule 的 choose 方法。
      

6. 查看 IRule

   这里 IRule 的实现类是 ZoneAvoidLoadBalancer。
   

7. 到此为止，就走完了整个 ribbon 的负载均衡流程，发起服务调用

8. Demo地址：https://github.com/yuluo-yx/ribbon-source.git

9. 调用流程总结如下

   1. LoadBalancerInterceptor 拦截请求；
   2. RibbonLoadBalancerClient 替换拦截到的请求 uri，并获取服务名字做为服务ID:
   3. chooseServer 选择服务；
   4. BaseLoadBalancer 的子类 DynamicServerListLoadBalancer 从注册中心拉取服务列表；
   5. IRule 根据负载均衡算法，选择服务实例；
   6. RibbonLoadBalancerClient 修改请求，发起真实服务调用。

负载均衡器接口

ILoadBalancer 接口中有以下方法：

public interface ILoadBalancer {//往该ILoadBalancer中添加服务void addServers(List<Server> var1);//选择一个可以调用的实例，keyb不是服务名称，而是zone的idServer chooseServer(Object var1);//标记下线服务void markServerDown(Server var1);/** @deprecated */@DeprecatedList<Server> getServerList(boolean var1);//获取可用服务列表List<Server> getReachableServers();//获取所有服务列表List<Server> getAllServers();
}

类关系说明：

1. AbstractLoadBalancer：定义了一个关于服务实例的分组枚举类 ServerGroup，定义了一个 chooseServer 方法去调用 ILoadBalancer 接口中的 chooseServer方法，抽象的 getServerList 方法来获取获取的服务，定义抽象方法 getLoadBalancerStats 获取 LoadBalancer 相关的统计信息
2. BaseLoadBalancer 类是 Ribbon 负载均衡器的基础实现类，在该类中定义了很多关于负载均衡器相关的基础内容。
3. DynamicServerListLoadBalancer 类继承了 BaseLoadBalancer，它是对基础负载均衡器的扩展。在该负载均衡器中，实现了服务实例清单在运行期的动态更新能力，同时，它还具备了对服务实例清单的过滤功能，也就是说，我们可以通过过滤器来选择性的获取一批服务实例清单。

负载均衡规则接口

IRule：负载均衡规则的顶层接口。

各个内置的负载均衡规则类如下：（其中 ZoneAvoidanceRule 是默认实现，根据可用去对服务进行分类）