其他分享
首页 > 其他分享> > 【spring cloud hoxton】Ribbon 真的能被 spring-cloud-load

【spring cloud hoxton】Ribbon 真的能被 spring-cloud-load

作者:互联网

背景

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.
  1. 2017年spring 开始尝试开发新的项目 spring-cloud-loadbalancer 替代ribbon,项目托管在 spring-cloud-incubator 孵化器 (多提一嘴,spring cloud alibaba 等顶级的项目大多从此孵化出来的,代表着 spring cloud 的发展方向)

  2. 经过N个月的不维护,还以为spring 放弃此项目时,突然把此项目标记成归档迁移到spring-cloud-commons

  3. 发布2.2.0.M2 版本

如何使用

<dependencyManagement>    <dependencies>        <dependency>            <groupId>org.springframework.cloud</groupId>            <artifactId>spring-cloud-dependencies</artifactId>            <version>Hoxton.M2</version>            <type>pom</type>            <scope>import</scope>        </dependency></dependencyManagement>
<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>
<dependency>    <groupId>org.springframework.cloud</groupId>    <artifactId>spring-cloud-loadbalancer</artifactId></dependency>
  1. @Configuration

  2. public class LbConfiguration {

  3.    @Bean

  4.    @LoadBalanced

  5.    RestTemplate restTemplate() {

  6.        return new RestTemplate();

  7.    }

  8. }


  9. @GetMapping("/demo")

  10. public String doOtherStuff() {

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

  12. }

源码解析

LoadBalancerClient 实现

图片

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

  2. public class BlockingLoadBalancerClient implements LoadBalancerClient {


  3.    @Override

  4.    public <T> T execute(String serviceId, LoadBalancerRequest<T> request)

  5.            throws IOException {

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

  7.        ServiceInstance serviceInstance = choose(serviceId);

  8.        return execute(serviceId, serviceInstance, request);

  9.    }


  10.    @Override

  11.    public ServiceInstance choose(String serviceId) {

  12.        // 获取负载均衡策略

  13.        ReactiveLoadBalancer<ServiceInstance> loadBalancer = loadBalancerClientFactory

  14.                .getInstance(serviceId);

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

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

  17.                .block();

  18.        return loadBalancerResponse.getServer();

  19.    }


  20. }

loadBalancer 负载均衡策略实现

图片

  1. public class RoundRobinLoadBalancer implements ReactorServiceInstanceLoadBalancer {

  2.    public Mono<Response<ServiceInstance>> choose(Request request) {

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

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

  5.            if (instances.isEmpty()) {

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

  7.                return new EmptyResponse();

  8.            }

  9.            // TODO: enforce order?

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


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


  12.            return new DefaultResponse(instance);

  13.        });

  14.    }


  15. }

和ribbon 比较

默认负载均衡比较

配置方面丰富性

结论


标签:load,return,spring,cloud,serviceId,ribbon,loadbalancer
来源: https://blog.51cto.com/15016434/2646058