10.Ribbon 源码分析（springcloud）

package com.it.controller;
 
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.client.ServiceInstance;
import org.springframework.cloud.client.loadbalancer.LoadBalancerClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;
 
@RestController
public class ConsumerController {
 
    @Autowired
    private RestTemplate restTemplate;
 
    @Autowired
    private LoadBalancerClient loadBalancerClient;
 
    @GetMapping("testRibbon")
    public String testRibbon(String serviceName){
        //正常来讲，需要拿到ip和port 以及路径 才可以用
        String url="http://"+serviceName+"/hello";
        String forObject = restTemplate.getForObject(url, String.class);
        return forObject;
    }
 
    /**
     * 核心是负载均衡
     * @param serviceName
     * @return
     */
    @GetMapping("testRibbonRule")
    public String testRibbonRule(String serviceName){
        ServiceInstance choose = loadBalancerClient.choose(serviceName);
        return choose.toString();
    }
 
 
}

4.3 从 choose 方法入手，查看 Ribbon 负载均衡的源码

走进 getServer()方法

在 chooseServer()里面得到 rule 是哪个对象

         

发现当前的 rule 是 ZoneAvoidanceRule 对象，而他只有一个父类 PredicateBasedRule

最终进入 PredicateBasedRule 类的 choose()方法

com.netflix.loadbalancer.AbstractServerPredicate#incrementAndGetModulo