Spring Cloud构建微服务架构:服务容错保护(Hystrix服务降级)
2017-09-13 08:39
851 查看
前言
在微服务架构中,我们将系统拆分成了一个个的服务单元,各单元应用间通过服务注册与订阅的方式互相依赖。由于每个单元都在不同的进程中运行,依赖通过远程调用的方式执行,这样就有可能因为网络原因或是依赖服务自身问题出现调用故障或延迟,而这些问题会直接导致调用方的对外服务也出现延迟,若此时调用方的请求不断增加,最后就会出现因等待出现故障的依赖方响应而形成任务积压,线程资源无法释放,最终导致自身服务的瘫痪,进一步甚至出现故障的蔓延最终导致整个系统的瘫痪。如果这样的架构存在如此严重的隐患,那么相较传统架构就更加的不稳定。为了解决这样的问题,因此产生了断路器等一系列的服务保护机制。针对上述问题,在Spring Cloud Hystrix中实现了线程隔离、断路器等一系列的服务保护功能。它也是基于Netflix的开源框架 Hystrix实现的,该框架目标在于通过控制那些访问远程系统、服务和第三方库的节点,从而对延迟和故障提供更强大的容错能力。Hystrix具备了服务降级、服务熔断、线程隔离、请求缓存、请求合并以及服务监控等强大功能。
接下来,我们就从一个简单示例开始对Spring Cloud Hystrix的学习与使用。
动手试一试
在开始使用Spring Cloud Hystrix实现断路器之前,我们先拿之前实现的一些内容作为基础,其中包括:eureka-server工程:服务注册中心,端口:1001
eureka-client工程:服务提供者,两个实例启动端口分别为2001
下面我们可以复制一下之前实现的一个服务消费者:
eureka-consumer-ribbon,命名为
eureka-consumer-ribbon-hystrix。下面我们开始对其进行改在:
第一步:
pom.xml的dependencies节点中引入
spring-cloud-starter-hystrix依赖:
1234 | <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-hystrix</artifactId></dependency> |
@EnableCircuitBreaker或
@EnableHystrix注解开启Hystrix的使用:
12345678910111213141516 | @EnableCircuitBreaker@EnableDiscoveryClient@SpringBootApplicationpublic class Application { @Bean @LoadBalanced public RestTemplate restTemplate() { return new RestTemplate(); } public static void main(String[] args) { new SpringApplicationBuilder(Application.class).web(true).run(args); }} |
@SpringCloudApplication注解来修饰应用主类,该注解的具体定义如下所示。我们可以看到该注解中包含了上我们所引用的三个注解,这也意味着一个Spring
Cloud标准应用应包含服务发现以及断路器。
123456789 | @Target({ElementType.TYPE})@Retention(RetentionPolicy.RUNTIME)@Documented@Inherited@SpringBootApplication@EnableDiscoveryClient@EnableCircuitBreakerpublic @interface SpringCloudApplication {} |
ConsumerService类,然后将在
Controller中的逻辑迁移过去。最后,在为具体执行逻辑的函数上增加
@HystrixCommand注解来指定服务降级方法,比如:
12345678910111213141516171819202122232425262728 | @RestControllerpublic class DcController { @Autowired ConsumerService consumerService; @GetMapping("/consumer") public String dc() { return consumerService.consumer(); } class ConsumerService { @Autowired RestTemplate restTemplate; @HystrixCommand(fallbackMethod = "fallback") public String consumer() { return restTemplate.getForObject("http://eureka-client/dc", String.class); } public String fallback() { return "fallback"; } }} |
localhost:2101/consumer,此时可以获取正常的返回,比如:
Services: [eureka-consumer-ribbon-hystrix, eureka-client]。
为了触发服务降级逻辑,我们可以将服务提供者
eureka-client的逻辑加一些延迟,比如:
1234567 | @GetMapping("/dc")public String dc() throws InterruptedException { Thread.sleep(5000L); String services = "Services: " + discoveryClient.getServices(); System.out.println(services); return services;} |
eureka-client之后,再尝试访问
localhost:2101/consumer,此时我们将获得的返回结果为:
fallback。我们从
eureka-client的控制台中,可以看到服务提供方输出了原本要返回的结果,但是由于返回前延迟了5秒,而服务消费方触发了服务请求超时异常,服务消费者就通过HystrixCommand注解中指定的降级逻辑进行执行,因此该请求的结果返回了
fallback。这样的机制,对自身服务起到了基础的保护,同时还为异常情况提供了自动的服务降级切换机制。
更多Spring Cloud内容请持续关注我的博客更新或在《Spring Cloud微服务实战》中获取。
代码示例
样例工程将沿用之前在码云和GitHub上创建的SpringCloud-Learning项目,重新做了一下整理。通过不同目录来区分Brixton和Dalston的示例。
相关文章推荐
- Spring Cloud构建微服务架构:服务容错保护(Hystrix服务降级)【Dalston版】
- 企业级 Spring Cloud构建微服务架构:服务容错保护(Hystrix服务降级)
- Spring Cloud构建微服务架构:服务容错保护(Hystrix断路器)【Dalston版】
- Spring Cloud架构教程 (十四)服务容错保护(Hystrix服务降级)【Dalston版】
- Spring Cloud构建微服务架构:服务容错保护(Hystrix断路器)
- Spring Cloud构建微服务架构:服务容错保护(Hystrix服务降级)【Dalston版】
- Spring Cloud构建微服务架构:服务容错保护(Hystrix依赖隔离)
- Spring Cloud构建微服务架构:服务容错保护
- Spring Cloud构建微服务架构:服务容错保护(Hystrix依赖隔离)
- Spring Cloud构建微服务架构:服务容错保护(Hystrix依赖隔离)【Dalston版】
- Spring Cloud构建微服务架构:服务容错保护(Hystrix断路器)【Dalston版】
- Spring Cloud构建微服务架构:服务容错保护(Hystrix依赖隔离)
- spring cloud学习笔记2(负载均衡ribbon,服务容错保护Hystrix)
- 服务容错保护断路器Hystrix之六:服务熔断和服务降级
- Spring Cloud构建微服务架构-Hystrix服务降级
- Spring Cloud Spring Boot mybatis 企业分布式微服务云(七)服务容错保护(Hystrix服务降级)【Dalston版】
- Spring Cloud构建微服务架构(四)断路器(Hystrix)
- Spring Cloud构建微服务架构-Hystrix依赖隔离
- Spring Cloud构建微服务架构服务容错保护
- Spring Cloud学习--容错机制(Hystrix之服务降级)