沈阳网站建设蓝顶网络,国企网站建设报告,网站建设有哪些岗位,网络宣传渠道有哪些在微服务架构中#xff0c;一个应用往往由多个服务组成#xff0c;这些服务之间相互依赖#xff0c;依赖关系错综复杂。例如一个微服务系统中存在 A、B、C、D、E、F 等多个服务#xff0c;它们的依赖关系如下图。图1#xff1a;服务依赖关系通常情况下#xff0c;一个用户…在微服务架构中一个应用往往由多个服务组成这些服务之间相互依赖依赖关系错综复杂。例如一个微服务系统中存在 A、B、C、D、E、F 等多个服务它们的依赖关系如下图。图1服务依赖关系通常情况下一个用户请求往往需要多个服务配合才能完成。如图 1 所示在所有服务都处于可用状态时请求 1 需要调用 A、D、E、F 四个服务才能完成请求 2 需要调用 B、E、D 三个服务才能完成请求 3 需要调用服务 C、F、E、D 四个服务才能完成。当服务 E 发生故障或网络延迟时会出现以下情况即使其他所有服务都可用由于服务 E 的不可用那么用户请求 1、2、3 都会处于阻塞状态等待服务 E 的响应。在高并发的场景下会导致整个服务器的线程资源在短时间内迅速消耗殆尽。所有依赖于服务 E 的其他服务例如服务 B、D 以及 F 也都会处于线程阻塞状态等待服务 E 的响应导致这些服务的不可用。所有依赖服务B、D 和 F 的服务例如服务 A 和服务 C 也会处于线程阻塞状态以等待服务 D 和服务 F 的响应导致服务 A 和服务 C 也不可用。从以上过程可以看出当微服务系统的一个服务出现故障时故障会沿着服务的调用链路在系统中疯狂蔓延最终导致整个微服务系统的瘫痪这就是“雪崩效应”。为了防止此类事件的发生微服务架构引入了“熔断器”的一系列服务容错和保护机制。熔断器熔断器Circuit Breaker一词来源物理学中的电路知识它的作用是当线路出现故障时迅速切断电源以保护电路的安全。在微服务领域熔断器最早是由 Martin Fowler 在他发表的 《Circuit Breaker》一文中提出。与物理学中的熔断器作用相似微服务架构中的熔断器能够在某个服务发生故障后向服务调用方返回一个符合预期的、可处理的降级响应FallBack而不是长时间的等待或者抛出调用方无法处理的异常。这样就保证了服务调用方的线程不会被长时间、不必要地占用避免故障在微服务系统中的蔓延防止系统雪崩效应的发生。Spring Cloud Hystrix Spring Cloud Hystrix 是一款优秀的服务容错与保护组件也是 Spring Cloud 中最重要的组件之一。Spring Cloud Hystrix 是基于 Netflix 公司的开源组件 Hystrix 实现的它提供了熔断器功能能够有效地阻止分布式微服务系统中出现联动故障以提高微服务系统的弹性。Spring Cloud Hystrix 具有服务降级、服务熔断、线程隔离、请求缓存、请求合并以及实时故障监控等强大功能。Hystrix [hɪstrɪks]中文含义是豪猪豪猪的背上长满了棘刺使它拥有了强大的自我保护能力。而 Spring Cloud Hystrix 作为一个服务容错与保护组件也可以让服务拥有自我保护的能力因此也有人将其戏称为“豪猪哥”。在微服务系统中Hystrix 能够帮助我们实现以下目标保护线程资源防止单个服务的故障耗尽系统中的所有线程资源。快速失败机制当某个服务发生了故障不让服务调用方一直等待而是直接返回请求失败。提供降级FallBack方案在请求失败后提供一个设计好的降级方案通常是一个兜底方法当请求失败后即调用该方法。防止故障扩散使用熔断机制防止故障扩散到其他服务。监控功能提供熔断器故障监控组件 Hystrix Dashboard随时监控熔断器的状态。Hystrix 服务降级Hystrix 提供了服务降级功能能够保证当前服务不受其他服务故障的影响提高服务的健壮性。服务降级的使用场景有以下 2 种在服务器压力剧增时根据实际业务情况及流量对一些不重要、不紧急的服务进行有策略地不处理或简单处理从而释放服务器资源以保证核心服务正常运作。当某些服务不可用时为了避免长时间等待造成服务卡顿或雪崩效应而主动执行备用的降级逻辑立刻返回一个友好的提示以保障主体业务不受影响。我们可以通过重写 HystrixCommand 的 getFallBack() 方法或 HystrixObservableCommand 的 resumeWithFallback() 方法使服务支持服务降级。Hystrix 服务降级 FallBack 既可以放在服务端进行也可以放在客户端进行。Hystrix 会在以下场景下进行服务降级处理程序运行异常服务超时熔断器处于打开状态线程池资源耗尽示例1下面我们就通过一个案例分别演示下 Hystrix 服务端服务降级和客户端服务降级。服务端服务降级1. 在主工程 spring-cloud-demo2 下创建一个名为 micro-service-cloud-provider-dept-hystrix-8004 的服务提供者并在其 pom.xml 中添加以下依赖。?xml version1.0 encodingUTF-8?
project xmlnshttp://maven.apache.org/POM/4.0.0 xmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexsi:schemaLocationhttp://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsdmodelVersion4.0.0/modelVersion!--父pom--parentartifactIdspring-cloud-demo2/artifactIdgroupIdnet.biancheng.c/groupIdversion0.0.1-SNAPSHOT/version/parentgroupIdnet.biancheng.c/groupIdartifactIdmicro-service-cloud-provider-dept-hystrix-8004/artifactIdversion0.0.1-SNAPSHOT/versionnamemicro-service-cloud-provider-dept-hystrix-8004/namedescriptionDemo project for Spring Boot/descriptionpropertiesjava.version1.8/java.version/propertiesdependenciesdependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-web/artifactId/dependencydependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-devtools/artifactIdscoperuntime/scopeoptionaltrue/optional/dependencydependencygroupIdorg.projectlombok/groupIdartifactIdlombok/artifactIdoptionaltrue/optional/dependencydependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-test/artifactIdscopetest/scope/dependency!--添加 Spring Boot 的监控模块--dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-actuator/artifactId/dependency!-- eureka 客户端--dependencygroupIdorg.springframework.cloud/groupIdartifactIdspring-cloud-starter-netflix-eureka-client/artifactId/dependency!--hystrix 依赖--dependencygroupIdorg.springframework.cloud/groupIdartifactIdspring-cloud-starter-netflix-hystrix/artifactId/dependency/dependenciesbuildpluginsplugingroupIdorg.springframework.boot/groupIdartifactIdspring-boot-maven-plugin/artifactIdconfigurationexcludesexcludegroupIdorg.projectlombok/groupIdartifactIdlombok/artifactId/exclude/excludes/configuration/plugin/plugins/build
/project2. 在类路径即 /resources 目录下添加一个配置文件 application.yml配置内容如下。spring:application:name: microServiceCloudProviderDeptHystrix #微服务名称对外暴漏的微服务名称十分重要server:port: 8004
########################################### Spring cloud 自定义服务名称和 ip 地址###############################################
eureka:client: #将客户端注册到 eureka 服务列表内service-url:#defaultZone: http://eureka7001:7001/eureka #这个地址是 7001注册中心在 application.yml 中暴露出来额注册地址 单机版defaultZone: http://eureka7001.com:7001/eureka/,http://eureka7002.com:7002/eureka/,http://eureka7003.com:7003/eureka/ #将服务注册到 Eureka 集群instance:instance-id: spring-cloud-provider-8004 #自定义服务名称信息prefer-ip-address: true #显示访问路径的 ip 地址
#####################spring cloud 使用 Spring Boot actuator 监控完善信息###########################################
# Spring Boot 2.50对 actuator 监控屏蔽了大多数的节点只暴露了 heath 节点本段配置*就是为了开启所有的节点
management:endpoints:web:exposure:include: * # * 在yaml 文件属于关键字所以需要加引号
info:app.name: micro-service-cloud-provider-dept-hystrixcompany.name: c.biancheng.netbuild.aetifactId: project.artifactIdbuild.version: project.version3. 在 net.biancheng.c.service 包下创建一个名为 DeptService 的接口代码如下。package net.biancheng.c.service;public interface DeptService {// hystrix 熔断器示例 okpublic String deptInfo_Ok(Integer id);//hystrix 熔断器超时案例public String deptInfo_Timeout(Integer id);
}4. 在 net.biancheng.c.service.impl 包下创建 DeptService 接口的实现类 DeptServiceImpl代码如下。package net.biancheng.c.service.impl;import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
import com.netflix.hystrix.contrib.javanica.annotation.HystrixProperty;
import net.biancheng.c.service.DeptService;
import org.springframework.stereotype.Service;import java.util.concurrent.TimeUnit;Service(deptService)
public class DeptServiceImpl implements DeptService {Overridepublic String deptInfo_Ok(Integer id) {return 线程池 Thread.currentThread().getName() deptInfo_Ok,id: id;}//一旦该方法失败并抛出了异常信息后会自动调用 HystrixCommand 注解标注的 fallbackMethod 指定的方法HystrixCommand(fallbackMethod dept_TimeoutHandler,commandProperties //规定 5 秒钟以内就不报错正常运行超过 5 秒就报错调用指定的方法{HystrixProperty(name execution.isolation.thread.timeoutInMilliseconds, value 5000)})Overridepublic String deptInfo_Timeout(Integer id) {int outTime 6;try {TimeUnit.SECONDS.sleep(outTime);} catch (InterruptedException e) {e.printStackTrace();}return 线程池 Thread.currentThread().getName() deptInfo_Timeout,id: id 耗时: outTime;}// 当服务出现故障后调用该方法给出友好提示public String dept_TimeoutHandler(Integer id) {return C语言中文网提醒您系统繁忙请稍后再试线程池 Thread.currentThread().getName() deptInfo_Timeout,id: id;}
}我们可以看到 deptInfo_Timeout() 方法上使用 HystrixCommand 注解该注解说明如下参数 fallbackMethod 属性用于指定降级方法。参数 execution.isolation.thread.timeoutInMilliseconds 用于设置自身调用超时时间的峰值峰值内可以正常运行否则执行降级方法5. 在 net.biancheng.c.controller 包下创建一个名为 DeptController 的 Controller 类代码如下。package net.biancheng.c.controller;import lombok.extern.slf4j.Slf4j;
import net.biancheng.c.service.DeptService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.*;RestController
Slf4j
public class DeptController {Autowiredprivate DeptService deptService;Value(${server.port})private String serverPort;RequestMapping(value /dept/hystrix/ok/{id})public String deptInfo_Ok(PathVariable(id) Integer id) {String result deptService.deptInfo_Ok(id);log.info(端口号 serverPort result: result);return result 端口号 serverPort;}// Hystrix 服务超时降级RequestMapping(value /dept/hystrix/timeout/{id})public String deptInfo_Timeout(PathVariable(id) Integer id) {String result deptService.deptInfo_Timeout(id);log.info(端口号 serverPort result: result);return result 端口号 serverPort;}}6. 在 micro-service-cloud-provider-dept-hystrix-8004 的主启动类上使用 EnableCircuitBreaker 注解开启熔断器功能代码如下。package net.biancheng.c;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;SpringBootApplication
EnableEurekaClient //开启 Eureka 客户端功能
EnableCircuitBreaker //激活熔断器功能
public class MicroServiceCloudProviderDeptHystrix8004Application {public static void main(String[] args) {SpringApplication.run(MicroServiceCloudProviderDeptHystrix8004Application.class, args);}}7. 依次启动服务注册中心Eureka Server集群和 micro-service-cloud-provider-dept-hystrix-8004并使用浏览器访问“http://eureka7001.com:8004/dept/hystrix/ok/1”结果如下图。图2Hystrix 正常服务案例8. 使用浏览器访问“http://eureka7001.com:8004/dept/hystrix/timeout/1”结果如下图。图3Hystrix 服务端服务降级客户端服务降级通常情况下我们都会在客户端进行服务降级当客户端调用的服务端的服务不可用时客户端直接进行服务降级处理避免其线程被长时间、不必要地占用。客户端服务降级步骤如下。1. 在 micro-service-cloud-consumer-dept-feign 的 pom.xml 中添加 Hystrix 的依赖代码如下。!--hystrix 依赖--
dependencygroupIdorg.springframework.cloud/groupIdartifactIdspring-cloud-starter-netflix-hystrix/artifactId
/dependency2. 在 micro-service-cloud-consumer-dept-feign 的 application.yml 中添加以下配置开启客户端的 Hystrix 功能。feign:hystrix:enabled: true #开启客户端 hystrix3. 在 net.biancheng.c.service 包下创建一个名为 DeptHystrixService 的服务绑定接口与 micro-service-cloud-provider-dept-hystrix-8004 中提供的服务接口进行绑定代码如下。package net.biancheng.c.service;import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;Component
FeignClient(value MICROSERVICECLOUDPROVIDERDEPTHYSTRIX)
public interface DeptHystrixService {RequestMapping(value /dept/hystrix/ok/{id})public String deptInfo_Ok(PathVariable(id) Integer id);RequestMapping(value /dept/hystrix/timeout/{id})public String deptInfo_Timeout(PathVariable(id) Integer id);
}4. 在 net.biancheng.c.controller 包下创建一个名为 HystrixController_Consumer 的 Controller 代码如下。package net.biancheng.c.controller;import com.netflix.hystrix.contrib.javanica.annotation.DefaultProperties;
import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;;
import lombok.extern.slf4j.Slf4j;
import net.biancheng.c.service.DeptHystrixService;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;import javax.annotation.Resource;Slf4j
RestController
public class HystrixController_Consumer {Resourceprivate DeptHystrixService deptHystrixService;RequestMapping(value /consumer/dept/hystrix/ok/{id})public String deptInfo_Ok(PathVariable(id) Integer id) {return deptHystrixService.deptInfo_Ok(id);}//在客户端进行降级RequestMapping(value /consumer/dept/hystrix/timeout/{id})HystrixCommand(fallbackMethod dept_TimeoutHandler) //为该请求指定专属的回退方法public String deptInfo_Timeout(PathVariable(id) Integer id) {String s deptHystrixService.deptInfo_Timeout(id);log.info(s);return s;}// deptInfo_Timeout方法的 专用 fallback 方法public String dept_TimeoutHandler(PathVariable(id) Integer id) {log.info(deptInfo_Timeout 出错服务已被降级);return C语言中文网提醒您服务端系统繁忙请稍后再试客户端 deptInfo_Timeout 专属的回退方法触发;}
}5. 在配置文件 appliction.yml 中添加以下配置在客户端配置请求超时的时间。######################### Ribbon 客户端超时控制 ###################################
ribbon:ReadTimeout: 6000 #建立连接所用的时间适用于网络状况正常的情况下两端两端连接所用的时间ConnectionTimeout: 6000 #建立连接后服务器读取到可用资源的时间
######################配置请求超时时间##########################
hystrix:command:default:execution:isolation:thread:timeoutInMilliseconds: 7000
####################配置具体方法超时时间 为 3 秒########################DeptHystrixService#deptInfo_Timeout(Integer):execution:isolation:thread:timeoutInMilliseconds: 3000在配置文件中设计请求的超时时间时需要注意以下 2 点 1Hystrix 可以来为所有请求方法设置超时时间单位为毫秒若请求超时则触发全局的回退方法进行处理。hystrix.command.default.execution.isolation.thread.timeoutInMillisecondsmmm2Hystrix 还可以为某个特定的服务请求方法设置超时时间格式如下hystrix.command.xxx#yyy(zzz).execution.isolation.thread.timeoutInMillisecondsmmm格式说明如下xxx为包含该服务方法的类的名称通常为服务绑定接口的名称例如 DeptHystrixService 接口。yyy服务方法名例如 deptInfo_Timeout() 方法。zzz方法内的参数类型例如 Integer、String 等等mmm要设置的超时时间单位为毫秒1 秒 1000 毫秒6. 在 micro-service-cloud-consumer-dept-feign 的主启动类上使用 EnableHystrix 注解开启客户端 Hystrix 功能代码如下。package net.biancheng.c;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.hystrix.EnableHystrix;
import org.springframework.cloud.openfeign.EnableFeignClients;SpringBootApplication
EnableFeignClients //开启 OpenFeign 功能
EnableHystrix //启用 Hystrix
public class MicroServiceCloudConsumerDeptFeignApplication {public static void main(String[] args) {SpringApplication.run(MicroServiceCloudConsumerDeptFeignApplication.class, args);}
}7. 修改 micro-service-cloud-provider-dept-hystrix-8004 中 DeptServiceImpl 的代码将 deptInfo_Timeout() 方法的运行时间修改为 4 秒小于超时时间 5 秒以保证服务端请求正常不被降级代码如下。//一旦该方法失败并抛出了异常信息后会自动调用 HystrixCommand 注解标注的 fallbackMethod 指定的方法
HystrixCommand(fallbackMethod dept_TimeoutHandler,commandProperties //规定 5 秒钟以内就不报错正常运行超过 5 秒就报错调用指定的方法{HystrixProperty(name execution.isolation.thread.timeoutInMilliseconds, value 5000)})
Override
public String deptInfo_Timeout(Integer id) {int outTime 4;try {TimeUnit.SECONDS.sleep(outTime);} catch (InterruptedException e) {e.printStackTrace();}return 线程池 Thread.currentThread().getName() deptInfo_Timeout,id: id 耗时: outTime;
}8. 重启 micro-service-cloud-provider-dept-hystrix-8004 和 micro-service-cloud-consumer-dept-feign使用浏览器访问“http://eureka7001.com:8004/dept/hystrix/timeout/1”直接调用服务端的 deptInfo_Timeout() 方法结果如下图。图4Hystrix 服务端请求正常9. 使用浏览器访问“http://eureka7001.com/consumer/dept/hystrix/timeout/1”结果如下图。图5Hystrix 客户端服务降级由图 5 可以看出由于服务请求的耗时为 4 秒超过了客户端为该请求指定的超时时间 3 秒 因此该服务被降级处理触发了其指定的回退方法。全局降级方法通过上面的方式实现服务降级时需要针对所有业务方法都配置降级方法这极有可能会造成代码的急剧膨胀。为了解决该问题我们还可以为所有业务方法指定一个全局的回退方法具体步骤如下。1. 在 HystrixController_Consumer 的类名上标注 DefaultProperties 注解并通过其 defaultFallback 属性指定一个全局的降级方法代码如下。Slf4j
RestController
DefaultProperties(defaultFallback dept_Global_FallbackMethod) //全局的服务降级方法
public class HystrixController_Consumer {
……
}2. 在 HystrixController_Consumer 中创建一个名为 dept_Global_FallbackMethod 的全局回方法代码如下。/*** 全局的 fallback 方法* 回退方法必须和 hystrix 的执行方法在相同类中* DefaultProperties(defaultFallback dept_Global_FallbackMethod) 类上注解请求方法上使用 HystrixCommand 注解*/
public String dept_Global_FallbackMethod() {return C语言中文网提醒您运行出错或服务端系统繁忙请稍后再试客户端全局回退方法触发,;
}注意降级FallBack方法必须与其对应的业务方法在同一个类中否则无法生效。3. 在所有的业务方法上都标注 HystrixCommand 注解这里我们将 deptInfo_Timeout() 方法上的 HystrixCommand(fallbackMethod dept_TimeoutHandler) 修改为 HystrixCommand 即可代码如下。//在客户端进行降级
RequestMapping(value /consumer/dept/hystrix/timeout/{id})
HystrixCommand
public String deptInfo_Timeout(PathVariable(id) Integer id) {String s deptHystrixService.deptInfo_Timeout(id);log.info(s);return s;
}注意全局降级方法的优先级较低只有业务方法没有指定其降级方法时服务降级时才会触发全局回退方法。若业务方法指定它自己的回退方法那么在服务降级时就只会直接触发它自己的回退方法而非全局回退方法。4. 重启 micro-service-cloud-consumer-dept-feign使用浏览器访问“http://eureka7001.com/consumer/dept/hystrix/timeout/1”结果如下图。图6全局回退方法解耦降级逻辑不管是业务方法指定的降级方法还是全局降级方法它们都必须和业务方法在同一个类中才能生效业务逻辑与降级逻辑耦合度极高。下面我们对业务逻辑与降级逻辑进行解耦操作步骤如下。1. 在 micro-service-cloud-consumer-dept-feign 的 net.biancheng.c.service 包下新建 DeptHystrixService 接口的实现类 DeptHystrixFallBackService统一为 DeptHystrixService 中的方法提供服务降级处理 代码如下。package net.biancheng.c.service;import org.springframework.stereotype.Component;/**
* Hystrix 服务降级
* 解耦回退逻辑
*/
Component
public class DeptHystrixFallBackService implements DeptHystrixService {Overridepublic String deptInfo_Ok(Integer id) {return --------------------C语言中文网提醒您系统繁忙请稍后重试解耦回退方法触发-----------------------;}Overridepublic String deptInfo_Timeout(Integer id) {return --------------------C语言中文网提醒您系统繁忙请稍后重试解耦回退方法触发-----------------------;}
}注意该类必须以组件的形式添加 Spring 容器中才能生效最常用的方式就是在类上标注 Component 注解。2. 在服务绑定接口 DeptHystrixService 标注的 FeignClient 注解中添加 fallback 属性属性值为 DeptHystrixFallBackService.class代码如下。package net.biancheng.c.service;import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;Component
FeignClient(value MICROSERVICECLOUDPROVIDERDEPTHYSTRIX, fallback DeptHystrixFallBackService.class)
public interface DeptHystrixService {RequestMapping(value /dept/hystrix/ok/{id})public String deptInfo_Ok(PathVariable(id) Integer id);RequestMapping(value /dept/hystrix/timeout/{id})public String deptInfo_Timeout(PathVariable(id) Integer id);
}3. 重启 micro-service-cloud-consumer-dept-feign然后关闭服务端 micro-service-cloud-provider-dept-hystrix-8004使用浏览器访问“http://eureka7001.com/consumer/dept/hystrix/ok/1”结果如下图。图7Hystrix 解耦回退方法Hystrix 服务熔断熔断机制是为了应对雪崩效应而出现的一种微服务链路保护机制。当微服务系统中的某个微服务不可用或响应时间太长时为了保护系统的整体可用性熔断器会暂时切断请求对该服务的调用并快速返回一个友好的错误响应。这种熔断状态不是永久的在经历了一定的时间后熔断器会再次检测该微服务是否恢复正常若服务恢复正常则恢复其调用链路。熔断状态在熔断机制中涉及了三种熔断状态熔断关闭状态Closed当服务访问正常时熔断器处于关闭状态服务调用方可以正常地对服务进行调用。熔断开启状态Open默认情况下在固定时间内接口调用出错比率达到一个阈值例如 50%熔断器会进入熔断开启状态。进入熔断状态后后续对该服务的调用都会被切断熔断器会执行本地的降级FallBack方法。半熔断状态Half-Open 在熔断开启一段时间之后熔断器会进入半熔断状态。在半熔断状态下熔断器会尝试恢复服务调用方对服务的调用允许部分请求调用该服务并监控其调用成功率。如果成功率达到预期则说明服务已恢复正常熔断器进入关闭状态如果成功率仍旧很低则重新进入熔断开启状态。三种熔断状态之间的转化关系如下图图8三种熔断状态转换Hystrix 实现熔断机制在 Spring Cloud 中熔断机制是通过 Hystrix 实现的。Hystrix 会监控微服务间调用的状况当失败调用到一定比例时例如 5 秒内失败 20 次就会启动熔断机制。Hystrix 实现服务熔断的步骤如下当服务的调用出错率达到或超过 Hystix 规定的比率默认为 50%后熔断器进入熔断开启状态。熔断器进入熔断开启状态后Hystrix 会启动一个休眠时间窗在这个时间窗内该服务的降级逻辑会临时充当业务主逻辑而原来的业务主逻辑不可用。当有请求再次调用该服务时会直接调用降级逻辑快速地返回失败响应以避免系统雪崩。当休眠时间窗到期后Hystrix 会进入半熔断转态允许部分请求对服务原来的主业务逻辑进行调用并监控其调用成功率。如果调用成功率达到预期则说明服务已恢复正常Hystrix 进入熔断关闭状态服务原来的主业务逻辑恢复否则 Hystrix 重新进入熔断开启状态休眠时间窗口重新计时继续重复第 2 到第 5 步。示例下面我们就通过一个实例来验证下 Hystrix 是如何实现熔断机制的。1. 在 micro-service-cloud-provider-dept-hystrix-8004 中的 DeptService 接口中添加一个 deptCircuitBreaker() 方法代码如下。package net.biancheng.c.service;public interface DeptService {// hystrix 熔断器示例 okpublic String deptInfo_Ok(Integer id);//hystrix 熔断器超时案例public String deptInfo_Timeout(Integer id);// Hystrix 熔断机制案例public String deptCircuitBreaker(Integer id);
}2. 在 DeptService 接口的实现类 DeptServiceImpl 添加 deptCircuitBreaker() 的方法实现及其回退方法代码如下。//Hystrix 熔断案例
Override
HystrixCommand(fallbackMethod deptCircuitBreaker_fallback, commandProperties {//以下参数在 HystrixCommandProperties 类中有默认配置HystrixProperty(name circuitBreaker.enabled, value true), //是否开启熔断器HystrixProperty(name metrics.rollingStats.timeInMilliseconds,value 1000), //统计时间窗HystrixProperty(name circuitBreaker.requestVolumeThreshold, value 10), //统计时间窗内请求次数HystrixProperty(name circuitBreaker.sleepWindowInMilliseconds, value 10000), //休眠时间窗口期HystrixProperty(name circuitBreaker.errorThresholdPercentage, value 60), //在统计时间窗口期以内请求失败率达到 60% 时进入熔断状态
})
public String deptCircuitBreaker(Integer id) {if (id 0) {//当传入的 id 为负数时抛出异常调用降级方法throw new RuntimeException(c语言中文网提醒您id 不能是负数);}String serialNum IdUtil.simpleUUID();return Thread.currentThread().getName() \t 调用成功流水号为 serialNum;
}//deptCircuitBreaker 的降级方法
public String deptCircuitBreaker_fallback(Integer id) {return c语言中文网提醒您id 不能是负数,请稍后重试!\t id: id;
}在以上代码中共涉及到了 4 个与 Hystrix 熔断机制相关的重要参数这 4 个参数的含义如下表。参数描述metrics.rollingStats.timeInMilliseconds统计时间窗。circuitBreaker.sleepWindowInMilliseconds休眠时间窗熔断开启状态持续一段时间后熔断器会自动进入半熔断状态这段时间就被称为休眠窗口期。circuitBreaker.requestVolumeThreshold请求总数阀值。在统计时间窗内请求总数必须到达一定的数量级Hystrix 才可能会将熔断器打开进入熔断开启转态而这个请求数量级就是 请求总数阀值。Hystrix 请求总数阈值默认为 20这就意味着在统计时间窗内如果服务调用次数不足 20 次即使所有的请求都调用出错熔断器也不会打开。circuitBreaker.errorThresholdPercentage错误百分比阈值。当请求总数在统计时间窗内超过了请求总数阀值且请求调用出错率超过一定的比例熔断器才会打开进入熔断开启转态而这个比例就是错误百分比阈值。错误百分比阈值设置为 50就表示错误百分比为 50%如果服务发生了 30 次调用其中有 15 次发生了错误即超过了 50% 的错误百分比这时候将熔断器就会打开。3. 在 DeptController 中添加一个 deptCircuitBreaker() 方法对外提供服务代码如下。// Hystrix 服务熔断
RequestMapping(value /dept/hystrix/circuit/{id})
public String deptCircuitBreaker(PathVariable(id) Integer id){String result deptService.deptCircuitBreaker(id);log.info(result:result);return result;
}4. 重启 micro-service-cloud-provider-dept-hystrix-8004使用浏览器访问“http://eureka7001.com:8004/dept/hystrix/circuit/1”结果如下图。图9Hystrix 实现熔断机制 调用正确示例5. 浏览器多次调用次数大于请求总数阀值访问“http://eureka7001.com:8004/dept/hystrix/circuit/-2”使调用出错率大于错误百分比阀值结果下图。图10Hystrix 实现熔断机制 错误调用6. 重新将参数修改为正数例如参数为 3使用浏览器访问“http://eureka7001.com:8004/dept/hystrix/circuit/3”结果如下图。图11Hystrix 熔断开启状态传入正数通过图 11 可以看到在熔断开启状态下即使我们传入的参数已经是正数调用的依然降级逻辑。7. 继续连续访问“http://eureka7001.com:8004/dept/hystrix/circuit/3”结果下图。图12Hystrix 进入熔断关闭状态通过图 12 可以看出当服务调用正确率上升到一定的利率后Hystrix 进入熔断关闭状态。Hystrix 故障监控Hystrix 还提供了准实时的调用监控Hystrix Dashboard功能Hystrix 会持续地记录所有通过 Hystrix 发起的请求的执行信息并以统计报表的形式展示给用户包括每秒执行请求的数量、成功请求的数量和失败请求的数量等。下面我们就通过一个实例来搭建 Hystrix Dashboard监控 micro-service-cloud-provider-dept-hystrix-8004 的运行情况。1. 在父工程下新建一个名为 micro-service-cloud-consumer-dept-hystrix-dashboard-9002 的子模块并在其 pom.xml 中添加以下依赖。?xml version1.0 encodingUTF-8?
project xmlnshttp://maven.apache.org/POM/4.0.0 xmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexsi:schemaLocationhttp://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsdmodelVersion4.0.0/modelVersionparentartifactIdspring-cloud-demo2/artifactIdgroupIdnet.biancheng.c/groupIdversion0.0.1-SNAPSHOT/version/parentgroupIdnet.biancheng.c/groupIdartifactIdmicro-service-cloud-consumer-dept-hystrix-dashboard-9002/artifactIdversion0.0.1-SNAPSHOT/versionnamemicro-service-cloud-consumer-dept-hystrix-dashboard-9002/namedescriptionDemo project for Spring Boot/descriptionpropertiesjava.version1.8/java.version/propertiesdependenciesdependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter/artifactId/dependency!--Spring Boot 测试依赖--dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-test/artifactIdscopetest/scope/dependency!--hystrix-dashboard 监控的依赖--dependencygroupIdorg.springframework.cloud/groupIdartifactIdspring-cloud-starter-netflix-hystrix-dashboard/artifactId/dependency!--添加 Spring Boot 的监控模块--dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-actuator/artifactId/dependencydependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-devtools/artifactId/dependencydependencygroupIdorg.projectlombok/groupIdartifactIdlombok/artifactId/dependency/dependenciesbuildpluginsplugingroupIdorg.springframework.boot/groupIdartifactIdspring-boot-maven-plugin/artifactId/plugin/plugins/build
/project2. 在 micro-service-cloud-consumer-dept-hystrix-dashboard-9002 的 application.yml 中添加以下配置。server:port: 9002 #端口号#http://eureka7001.com:9002/hystrix 熔断器监控页面
# localhost:8004//actuator/hystrix.stream 监控地址
hystrix:dashboard:proxy-stream-allow-list:- localhost3. 在 micro-service-cloud-consumer-dept-hystrix-dashboard-9002 的主启动类上添加 EnableHystrixDashboard 注解开启 Hystrix 监控功能代码如下。package net.biancheng.c;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.hystrix.dashboard.EnableHystrixDashboard;SpringBootApplication
EnableHystrixDashboard
public class MicroServiceCloudConsumerDeptHystrixDashboard9002Application {public static void main(String[] args) {SpringApplication.run(MicroServiceCloudConsumerDeptHystrixDashboard9002Application.class, args);}}4. 在 micro-service-cloud-provider-dept-hystrix-8004 的 net.biancheng.c.config 包下创建一个名为 HystrixDashboardConfig 的配置类代码如下。package net.biancheng.c.config;import com.netflix.hystrix.contrib.metrics.eventstream.HystrixMetricsStreamServlet;
import org.springframework.boot.web.servlet.ServletRegistrationBean;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;Configuration
public class HystrixDashboardConfig {/*** Hystrix dashboard 监控界面必须配置* return*/Beanpublic ServletRegistrationBean getServlet() {HystrixMetricsStreamServlet streamServlet new HystrixMetricsStreamServlet();ServletRegistrationBean registrationBean new ServletRegistrationBean(streamServlet);registrationBean.setLoadOnStartup(1);registrationBean.addUrlMappings(/actuator/hystrix.stream);//访问路径registrationBean.setName(hystrix.stream);return registrationBean;}}5. 启动 micro-service-cloud-consumer-dept-hystrix-dashboard-9002使用浏览器访问“http://eureka7001.com:9002/hystrix”结果如下图。图13Hystrix 监控页面6. 重启 micro-service-cloud-provider-dept-hystrix-8004并将以下信息填到 Hystrix 监控页面中如下图。图14Hystrix 监控信息7. 点击下方的 Monitor Stream 按钮跳转到 Hystrix 对 micro-service-cloud-provider-dept-hystrix-8004 的监控页面如下图。图15Hystrix 监控微服务运行情况8. 使用浏览器多次访问“http://eureka7001.com:8004/dept/hystrix/circuit/1”和 “http://eureka7001.com:8004/dept/hystrix/circuit/-1”查看 Hystrix 监控页面如下图。参考文章http://c.biancheng.net/springcloud/hystrix.html
