SpringCloud LoadBalancer自定义负载均衡器使用解析

目录

• 正文
• 总结

由于原有的负载均衡组件Ribbon停止维护，而完美的Spring生态怎能允许缺少负载均衡组件呢？Spring Cloud官方自己造出了Spring Cloud LoadBalancer来代替原有的Ribbon。由于是官方自己写的组件，所以并没有像eureka、Feign那样抽出一个单独的组件包出来。而放入到Spring Cloud Commons规范包中。android

正文

Spring Cloud LoadBalancer 帮开发者已经实现了RoundRobinLoadBalancer、RandomLoadBalancehttp://www.devze.comr，分别是轮训和随机，默认实现为轮训。

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

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

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

@LoadBalancerClient(value = "deptmanagecloud-provider", configuration = MyConfig.class)
public class MyConfig {
    // 配置负载均衡策略
    @Bean
    public ReactorLoadBalancer<ServiceInstance> 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<ServiceInstance> myLB(Environment environment, LoadBalancerClientFactory loadBalancerClientFactory) {
        String name = environment.getProperty(LoadBalancerClientFactory.PROPERTY_NAME);
        return new MyLB(
                loadBalancerClientFactohttp://ww开发者_Go教程w.devze.comry.getLazyProjavascriptvider(name, ServiceInstanceListSupplier.class));
    }
}

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

总结

相比以前的Ribbon的IRule方式这个要复杂一些，不过大部分都是造轮子，开发者只需要关心自定义的负载均衡逻辑即可～！

到此这篇关于SpringCloud LoadBalancer自定义负载均衡器使用解析的文章就介绍到这了,更多相关SpringCloud LoadBalancer内容请搜索我们以前的文章或继续浏览下面的相关文章希望大家以后多多支持我们！