【微服务】Ribbon和Feign负载均衡

前面讲的，我们用Eureka作为服务注册中心，在服务启动后，各个微服务会将自己注册到Eureka Server，服务间通过REST调用，那么服务之间如何做负载均衡的，在实际开发中我们该如何选择呢？

正题之前我们先来回忆一下，Dubbo中我们消费者是如何找到提供者的呢？
不错，我们用的是Dubbo的负载均衡。

那么在Spring Cloud中我们有Ribbon和Feign做负载均衡，这样看就不陌生了吧。

好的，言归正传，我们知道在Spring Cloud中服务间通过restful方式调用有两种方式：

RestTemplate+Ribbon
Feign

我们首先来看下两者的用法：

Ribbon：

1、controller层：使用RestTemplate

@RestController
public class DeptController_Consumer { 
    private static final String REST_URL_PREFIX = "http://MICROSERVICECLOUD-DEPT";
    @Autowired
    private RestTemplate restTemplate;
    @RequestMapping(value = "/consumer/dept/add")
    public boolean add(Dept dept) {
        return restTemplate.postForObject(REST_URL_PREFIX + "/dept/add", dept, Boolean.class);
    }
}

2、可自定义负载均衡算法，如下：

@Configuration
public class ConfigBean //boot -->spring   applicationContext.xml --- @Configuration配置   ConfigBean = applicationContext.xml
{ 
    @Bean
    @LoadBalanced//开启客户端负载均衡 Spring Cloud Ribbon是基于Netflix Ribbon实现的一套客户端 负载均衡的工具。
    public RestTemplate getRestTemplate()
    {
        return new RestTemplate();
    }
    //修改Ribbon的负载均衡算法(默认轮询)
    @Bean
    public IRule myRule()
    {
        //return new RoundRobinRule();
        //return new RandomRule();//达到的目的，用我们重新选择的随机算法替代默认的轮询。
        return new RetryRule();
    }
}

2.1如果要根据自己的需求定义，可抽出一个MyRule类：

public class MySelfRule {
    @Bean
    public IRule myRule(){
// return new RetryRule();//重试（轮询） 如果其中一台宕机，它会试着轮询它，轮询几次后就放弃这台宕机的机器了
        return new RandomRule_ZY();
    }
}

定义RandomRule_ZY()：必须继承AbstractLoadBalancerRule：
核心代码：

private int total = 0;          // 总共被调用的次数，目前要求每台被调用5次
private int currentIndex = 0;   // 当前提供服务的机器号
//要求：轮询每台服务器，每台服务器调用5次
if(total < 5)
{
    server = upList.get(currentIndex);
    total++;
}else {
    total = 0;
    currentIndex++;
    if(currentIndex >= upList.size())
    {
        currentIndex = 0;
    }
}

最后还需在启动类上加@RibbonClient注解：
加configuration：

@RibbonClient(name = "MICROSERVICECLOUD-DEPT",configuration = MySelfRule.class)
public class DeptConsumer80_App {
    public static void main(String[] args) {
        SpringApplication.run(DeptConsumer80_App.class,args);
    }
}

Feign：

面向接口编程，用法简单

@FeignClient(value = "MICROSERVICECLOUD-DEPT")
public interface DeptClientService {
    @RequestMapping(value = "/dept/add", method = RequestMethod.POST)
    public boolean add(Dept dept);
}