Spring Cloud系列文，Feign整合Ribbon和Hysrix

    在本博客以前的Spring Cloud系列里，咱们讲述了Feign的基本用法，这里咱们将讲述下Feign整合Ribbon实现负载均衡以及整合Hystrix实现断路保护效果的方式。    

1 准备Eureka服务器以及多个服务提供者

    这里，咱们将重用以前博文里讲过的案例，提供的两个（即主从）Eureka服务项目以及三个服务提供者的项目。随后在此基础上，在服务调用者的项目中，经过Feign以负载均衡的方式调用三个服务提供者所提供的sayHello方法。    

2 在客户端引入Ribbon

在FeignDemo-ServiceCaller项目里开发Fegin整合Ribbon，具体的步骤以下。

 在pom.xml中，引入Ribbon依赖包，关键代码以下。

1       <dependency>
2          <groupId>org.springframework.cloud</groupId>
3          <artifactId>spring-cloud-ribbon</artifactId>
4       </dependency>

     在ControllerForFeignRibbon.java中，编写Feign以Ribbon负载均衡的方式调用服务的代码。

 //省略必要的package和import的代码
//这和Ribbon Provider中的applicationname一致
@FeignClient(value = "sayHelloAvoidCopy")
interface FeignClientRibbonTool{
      @RequestMapping(method = RequestMethod.GET, value = "/sayHello/{username}/avoidCopy")
       String sayHelloAsRibbon(@PathVariable("username") String username);
}

@RestController
public class ControllerForFeignRibbon {    
     private FeignClientRibbonTool tool;
     @RequestMapping(value = "/callHelloAsRibbon/{username}", method = RequestMethod.GET)
     public String callHelloAsRibbon(@PathVariable("username") String username) {
        return tool.sayHelloAsRibbon(username);
    }
 }

    在上述代码里，，咱们定义了一个名为FeignClientRibbonTool的接口；在第3行中，咱们经过@FeignClient注解指定了该Feign接口将会调用名为sayHello的服务。请注意，这里的sayHello命名须要和EurekaRibbonDemo-ServiceProviderOne等项目中application.yml中的相应配置一致。

    在第10行中，咱们经过@RestController注解定义了一个名为ControllerForFeignRibbon的控制器类，在其中的第14行的callHelloAsRibbon中，咱们是经过Feign接口中的sayHelloAsRibbon方法调用服务的。

     在application.yml中，编写Ribbon的相关配置信息，关键代码以下。

1   sayHello:
2     ribbon:
3       listOfServer: http://localhost:1111/,http://localhost:2222/,http://localhost:3333
4       ConnectionsTimeout: 1000
5   ribbon:
6       ConnectionsTimeout: 2000  

    在第1~4行，咱们经过配置指定了基于ribbon的多台服务器，它们将以负载均衡的方式承担请求url，并且还指定了链接超时的时间。从第1行咱们能看到，这个配置是针对sayHello这个服务实例的。而在第5行和第6行，咱们配置了全局性的ribbon属性，这里也配置了链接超时时间。

    完成开发后，启动定义在表6.2中的两台Eureka服务器、三台服务提供者和一台服务调用者程序后，在浏览器中屡次输入http://localhost:8080/callHelloAsRibbon/Peter以调用服务，这时咱们能看到有以下输出。从输出结果来看，咱们以Feign的形式调用的请求确实被均衡地转发到3台服务提供者的机器上。

    1   Hello Ribbon, there are Server1, my name is:Peter

    2   Hello Ribbon, there are Server2, my name is:Peter

    3   Hello Ribbon, there are Server3, my name is:Peter

    这里咱们来总结一下Feign整合Ribbon的要点。

    第一，多个服务器提供者的实例名应当一致，好比这里都是sayHello。

    第二，在Feign的接口中，是经过@FeignClient的注解调用服务提供者的方法的。

    第三，这里咱们是在application.yml配置文件中指定Ribbon的各类参数，也能够经过@Configuration注解在Java文件中配置Ribbon的参数。

3 在客户端引入Hystrix(Feigh整合Hystrix)

    在经过Feign调用服务时，一样不能保证服务必定可用，为了提高客户体验，这里能够经过引入Hystrix对访问请求进行“容错保护”。

     在FeignDemo-ServiceCaller的pom.xml中，增长Hystrix的依赖包，关键代码以下。

