一块儿来学Spring Cloud | 第五章：熔断器 ( Hystrix)

在微服务项目中，一个系统能够分割成不少个不一样的服务模块，不一样模块之间咱们一般须要进行相互调用。springcloud中可使用RestTemplate+Ribbon和Feign来调用（工做中基本都是使用feign）。有时为了提升系统的健壮性，某些访问量大的服务模块还会作集群部署。可是服务之间的调用不可能百分之百成功的，若是出现超时、异常会致使服务没法提供功能。这时若是有大量请求访问异常服务，就会形成系统资源耗尽，致使服务瘫痪。服务与服务之间的依赖性，故障会传播，会对整个微服务系统形成灾难性的严重后果，这就是服务故障的“雪崩”效应。在实际工做中，复杂的系统每每有成百上千个服务模块，某个功能模块出现异常，不能影响其它功能的正常运行，因此熔断器Hystrix就派上用场了。

1、Hystrix简介：

Hystrix由Netfilix API团队研发于2011年，2012年开始在Hystrix公司内部推广和使用，Hystrix在Netflix中久经沙场，如今已是一个很是成熟的系统，而最近流行的微服务架构和Spring Cloud，让Hystrix成为了配套的基础设施，在国内也逐渐流行起来。

hystrix的出现即为解决服务雪崩效应，它经过四个方面的机制来解决这个问题

1. 隔离（线程池隔离和信号量隔离）：限制调用分布式服务的资源使用，某一个调用的服务出现问题不会影响其余服务调用。

2. 降级：超时降级、资源不足时(线程或信号量)降级，降级后能够配合降级接口返回托底数据。

3. 熔断：当失败率达到阀值自动触发降级(如因网络故障/超时形成的失败率高)，熔断器触发的快速失败会进行快速恢复。

4. 缓存：提供了请求缓存、请求合并实现。

若是想要了解更多的Hystrix的底层及实现原理，能够参考相关文章学习，本系列主要讲解如何快速在工做中使用Hystrix。

2、环境准备：

最终目录结构：

 

本系列文章，都是层层递进的，本章内容在前面搭建好的项目框架上进行开发讲解，对搭建springcloud的多模块子项目框架不清楚的同窗能够参考 ：一块儿来学Spring Cloud | 第一章 ：如何搭建一个多模块的springcloud项目 

工做中，咱们基本上都是使用feign进行服务调用的，因此本章只讲解Feign中使用断路器，对上一章feign工程搭建有兴趣的能够参考：一块儿来学Spring Cloud | 第四章：服务消费者 ( Feign )

3、Feign中使用断路器：

1. 在上章的springcloud-feign-client工程的application.properties配置文件中，加入配置：feign.hystrix.enabled=true

server.port=9600
spring.application.name=springcloud-feign-client
eureka.client.serviceUrl.defaultZone=http://localhost:8761/eureka/
feign.hystrix.enabled=true

2. 在上章的springcloud-feign-client工程中，新增一个FeignRemoteService类的实现类，命名为：HystrixFeignRemoteCallBack，作为出现接口异常时的回调方法

package com.haly.romote.hystrix;

import org.springframework.stereotype.Component;

import com.haly.romote.FeignRemoteService;

@Component
public class HystrixFeignRemoteCallBack implements FeignRemoteService{

	@Override
	public String hello(String name) {
		// TODO Auto-generated method stub
		return name + ",Due error,enter Hystrix";
	}

}

3. 在上章的springcloud-feign-client工程中，新增一个FeignRemoteService类中加入回调实现类的注解配置

package com.haly.romote;

import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RequestParam;

import com.haly.romote.hystrix.HystrixFeignRemoteCallBack;

@FeignClient(value = "springcloud-eureka-client",fallback = HystrixFeignRemoteCallBack.class)
public interface FeignRemoteService {

    @RequestMapping(value = "/hello",method = RequestMethod.GET)
    public String hello(@RequestParam(value = "name") String name);
    
}

4. 运行项目

① 先启动springcloud-eureka-server模块，开启eureka注册中心

② 启动springcloud-eureka-client模块，开启提供远程服务功能，而且提供接口能力 /hello

③ 启动springcloud-feign-client模块，开启消费模块，用来调用springcloud-eureka-client模块中的/hello接口

Eureka上的注册信息，以下图：

打开浏览器，输入网址：http://localhost:9600/getHello?name=young码农，运行结果以下：

咱们模仿生产环境，服务提供者宕机（或者返回超时），这里咱们手动停掉springcloud-eureka-client服务

输入网址：http://localhost:9600/getHello?name=young码农

本章咱们只是在回调接口中，返回一个字符串，工做中，有些场景会作一些业务逻辑处理（好比调用短信发送接口，出现异常会在记录一条异常日志，后面来处理这些异常）。

工做中咱们会遇到不少特殊场景，特别在访问量过大，业务较复杂的时候，会出现一些奇奇怪怪的问题，因此Feign,Hystrix有许多配置项可使用，咱们能够根据相应业务配进行合理配置