SpringCloud之Ribbon和Feign断路器支持（Hystrix）|第四章-yellowcong

￡神魔★判官ぃ 2022-05-29 03:52 189阅读 0赞

> 断路器，听起来高大上的，其实简单点来说，就是我springcloud提供服务的服务器挂掉了，然后通过断路器进行处理，返回错误界面。由于服务的消费有两种方式，一种是通过Ribbon+Rest的方式，另一种，是通过Feign的方式，所以断路器的使用，也是分两种。下面我分别讲解这两种的操作

## 代码地址 ##

https://gitee.com/yellowcong/springcloud/tree/master/chapter4

### 目录结构 ###

![这里写图片描述][SouthEast]

### 项目架构 ###

<table> 
 <thead> 
  <tr> 
   <th>节点</th> 
   <th>服务</th> 
   <th>项目名</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>yellowcong.com:8761</td> 
   <td>eureka注册服务</td> 
   <td>eureka-server</td> 
  </tr> 
  <tr> 
   <td>yellowcong.com:8762</td> 
   <td>提供服务1</td> 
   <td>eureka-client</td> 
  </tr> 
  <tr> 
   <td>yellowcong.com:8763</td> 
   <td>提供服务2</td> 
   <td>eureka-client2</td> 
  </tr> 
  <tr> 
   <td>yellowcong.com:8764</td> 
   <td>ribbon服务</td> 
   <td>ribbon-server</td> 
  </tr> 
  <tr> 
   <td>yellowcong.com:8765</td> 
   <td>feign服务</td> 
   <td>feign-server</td> 
  </tr> 
 </tbody> 
</table>

## Ribbon添加断路器支持 ##

> Ribbon断路器配置的步骤：1、配置pom.xml，添加对断路器的依赖，2、配置启动类，开启断路器，3、配置service来添加熔断操作。

### 1、配置pom.xml ###

想要ribbon支持断路器，就需要添加`spring-cloud-starter-hystrix`的依赖

<dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-hystrix</artifactId>
        <version>1.3.0.RELEASE</version>
    </dependency>

下面是pom.xml完整配置

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
    
        <groupId>yellowcong.com</groupId>
        <artifactId>cas-client-springboot</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <packaging>jar</packaging>
    
        <name>cas-client-springboot</name>
        <url>http://maven.apache.org</url>
    
        <repositories>
            <repository>
                <id>spring-milestones</id>
                <name>Spring Milestones</name>
                <url>https://repo.spring.io/milestone</url>
                <snapshots>
                    <enabled>false</enabled>
                </snapshots>
            </repository>
        </repositories>
    
        
        <parent>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>1.5.10.RELEASE</version>
        </parent>
    
        <properties>
            <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
            <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
            <java.version>1.8</java.version>
        </properties>
    
        <dependencies>
    
            
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-eureka-server</artifactId>
                <version>1.3.0.RELEASE</version>
            </dependency>
    
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-ribbon</artifactId>
                <version>1.3.0.RELEASE</version>
            </dependency>
    
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-hystrix</artifactId>
                <version>1.3.0.RELEASE</version>
            </dependency>
    
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
    
        </dependencies>
        <build>
            <plugins>
                
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                    <dependencies>
                        <dependency>
                            <groupId>org.springframework</groupId>
                            <artifactId>springloaded</artifactId>
                            <version>1.2.4.RELEASE</version>
                        </dependency>
                    </dependencies>
                </plugin>
            </plugins>
        </build>
    </project>

### 2、配置启动器 ###

在原来启动器的基础上，添加`@EnableHystrix`注解，打开对断路的支持。

package com.yellowcong;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
    import org.springframework.cloud.client.loadbalancer.LoadBalanced;
    import org.springframework.cloud.netflix.hystrix.EnableHystrix;
    import org.springframework.context.annotation.Bean;
    import org.springframework.web.client.RestTemplate;
    
    @SpringBootApplication
    @EnableDiscoveryClient
    @EnableHystrix
    public class ConfigMain { 
    
        public static void main(String[] args) {
            SpringApplication.run(ConfigMain.class, args);
        }
    
        /** * 创建日期:2018年3月16日<br/> * 创建用户:yellowcong<br/> * 功能描述:设定负载均衡策略 * @return */
        @Bean
        @LoadBalanced
        public RestTemplate restTemplate() {
            return new RestTemplate();
        }
    }

### 3、配置serivice，添加熔断操作 ###

通过添加`@HystrixCommand`注解，指定熔断后，调用哪一个方法。

package com.yellowcong.service;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Service;
    import org.springframework.web.client.RestTemplate;
    
    import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
    
    /** * 创建日期:2018年3月16日 <br/> * 创建用户:yellowcong <br/> * 功能描述: */
    @Service
    public class HelloService { 
        @Autowired
        RestTemplate restTemplate;
    
        /** * 创建日期:2018年3月16日<br/> * 创建用户:yellowcong<br/> * 功能描述:通过rest的方式来调用模板 * @HystrixCommand 表示当熔断的情况，访问 error这个界面 * @param name * @return */
        @HystrixCommand(fallbackMethod = "error")
        public String sayHi(String name) {
            //可以看到执行的路径直接是SERVICE-HI ，在ribbon中，在ribbon中它会根据服务名来选择具体的服务实例，根据服务实例在请求的时候会用具体的url替换掉服务名
            return restTemplate.getForObject("http://SERVICE-HI/hi/" + name, String.class);
        }
    
        //这个error是上面fallbackMethod 熔断后，回调方法
        public String error(String name){
            return name+" has error ,404";
        }
    }

