SpringCloud微服务系列(5): 服务容错断路器Hystrix

SpringCloud微服务系列(5): 
服务容错断路器Hystrix

作者:家辉,日期:2017-08-08 CSDN博客http://blog.csdn.net/gobitan

摘要:
在本系列的前四篇创建了一个高可用Eureka微服务注册中心,一个hello服务,一个服务消费者ribbon-consumer。本文将介绍服务容错断路器Hystrix。

概述

用户的一个请求可能在后端微服务中被拆分成多个服务,如果其中一个服务出现故障,如何进行隔离,尽可能地降低因为单个服务故障对整个系统的影响。这就是本文中的断路器Hystrix。

第一步:在
ribbon-consumer工程上增加对Hystrix的依赖

pom.xml中添加对Hystrix的依赖,如下:

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-hystrix</artifactId>
</dependency>

第二步:在主类中开启断路器功能

在主类中添加注解@EnableCircuitBreaker开启断路器功能。

也可用@SpringCloudApplication注解来替换如下三个注解:

@SpringBootApplication

@EnableDiscoveryClient

@EnableCircuitBreaker

第三步:改造服务消费方式

[1] 新增HelloService

package cn.dennishucd.ribbonconsumer;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.client.RestTemplate;

import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;

public class HelloService {

    @Autowired
    RestTemplate restTemplate;
    
    @HystrixCommand(fallbackMethod = "helloFallback")
    public String helloService() {
        return restTemplate.getForEntity("http://hello-service/hello", String.class).getBody();
    }
    
    public String helloFallback() {
        return "error";
    }
}

通过为服务方法helloService增加@HystrixCommand注解,并定义服务降级回调方法fallbackMethod,当服务失败时就调用该方法。

[2] 修改ConsumerController类

package cn.dennishucd.ribbonconsumer;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

@RestController
public class ConsumerController {
    @Autowired
    HelloService helloService;

    @RequestMapping(value = "ribbon-consumer", method = RequestMethod.GET)
    public String helloConsumer() {
        return helloService.helloService();
    }
}

修改后的类,通过调用前面的服务实现服务消费,而不是在Controller中直接实现。

第四步:修改ribbon-consumer的版本

为了与未加入断路器的之前的ribbon-consumer区别,将它的版本由原来默认的0.0.1改为0.0.2。具体修改位置位于pom.xml中如下:

<groupId>cn.dennishucd</groupId>
<artifactId>ribbonconsumer</artifactId>
<version>0.0.2-SNAPSHOT</version>
<packaging>jar</packaging>

第五步:调测和验证断路器

准备工作:

[1] 启动两个eureka注册中心:eureka1和eureka2; 启动方法参考系列3.

[2] 启动两个hello-service服务注册到注册中心; 启动方法参考系列4.

这时,分别做如下测试步骤:

[1] 启动老版本的ribbon-consumer,即java -jar ribbonconsumer-0.0.1-SNAPSHOT.jar。连续两次请求 http://localhost:9000/ribbon-consumer
服务,可以看到分别请求了启动在8081和8082的hello-service服务,每次都返回”Hello World!”; 然后将8081端口的hello-service停掉,然后再连续两次请求ribbon-consumer服务,可以看到一次返回500错误请求失败,一次返回”Hello World!”; 

[2] 停止老版本,启动新版本的ribbon-consumer,即java -jar ribbonconsumer-0.0.2-SNAPSHOT.jar。连续两次请求 http://localhost:9000/ribbon-consumer
服务,可以看到分别请求了启动在8081和8082的hello-service服务,每次都返回”Hello World!”; 然后将8081端口的hello-service停掉,然后再连续两次请求ribbon-consumer服务,可以看到一次返回error,一次返回”Hello World!”; 这说明断路器发挥了作用,当服务失败时,自动返回自定义的回调返回error。

[3] 经过测试,当8081的服务发生故障,过一会儿后(具体时间待确定)之后,ribbon每次请求都会成功。ribbon不会再将请求发往8081。因为,当一个服务发生故障后,注册器周期性地会把发生故障的服务清理出去。此时,后台的服务就只剩下8082了。

Hystrix还可以实现请求缓存,后续再做研究。

疑问:服务故障后,到注册中心主动清除的默认超时时间是多长?

[1]  http://start.spring.io/

[2]  http://projects.spring.io/spring-cloud/

原文 

http://blog.csdn.net/gobitan/article/details/76917473

PS:如果您想和业内技术大牛交流的话,请加qq群(527933790)或者关注微信公众 号(AskHarries),谢谢!

转载请注明原文出处:Harries Blog™ » SpringCloud微服务系列(5): 服务容错断路器Hystrix

赞 (0)

分享到:更多 ()

评论 0

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址