springcloud之ribbon自定义负载均衡规则

1、在springcloud中，使用的是ribbon来解决负载均很的问题，而常见的负载均衡策略包括有

    1）轮询

    2）随机

    3）一致性哈希

    4）哈希

    5）加权

2、在ribbon中提供了ILoadBalance接口用来代表负责均衡的操作，它提供了增加服务器，选择服务器，标记服务器状态为down，获得可用服务器以及获得所有服务器的操作

public interface ILoadBalancer {
    void addServers(List<Server> var1);

    Server chooseServer(Object var1);

    void markServerDown(Server var1);

    /** @deprecated */
    @Deprecated
    List<Server> getServerList(boolean var1);

    List<Server> getReachableServers();

    List<Server> getAllServers();
}

3、ribbon中具体实现负载均衡的策略是通过IRule这个接口来实现的，接口实现结构图

4、ribbon默认是使用的是zoneAvoidanceRule规则，这里我们修改规则使用随机算法

默认ribbon规则的配置

   @Bean
    @ConditionalOnMissingBean
    public IRule ribbonRule(IClientConfig config) {
        if (this.propertiesFactory.isSet(IRule.class, this.name)) {
            return (IRule)this.propertiesFactory.get(IRule.class, config, this.name);
        } else {
            ZoneAvoidanceRule rule = new ZoneAvoidanceRule();
            rule.initWithNiwsConfig(config);
            return rule;
        }
    }

// 来自 RibbonClientConfiguration

/**
 * 该类为Ribbon的配置类
 * 该类不能被@ComponentScan扫描到
 * @author nicker
 * @description
 * @date 2018/5/16 18:25
 * @
 */
@Configuration
public class RibbonConfiguration {

    @Bean
    public IRule ribbonRule() {
        // 负载均衡规则，改为随机
        return new RandomRule();
    }
}

5、自定义指定ribbon客户端的配置

/**
 * 使用RibbonClient，为特定name的Ribbon Client自定义配置
 * 使用@RibbonClient的configuration属性，指定Ribbon的配置类
 * @author nicker
 * @description
 * @date 2018/5/16 18:27
 */
@Configuration
@RibbonClient(name = "service-provider-user", configuration = RibbonConfiguration.class)
public class TestConfiguration {
}

6、controller层的api代码

/**
 * @author nicker
 * @description
 * @date 2018/5/16 14:31
 */
@RestController
public class MovieController {

    @Autowired
    private RestTemplate restTemplate;
    @Autowired
    private LoadBalancerClient loadBalancerClient;

    @Autowired
    private DiscoveryClient discoveryClient;

    @GetMapping("/user/{id}")
    public User findById(@PathVariable Long id){
        User user = restTemplate.getForObject("http://service-provider-user/" + id, User.class);
        return user;
    }

    @GetMapping("/user-instance")
    public List<ServiceInstance> showInfo() {
        return discoveryClient.getInstances("service-provider-user");
    }

    @GetMapping("/log-user-instance")
    public void logUserInstance() {
        ServiceInstance serviceInstance = loadBalancerClient.choose("service-provider-user");
        //打印当前选择的是哪个节点
        System.out.println(serviceInstance.getServiceId()+serviceInstance.getHost()+serviceInstance.getPort());
    }
}

7、在访问/log-user-instance这个接口的时候，使用自定义的策略对应的结果

8、通过application.yml中配置的方式，这里就不用使用前面的编程式配置了

格式如下<clientName>.ribbon.

NFLoadBalancerClassName: 配置ILoadBalancer的实现类
NFLoadBalancerRuleClassName: 配置IRule的实现类
NFLoadBalancerPingClassName: 配置IPing的实现类
NFWSServerListClassName: 配置ServerList的实现类
NIWSServerListFilterClassName: 配置ServerListFilter的实现类

service-provider-user:
  ribbon:
    NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule

9、ribbon自带的几个负载均衡规则说明