SpringCloud LoadBalancer自定义负载均衡器怎么使用

本文小编为大家详细介绍“SpringCloud LoadBalancer自定义负载均衡器怎么使用”，内容详细，步骤清晰，细节处理妥当，希望这篇“SpringCloud LoadBalancer自定义负载均衡器怎么使用”文章能帮助大家解决疑惑，下面跟着小编的思路慢慢深入，一起来学习新知识吧。

Spring Cloud LoadBalancer 帮开发者已经实现了RoundRobinLoadBalancer、RandomLoadBalancer，分别是轮训和随机，默认实现为轮训。

即让是负载均衡组件，那必然有默认实现，也必然有扩展接口暴露给开发者。所以第一步肯定是介绍抽象接口。

// 负载均衡的标志性接口，继承ReactorLoadBalancer接口
// 本接口无任何接口增强，仅仅作为一个标志性接口。
public interface ReactorServiceInstanceLoadBalancer extends ReactorLoadBalancer 
// 在Spring Cloud高版本中大部分组件采用了Reacotr框架（有一说一，阅读性极差！！）
// 这里定义了一个选择的抽象方法。
public interface ReactorLoadBalancer extends ReactiveLoadBalancer {
	Mono> choose(Request request);
	default Mono> choose() {
		return choose(REQUEST);
	}
}

这里有涉及到Reactor框架，不过完全可以当黑盒使用。接口非常的简单就一个choose方法，所以接下来我们只需要实现此接口。

@LoadBalancerClient(value = "deptmanagecloud-provider", configuration = MyConfig.class)
public class MyConfig {
    // 配置负载均衡策略
    @Bean
    public ReactorLoadBalancer myLB(Environment environment, LoadBalancerClientFactory loadBalancerClientFactory) {
        String name = environment.getProperty(LoadBalancerClientFactory.PROPERTY_NAME);
        return new MyLB(
                loadBalancerClientFactory.getLazyProvider(name, ServiceInstanceListSupplier.class));
    }
}

这里有部分逻辑，读者完全可以当作黑盒暂时不需要去理解。只需要明白从注册中心拿到注册表以后会执行getInstanceResponse方法，只需要实现自定义负载均衡策略的逻辑即可，好比我这里的逻辑是永远只调用一个服务（当然，这完全扯淡，仅仅是Demo无须太关心）

既然我们把自定义负载均衡策略写好了，那么，怎么告诉Spring呢？肯定需要注入给Spring。

@LoadBalancerClient(value = "deptmanagecloud-provider", configuration = MyConfig.class)
public class MyConfig {
    // 配置负载均衡策略
    @Bean
    public ReactorLoadBalancer myLB(Environment environment, LoadBalancerClientFactory loadBalancerClientFactory) {
        String name = environment.getProperty(LoadBalancerClientFactory.PROPERTY_NAME);
        return new MyLB(
                loadBalancerClientFactory.getLazyProvider(name, ServiceInstanceListSupplier.class));
    }
}

这里需要➕上@LoadBalancerClient注解，value为调用方的服务名，configuration为配置类