【spring cloud hoxton】Ribbon 真的能被 spring-cloud-loadbalancer 替代吗

野性酷女 2022-09-10 10:24 147阅读 0赞

背景

*  早上刷圈看到 [Spring Cloud Hoxton.M2 Released][] 的消息，随手发布到了我的知识星球，过了会有个朋友过来如下问题。 抽取半天时间学习spring-cloud-loadbalancer 的源码，整理出此文总结 
    
    ![https://oscimg.oschina.net/oscnet/f0f33c4d387352580bd6963b2f2479cf7dd.jpg][https_oscimg.oschina.net_oscnet_f0f33c4d387352580bd6963b2f2479cf7dd.jpg]
 *  Spring Cloud Hoxton.M2 是第一个整合新的loadbalancer实现来替代Ribbon的版本

Spring Cloud Hoxton.M2 is the **first** release containing both blocking and non-blocking load balancer client implementations **as** an alternative to Netflix Ribbon which has entered maintenance mode.

*  spring-cloud-loadbalancer 的渊源

1.  2017年spring 开始尝试开发新的项目 spring-cloud-loadbalancer 替代ribbon，项目托管在 [spring-cloud-incubator 孵化器][spring-cloud-incubator] （多提一嘴，spring cloud alibaba 等顶级的项目大多从此孵化出来的，代表着 spring cloud 的发展方向）
2.  经过N个月的不维护，还以为spring 放弃此项目时，突然把此项目标记成归档迁移到[spring-cloud-commons][]
3.  发布2.2.0.M2 版本

如何使用

*  这里基于 最新的hoxton.m2 版本才可以使用，所以要配置spring的代理maven库

<**dependencymanagement**>

<**dependencies**>

<**dependency**>

<**groupid**>org.springframework.cloud</**groupid**>

<**artifactid**>spring-cloud-dependencies</**artifactid**>

<**version**>Hoxton.M2</**version**>

<**type**>pom</**type**>

<**scope**>import</**scope**>

</**dependency**>

</**dependencies**></**dependencymanagement**>

*  加入nacos-client ，使用 2.1.0版本，特别注意排除 ribbon依赖，不然loadbalancer 无效

<**dependency**>

<**groupid**>com.alibaba.cloud</**groupid**>

<**artifactid**>spring-cloud-starter-alibaba-nacos-discovery</**artifactid**>

<**exclusions**>

<**exclusion**>

<**groupid**>org.springframework.cloud</**groupid**>

<**artifactid**>spring-cloud-starter-netflix-ribbon</**artifactid**>

</**exclusion**>

</**exclusions**>

</**dependency**>

*  加入 loadbalancer pom坐标

<**dependency**>

<**groupid**>org.springframework.cloud</**groupid**>

<**artifactid**>spring-cloud-loadbalancer</**artifactid**>

</**dependency**>

*  配置使用还是和 ribbon 一样配置

@Configuration

**public****class****LbConfiguration** \{

@Bean

@LoadBalanced

RestTemplate restTemplate() \{

**return** **new** RestTemplate();

@GetMapping("/demo")

**public** String **doOtherStuff**() \{

**return** restTemplate.getForObject("http://big-provider-server/demo", String.class);

源码解析

LoadBalancerClient 实现

![https://oscimg.oschina.net/oscnet/34a8546b004f8ee262c8cd3fbf1f4b7d7f9.jpg][https_oscimg.oschina.net_oscnet_34a8546b004f8ee262c8cd3fbf1f4b7d7f9.jpg]

*  目前版本只提供了 BlockingLoadBalancerClient 的实现， 注意看中文注释

*//* *删除只保留了核心代码注意*

**public****class****BlockingLoadBalancerClient****implements****LoadBalancerClient** \{

@Override

**public** <t> T **execute**(String serviceId, LoadBalancerRequest<t> request)

**throws** IOException \{

*//* *根据**服务名称去查询可用实例*

ServiceInstance serviceInstance = choose(serviceId);

**return** execute(serviceId, serviceInstance, request);

@Override

**public** ServiceInstance **choose**(String serviceId) \{

*//* *获取负载均衡策略*

ReactiveLoadBalancer<serviceinstance> loadBalancer = loadBalancerClientFactory

.getInstance(serviceId);

*//* *执行负载均衡策略获取可以实例*

Response<serviceinstance> loadBalancerResponse = Mono.from(loadBalancer.choose())

.block();

**return** loadBalancerResponse.getServer();

loadBalancer 负载均衡策略实现

![https://oscimg.oschina.net/oscnet/8b21845f0b2ff217e9e094c26234186b6e9.jpg][https_oscimg.oschina.net_oscnet_8b21845f0b2ff217e9e094c26234186b6e9.jpg]

*  目前只有一个RoundRobinLoadBalancer 轮询选择server的方式

**public****class****RoundRobinLoadBalancer****implements****ReactorServiceInstanceLoadBalancer** \{

**public** Mono<response<serviceinstance>> choose(Request request) \{

ServiceInstanceSupplier supplier = **this**.serviceInstanceSupplier.getIfAvailable();

**return** supplier.get().collectList().map(instances -> \{

**if** (instances.isEmpty()) \{

log.warn("No servers available for service: " \+ **this**.serviceId);

**return** **new** EmptyResponse();

*// TODO: enforce order?*

**int** pos = Math.abs(**this**.position.incrementAndGet());

ServiceInstance instance = instances.get(pos % instances.size());

**return** **new** DefaultResponse(instance);

\});