1       <dependency>
2          <groupId>org.springframework.cloud</groupId> 
3          <artifactId>spring-cloud-hystrix</artifactId>
4       </dependency>

 仍是在FeignDemo-ServiceCaller项目的application.yml配置文件中，经过以下配置项启动Hystrix模式，关键代码以下。

1   feign:
2       hystrix:
3           enabled: true   

 

    此外，还能够经过以下代码配置针对sayHelloServiceProvider服务的hystrix参数。其中，第3行指定了hystrix所做用的服务名，第7行指定了请求时间一旦超过1000毫秒（也就是1秒），就会启动熔断模式，调用定义在回退方法中的业务动做。

1   hystrix:
2       command:
3           sayHelloServiceProvider:
4               execution:
5                  isolations:
6                      threads:
7                         timeoutInMilliseconds: 1000   

     在启动类ServiceCallerApp.java中，增长启动hystrix断路器的注解，如第5行所示，这个类的关键代码以下。    

1   //省略必要的package和import方法
2   EnableFeignClients
3   @EnableDiscoveryClient
4   @SpringBootApplication
5   @EnableCircuitBreakers
6   public class ServiceCallerApp
7   {
8       //省略其余代码
9   }

 新建一个名为ControllerForFeignHystrix.java的控制器类，代码以下。

1   //省略必要的package和import代码
2   @FeignClient(value = "sayHelloServiceProvider",fallback=FeignClientHystrixToolFallback.class)
3   interface FeignClientHystrixTool{
4       @RequestMapping(method = RequestMethod.GET, value = "/hello/{name}")
5       String sayHelloInClient(@RequestParam("name") String name);
6   }

 

在第3行中，咱们定义了一个名为FeignClientHystrixTool的接口；在第2行的注解中，咱们定义了它将以Feign的形式调用sayHelloServiceProvider中的服务，而且经过fallback配置指定一旦出现调用异常，将调用FeignClientHystrixToolFallback类中的回退方法。

7   @Component
8   class FeignClientHystrixToolFallback implements FeignClientHystrixTool{
9       public String sayHelloInClient(String name)
10      { return "In Fallback Function.";    }  
11  }

    在第8行的FeignClientHystrixToolFallback类中，咱们将定义针对FeignClientHystrixTool接口的回退方法。

    注意该类必须和第2行中fallback指定的类同名，并且，该类须要实现（implements）FeignClientHystrixTool接口，在其中的sayHelloInClient方法中定义了回退动做，这里的动做是打印一段话。

12  @RestController
13  public class ControllerForFeignHystrix {       
14      @Autowired
15      private FeignClientHystrixTool tool;   
16      @RequestMapping(value = "/callHelloAsHystrix/{username}", method = RequestMethod.GET)
17      public String callHelloAsHystrix(@PathVariable("username") String username)
18      { return tool.sayHelloInClient(username);}  
19  }

    在第13行中，咱们定义了一个包含@RestController注解的控制器类ControllerForFeignHystrix，在其中第17行的callHelloAsHystrix方法中，咱们是以Feign的形式调用sayHelloInClient方法的。

    至此，完成代码的编写工做。咱们依次启动FeignDemo-Server、FeignDemo-ServiceProvider和FeignDemo-ServiceCaller项目，随后在浏览器中输入http://localhost:8080/callHelloAsHystrix/Peter，此时能看到“hello Peter”的输出，这个是正常的调用流程。

    若是咱们关闭FeignDemo-ServiceProvider项目，也就是说sayHelloServiceProvider服务不可用了，若是再次在浏览器中输入http://localhost:8080/callHelloAsHystrix/Peter，此时就会走熔断保护的流程，触发FeignClientHystrixToolFallback 类中的sayHelloInClient方法，在浏览器中输出“In Fallback Function“的字样。

 

本文谢绝转载，若是要代码，请和做者联系。Spring Cloud相关博文以下：

Spring Cloud微服务系列文，服务调用框架Feign   

Spring Cloud微服务系列文，Hystrix与Eureka的整合   

架构师系列文：经过Spring Cloud组件Hystrix合并请求  

架构师入门：Spring Cloud系列，Hystrix与Eureka的整合  

Hystrix针对不可用服务的保护机制以及引入缓存  

经过案例了解Hystrix的各类基本使用方式  

Ribbon整合Eureka组件，以实现负载均衡  

Spring Clould负载均衡重要组件：Ribbon中重要类的用法  

架构师入门：搭建双注册中心的高可用Eureka架构（基于项目实战）  

架构师入门：搭建基本的Eureka架构（从项目里抽取）  

借助Maven入手Spring Boot第一个程序