Spring Cloud客户端负载均衡 - Ribbon

Posted 2023-03-27

参考技术A

注册restTemplate

使用restTemplate发送GET请求

通过@LoadBalanced注解可知该注解用来给restTemplate做标记，使用客户端负载均衡进行配置，搜索LoadBalancerClient类

ServiceInstanceChooser用来根据serviceId进行选择服务

通过以上得知，客户端负载均衡器应具备的几种能力

LoadBalancerAutoConfiguration为实现客户端负载均衡器的自动化配置类

该配置类需要满足两个条件

在示例中没有retryTemplate，则会创建一个LoadBalancerInterceptor对象

在LoadBalancerInterceptor的构造方法中注入了LoadBalancerClient的实现

当一个被@LoadBalance标注的RestTemplate向外发送Http请求时，会被interceptor拦截，调用execute发起实际请求

LoadBalancerClient的具体实现为org.springframework.cloud.netflix.ribbon.RibbonLoadBalancerClient

execute方法

首先根据传入的serviceId获取具体的服务实例

根据getServer接口，可知并没有使用choose函数，而是使用了ribbon本身的chooseServer函数

在ribbonClientConfiguration中可知默认采用了ZoneAwareLoadBalancer实现负载均衡器

回到RibbonBalancerClient的execute函数

通过ZoneAwareLoadBalancer的chooseServer获取负载均衡策略分配到的服务实例后，将其包装成RibbonServer对象，RibbonServer对象除了包含服务实例对象外，还包含serviceId等信息，然后使用该对象回调LoadBalancerInteceptor请求拦截器中LoadBalancerRequest的apply函数，向一个实际的具体服务发起请求

ServiceInstance对象是对服务的抽象定义，包含了每个服务实例需要提供一些基础信息

而RibbonServer就是ServiceInstance的实现，除了Server实例，还包含了serviceId,是否使用https，和一个map的元数据

在LoadBalanceRequest的工厂方法中

传入了一个ServiceRequestWrapper对象

在LoadBalanceRequest的工厂方法中的execute具体执行时，会调用InteceptingClientHttpRequest下的execute函数

而这里面的request.getUri则会调用ServiceRequestWrapper中LoadBalancerClient的getUri函数，至此构建了一个服务治理环境的访问URI,完成代理访问

AbstractLoadBalancer

是ILoadBalancer的抽象实现，定义了服务的分组枚举类，实现了chooseServer，参数key为null，表示在选择具体服务实例时忽略key的条件判断

LoadBalancerStats用来记录负载均衡器中哥哥服务实例的属性和统计信息

getServerList根据分组类型来获取不同的服务实例列表

BaseLoadBalancer

是ribbon负载均衡器的基础实现类，在该类中定义了很多关于负载均衡器相关的基础内容

定义了所有服务清单和正常清单

定义了检查服务实例操作的执行策略对象，默认为SerialPingStrategy

SerialPingStrategy默认采用遍历方式，性能欠佳，如有需要，可以实现IPingStrategy并重写pingServers方法

定义了负载均衡的处理IRule对象，负载均衡策略委托给IRule，而默认的实现为RoundRobinRule

启动ping任务

是BaseLoadBalancer的拓展，该负载均衡器提供了运行期间动态更新服务实例清单的能力，在成员定义中可发现

T在类名中限定为Server的子类

ServerList提供了两个抽象方法

在spring cloud整合ribbon和eureka的包下搜索EurekaRibbonClientConfiguration

DiscoveryEnabledNIWSServerList内部获取serverlist通过内部私有函数obtainServersViaDiscovery

对服务进行遍历，如果状态为UP，转换成DiscoveryEnabledServer对象，组织成list返回。

DiscoveryEnabledNIWSServerList从eureka中拿到server列表后，继续通过DomainExtractingServerList的setZone进行处理，加入了一些必要属性

更新服务待续，没看明白

ZoneAwareLoadBalancer继承自DynamicServerListLoadBalancer并重写了setServerListForZones

个性化配置

Spring Cloud负载均衡：使用Feign作客户端负载均衡

有了一篇服务端负载均衡后，再来一篇客户端负载均衡，客户端负载均衡很简单，无需在zuul中做多余配置（本示例不引入zuul），只需要在客户端进行Feign引入和配置即可。

准备工作很简单，实现客户端负载均衡，首先需要Feign组件。

<dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
        </dependency>

在client启动类中添加EnableFeignClients属性，代码如下：

@SpringBootApplication
@EnableDiscoveryClient
@EnableFeignClients
public class ClientApplication 

    public static void main(String[] args) 
        SpringApplication.run(ClientApplication.class, args);
    

然后编写一个调用，示例代码如下：

@FeignClient(value = "$service.request.name", fallback = helloHystrix.class)
public interface hello extends BaseService
    @RequestMapping(method = RequestMethod.GET, value = path + "/index/hello")
    String hello();

然后，在eureka中注册相关服务提供者和调用者，如下图所示：

在本地输入调用地址：http://localhost:8004/index/hello，结果如下：

最终在Feign的加持下，实现客户端负载均衡（原理略）
over.