和ribbon 比较

默认负载均衡比较

*  ribbon 提供7中默认的负载均衡策略，常见的常见都有覆盖，一般我们都是使用 ZoneAvoidanceRule 复合判断server所在区域的性能和server的可用性选择server 
    
    ![https://oscimg.oschina.net/oscnet/d4584d428088b7d875833a16f1d22cde761.jpg][https_oscimg.oschina.net_oscnet_d4584d428088b7d875833a16f1d22cde761.jpg]

配置方面丰富性

*  目前spring-cloud-loadbalancer 仅支持 重试操作的配置
 *  ribbon 支持超时、懒加载处理、重试及其和 hystrix整合高级属性等

结论

*  老老实实用 ribbon 
    
    ![https://oscimg.oschina.net/oscnet/991e11148794bbd892ae1467d9450b14aa1.jpg][https_oscimg.oschina.net_oscnet_991e11148794bbd892ae1467d9450b14aa1.jpg]
 *  以上源码 [https://github.com/pigxcloud/big][https_github.com_pigxcloud_big]
 *  欢迎关注 [基于Spring Boot 2.1.7、 Spring Cloud Greenwich.SR2、 OAuth2 的RBAC 权限管理系统][Spring Boot 2.1.7_ Spring Cloud Greenwich.SR2_ OAuth2 _RBAC]
 *  欢迎关注我们获得更多的好玩JavaEE 实践

[Spring Cloud Hoxton.M2 Released]: https://spring.io/blog/2019/08/19/spring-cloud-hoxton-m2-released
[https_oscimg.oschina.net_oscnet_f0f33c4d387352580bd6963b2f2479cf7dd.jpg]: /images/20220829/dfa252728b8c4ef3b5ac6f905faa6e7a.png
[spring-cloud-incubator]: https://github.com/spring-cloud-incubator/spring-cloud-loadbalancer
[spring-cloud-commons]: https://github.com/spring-cloud/spring-cloud-commons
[https_oscimg.oschina.net_oscnet_34a8546b004f8ee262c8cd3fbf1f4b7d7f9.jpg]: /images/20220829/349790753acf4302afbd53b0a0fb6348.png
[https_oscimg.oschina.net_oscnet_8b21845f0b2ff217e9e094c26234186b6e9.jpg]: /images/20220829/017dbbb3f4b648b4be114b6c7c89bad1.png
[https_oscimg.oschina.net_oscnet_d4584d428088b7d875833a16f1d22cde761.jpg]: /images/20220829/b39d7d919e2d41028a41a5a8899197d7.png
[https_oscimg.oschina.net_oscnet_991e11148794bbd892ae1467d9450b14aa1.jpg]: /images/20220829/7ed5f7e7081049d7a3e4286c39b6325d.png
[https_github.com_pigxcloud_big]: https://github.com/pigxcloud/big
[Spring Boot 2.1.7_ Spring Cloud Greenwich.SR2_ OAuth2 _RBAC]: https://gitee.com/log4j/pig