服务容错保护

在微服务的架构中，存在着那么多单元服务，若一个单元出现故障，就很容易因依赖关系二引发故障的蔓延，最终导致整个系统的瘫痪。这样的架构相比较传统的架构更加不稳定。为了解决这个问题，产生了断路器等一系列的服务保护机制。
spring Cloud Hystrix实现了断路器、线程隔离等一系列服务保护功能。它也是基于Netflix的开源框架Hystrix实现的。，该框架的目标在于通过控制那些访问远程系统、服务和第三方库的节点，从而对延时和故障提供更加强大的容错能力。

快速入门

我们以之前的内容作为基础，针对"service-user-ribbon"进行配置。
在"service-user-ribbon"的pom.xml配置文件添加Hystrix依赖

<!--添加Hystrix依赖 断路器容错保护--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-hystrix</artifactId></dependency>

完整的pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<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>com.example</groupId><artifactId>eureka-bussniss-service-user-client-ribbon</artifactId><version>0.0.1-SNAPSHOT</version><packaging>jar</packaging><name>eureka-bussniss-service-user-client-ribbon</name><description>Demo project for Spring Boot</description><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.0.3.RELEASE</version><relativePath/> <!-- lookup parent from repository --></parent><properties><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding><project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding><java.version>1.8</java.version><spring-cloud.version>Finchley.RELEASE</spring-cloud.version></properties><dependencies><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-server</artifactId></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-ribbon</artifactId></dependency><!--添加Hystrix依赖 断路器容错保护--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-hystrix</artifactId></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency></dependencies><dependencyManagement><dependencies><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-dependencies</artifactId><version>${spring-cloud.version}</version><type>pom</type><scope>import</scope></dependency></dependencies></dependencyManagement><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build>
</project>

然后在主类EurekaBussnissServiceUserClientRibbonApplication中使用@EnableHystrix 注解以开启 Hystrix 特性

@SpringBootApplication
@EnableEurekaClient
@EnableHystrix
public class EurekaBussnissServiceUserClientRibbonApplication {public static void main(String[] args) {SpringApplication.run(EurekaBussnissServiceUserClientRibbonApplication.class, args);}@Bean@LoadBalanced //开启客户端负载均衡RestTemplate restTemplate() {return new RestTemplate();}
}

接下来修改服务消费方式，在UserManagementRibbonClient类的接口方法：ListUsersByRibbon增加@HystrixCommand并且指定fallbackMethod名，再实现该方法。具体的代码如下：

/*** 使用 @HystrixCommand 注解的 fallbackMethod 指定失败方法，并实现该方法** @return*/@GetMapping("/listUsersByRibbon")@HystrixCommand(fallbackMethod = "listUsersByRibbonFallback")public String ListUsersByRibbon() {/*** hystrix 断路器的默认的超时时间为2000毫秒* 这里测试的在3000毫秒的随机出现的超时概率出发断路器 对应的代码逻辑见service-user项目的listUsers接口*/long start = System.currentTimeMillis();String result = this.restTemplate.getForObject("http://service-user/listUsers", String.class);long end = System.currentTimeMillis();log.info("Spend Time ："+(end-start));return result;}public String listUsersByRibbonFallback() {return "listUsersByRibbon异常，端口：" + port;}

配置完成重启项目，在8802和8803服务正常的情况下服务调用正常。
当我们把其中一个service-user服务停掉。例如：把8802停掉，只剩下8803服务，我们重新访问http://localhost:8901/listUsersByRibbon地址，当我们一开始访问到8802服务时，因为此时服务已经挂了，所以我们会看到下面的响应：

1532500404150.png

过了几秒后，继续访问我们会发现请求总是负载到了8803的端口了，不会再去请求8802

1532500486184.png

接下来我们重新把8802的服务启动后，继续访问http://localhost:8901/listUsersByRibbon这时我们会发现请求接口又被一轮询的方式负载到8802和8803了

1532500622445.png

1532500630124.png

这样我们就实现了基础的分布式微服务的容错保护了。
github 项目源码

接下来我们会再研究一下，Hystrix框架针对单个应用实例和集群提供的监控功能。