第四节：使用Hystrix熔断器

一、Hystrix熔断器

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

断路打开后，可用避免连锁故障，熔断方法可以直接返回一个固定值。

二、在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​​，请求被ribbon转发给8763服务提供者类。

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

三、在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配置。

需要实现@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​​

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

四、源码下载

         ​​https://github.com/hairdryre/Study_SpringCloud​​

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

----------------------------------------------------分割线-------------------------------------------------------