服务容错保护
在微服务的架构中，存在着那么多单元服务，若一个单元出现故障，就很容易因依赖关系二引发故障的蔓延，最终导致整个系统的瘫痪。这样的架构相比较传统的架构更加不稳定。为了解决这个问题，产生了断路器等一系列的服务保护机制。
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服务时，因为此时服务已经挂了，所以我们会看到下面的响应：
过了几秒后，继续访问我们会发现请求总是负载到了8803的端口了，不会再去请求8802
接下来我们重新把8802的服务启动后，继续访问http://localhost:8901/listUsersByRibbon这时我们会发现请求接口又被一轮询的方式负载到8802和8803了
这样我们就实现了基础的分布式微服务的容错保护了。
github 项目源码
接下来我们会再研究一下，Hystrix框架针对单个应用实例和集群提供的监控功能。
