第四节：使用Hystrix熔断器

分手后的思念是犯贱 2023-02-20 07:09 13阅读 0赞

### 一、Hystrix熔断器 ###

在微服务架构中，根据业务来拆分成一个个的服务，服务与服务之间可以相互调用（RPC）。如果单个服务出现问题，调用这个服务就会出现线程阻塞，此时若有大量的请求涌入，Servlet容器的线程资源会被消耗完毕，导致服务瘫痪。服务与服务之间的依赖性，故障会传播，会对整个微服务系统造成灾难性的严重后果，这就是服务故障的“雪崩”效应。

也就是说，如果单个服务器节点出现问题，可能会导致依赖此微服务的节点系统均出现请求失败，这样循环下去可能会影响全局系统。断路打开后，可用避免连锁故障，熔断方法可以直接返回一个固定值。  
![HystrixFallback.png][]

### 二、在ribbon中使用断路器 ###

在第三小节的源码上，修改ribbon项目。

**        2.1  导入ribbon熔断器依赖**

<dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
            </dependency>

** 2.2  使用注解开启熔断功能**

在启动类上增加@EnableHystrix注解，以开启熔断功能。

@SpringBootApplication
    @EnableEurekaClient
    @EnableDiscoveryClient
    @EnableHystrix
    public class ApplicationRibbon {
     
        public static void main(String[] args) {
            SpringApplication.run( ApplicationRibbon.class, args );
        }
     
        @Bean
        @LoadBalanced
        RestTemplate restTemplate() {
            return new RestTemplate();
        }
    }

**2.3  编写熔断处理方法**

因为ribbon采用的是RestTemplate来调用其它微服务的接口，所以需要修改方法，在方法上增加@HystrixCommand注解。并指明如果请求不到指定的服务器数据，则执行fallbackMethod指定的方法。

package com.safesoft.ribbon.service;
     
    import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Service;
    import org.springframework.web.client.RestTemplate;
     
    /**
     * @author jay.zhou
     * @date 2019/1/24
     * @time 16:08
     */
    @Service
    public class HelloService {
     
        /**
         * 将IOC容器中的负载均衡RestTemplate工具注入进来
         */
        @Autowired
        RestTemplate restTemplate;
     
        @HystrixCommand(fallbackMethod = "obtainFailure")
        public String obtainOtherServiceData(String name) {
            //尝试调用其它微服务接口，访问的是SERVICE-CLIENT这个服务器的/hi 接口
            return restTemplate.getForObject("http://SERVICE-CLIENT/hi?name=" + name, String.class);
        }
     
        public String obtainFailure(String name) {
            return "sorry " + name + " , server internal error";
        }
    }

** 2.4  测试**

依次开启8761注册中心server，8763服务提供者client，当前项目8764 ribbon。访问[http://localhost:8764/hello?name=dayu][http_localhost_8764_hello_name_dayu]，请求被ribbon转发给8763服务提供者类。

![20190125132032879.png][]

仅关闭服务提供者client项目，再次访问[http://localhost:8764/hello?name=dayu][http_localhost_8764_hello_name_dayu]

![20190125132147302.png][]

### 三、在feign中使用断路器 ###

在第三小节的源码上，修改feign项目。

**        2.1  配置文件**

feign集成了ribbon，所以自己就能够熔断，不需要导入其它依赖。需要在配置文件中加上开启熔断功能的配置。

#指明注册中心的位置
    eureka:
      client:
        serviceUrl:
          defaultZone: http://localhost:8761/eureka/
    #当前项目部署的端口
    server:
      port: 8765
    #当前项目的名称
    spring:
      application:
        name: service-feign
    #开启熔断功能
    feign:
          hystrix:
            enabled: true

**2.2  配置熔断处理类**

在接口上的@FeignClient注解里，增加fallback = ErrorHandler.class配置。

package com.safesoft.feign.service;
     
    import org.springframework.cloud.openfeign.FeignClient;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RequestParam;
     
     
    @FeignClient(value = "SERVICE-CLIENT",fallback = ErrorHandler.class)
    public interface HelloService {
     
        /**
         * 从SERVICE-CLIENT服务器的/hi接口获取JSON数据
         *
         * @param name
         * @return
         */
        @RequestMapping("/hi")
        String obtainOtherServerJsonData(@RequestParam(value = "name") String name);
    }

2.3  编写熔断处理类

在接口上的@FeignClient注解里，增加fallback = ErrorHandler.class配置。

ErrorHandler是我们的熔断处理类。 需要实现@FeignClient注解的接口，并且使用@Component加入IOC容器。

package com.safesoft.feign.service;
     
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.stereotype.Component;
     
    @Component
    public class ErrorHandler implements HelloService {
        @Value("${server.port}")
        private String port;
     
        @Override
        public String obtainOtherServerJsonData(String name) {
            return "sorry " + name + " , " + port + " server internal error";
        }
    }

**   2.3  测试**

开启8761注册中心Server，开启8763服务提供者client，再开启当前8765端口的feign项目。

在浏览器输入[http://localhost:8765/sayHello?name=dayu][http_localhost_8765_sayHello_name_dayu]

![20190125133728476.png][]

仅关闭8763服务提供者client项目，再次在浏览器输入[http://localhost:8765/sayHello?name=dayu][http_localhost_8765_sayHello_name_dayu]。

![2019012513415569.png][]

### 四、源码下载 ###

[https://github.com/hairdryre/Study\_SpringCloud][https_github.com_hairdryre_Study_SpringCloud]

参考文章：[史上最简单的SpringCloud教程 | 第四篇:断路器（Hystrix）(Finchley版本)][SpringCloud_ _ _Hystrix_Finchley]

参考文章：[https://blog.csdn.net/yanluandai1985/article/details/86642081][https_blog.csdn.net_yanluandai1985_article_details_86642081]

[HystrixFallback.png]: https://img-blog.csdnimg.cn/20181222163659446
[http_localhost_8764_hello_name_dayu]: http://localhost:8764/hello?name=dayu
[20190125132032879.png]: https://img-blog.csdnimg.cn/20190125132032879.png
[20190125132147302.png]: https://img-blog.csdnimg.cn/20190125132147302.png
[http_localhost_8765_sayHello_name_dayu]: http://localhost:8765/sayHello?name=dayu
[20190125133728476.png]: https://img-blog.csdnimg.cn/20190125133728476.png
[2019012513415569.png]: https://img-blog.csdnimg.cn/2019012513415569.png
[https_github.com_hairdryre_Study_SpringCloud]: https://github.com/hairdryre/Study_SpringCloud
[SpringCloud_ _ _Hystrix_Finchley]: https://blog.csdn.net/forezp/article/details/81040990
[https_blog.csdn.net_yanluandai1985_article_details_86642081]: https://blog.csdn.net/yanluandai1985/article/details/86642081