### 4、测试熔断 ###

访问[http://yellowcong.com:8764/hi/xxx][http_yellowcong.com_8764_hi_xxx] 来测试ribbon熔断服务  
这个地方，我直接测试了ribbo和 feign两个，手有点残，点到百度了，我先把所有的服务，都开起来，然后，关闭掉了两个提供服务的，然后就熔断，都跑到自己对应的熔断函数里面了。

![这里写图片描述][SouthEast 1]

## Feign添加加断路器支持 ##

> Feign默认就是已经导入了断路器的依赖，只是没有默认开启断路器，所以需要实现的步骤是：1、配置application.yml，开启断路器。2、创建熔断需要访问的类(需要实现service接口)，3、配置断路器到service接口上

### 1、配置application.yml ###

Feign是默认支持断路器的，所以我们需要配置application.yml,开启断路器操作

#开启熔断器
    feign:
      hystrix:
        enabled: true

下面是完整配置

#配置eureka 的注册中心
    eureka:
      client:
        serviceUrl:
          defaultZone: http://yellowcong.com:8761/eureka/
    
    # 注册服务的端口
    server:
      port: 8765
    
    #开启熔断器
    feign:
      hystrix:
        enabled: true
    
    #配置当前服务的名称
    spring:
      application:
        name: service-feign

### 2、创建熔断后的处理类 ###

断路处理类，需要实现访问服务类的接口，然后里面配置对应的断路处理操作。就这样，将每一个服务同熔断操作一 一对应起来。

package com.yellowcong.service.impl.fallback;
    
    import org.springframework.stereotype.Component;
    
    import com.yellowcong.service.HelloService;
    
    /** * 创建日期:2018年3月16日 <br/> * 创建用户:yellowcong <br/> * 功能描述: */
    @Component
    public class HelloServiceFallback implements HelloService{ 
    
        @Override
        public String sayHi(String name) {
            return name+" has error (feign),404";
        }
    
    }

### 3、配置熔断操作 ###

通过`@FeignClient`注解中的fallback ，来配置那一个类来处理熔断操作，而熔断类有实现了这个服务类的所有操作，对应的类如果出现了熔断，就会调用fallback 指定的类的处理方法。

package com.yellowcong.service;
    
    import org.springframework.cloud.netflix.feign.FeignClient;
    import org.springframework.web.bind.annotation.PathVariable;
    import org.springframework.web.bind.annotation.RequestMapping;
    
    import com.yellowcong.service.impl.fallback.HelloServiceFallback;
    
    /** * 创建日期:2018年3月16日 <br/> * 创建用户:yellowcong <br/> * 功能描述: */
    //通过@FeignClient 指定访问那一个服务名
    @FeignClient(value = "service-hi",fallback = HelloServiceFallback.class)
    public interface HelloService { 
    
        /** * 创建日期:2018年3月16日<br/> * 创建用户:yellowcong<br/> * 功能描述:通过feignClient的方式来指定调用 * service-hi 中的 hi这个请求服务 * @param name * @return */
        @RequestMapping(value = "/hi/{name}")
        public String sayHi(@PathVariable(value="name") String name);
    }

### 4、测试 ###

访问[http://yellowcong.com:8765/hi/xxx][http_yellowcong.com_8765_hi_xxx] 来测试feign熔断服务  
这个地方，我直接测试了ribbo和 feign两个，手优点残，点到百度了，我先把所有的服务，都开起来，然后，关闭掉了两个提供服务的，然后就熔断，都跑到自己对应的熔断函数里面了。

![这里写图片描述][SouthEast 1]

## 常见问题 ##

### 1、com.netflix.client.ClientException: Load balancer does not have available server for client: hello-service ###

默认情况下feign对于Hystrix是支持的，但是有可能没有打开，需要我们手动打开，在application.yml 配置

#开启熔断器
    feign:
      hystrix:
        enabled: true

## 参考文章 ##

1、[史上最简单的SpringCloud教程 | 第四篇:断路器（Hystrix）][SpringCloud_ _ _Hystrix]

2、[spring cloud学习(三) 断路器][spring cloud_]

[SouthEast]: /images/20220529/58af97d637a04c0ea26a81f6b07d6a4b.png
[http_yellowcong.com_8764_hi_xxx]: http://yellowcong.com:8764/hi/xxx
[SouthEast 1]: /images/20220529/9883fef3155b4b769ec40a8496259bed.png
[http_yellowcong.com_8765_hi_xxx]: http://yellowcong.com:8765/hi/xxx
[SpringCloud_ _ _Hystrix]: http://blog.csdn.net/forezp/article/details/69934399
[spring cloud_]: https://www.cnblogs.com/andyfengzp/p/6831145.html