Spring Cloud中的断路器Hystrix怎么使用

本篇内容介绍了“Spring Cloud中的断路器Hystrix怎么使用”的有关知识，在实际案例的操作过程中，不少人都会遇到这样的困境，接下来就让小编带领大家学习一下如何处理这些情况吧！希望大家仔细阅读，能够学有所成！

首先我们分别启动服务注册中心，再启动两个服务提供者的实例，端口号分别是8080和8081，然后再启动一个服务消费者，服务消费者的端口号为9000，这几个都启动成功之后，我们访问http://localhost:9000/ribbon-consumer这个地址，可以看到如下效果：

此时我们关闭掉任意一个服务提供者，再去访问这个地址，会看到如下效果：

通过前面几篇文章的学习，大家知道Spring Cloud中采取的默认负载均衡策略就是轮询，所以当一个服务提供者关掉之后，刷新的时候服务请求成功和请求失败是成对出现的：当服务消费者去请求那个被关掉的服务提供者的时候就会请求失败，当服务消费者去请求正常的服务提供者时就能获得期望的结果。请求失败时不能给用户展示这样一个ErrorPage,而应该是一个可控的页面，OK，我们来看看如何使用断路器来解决这个问题。

服务消费者中加入断路器

首先我们需要在服务消费者中引入hystrix，如下：

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

修改服务消费者启动入口类

引入hystrix之后，我们需要在入口类上通过@EnableCircuitBreaker开启断路器功能，如下:

@EnableCircuitBreaker@SpringBootApplication@EnableDiscoveryClientpublic class RibbonConsumerApplication {    public static void main(String[] args) {        SpringApplication.run(RibbonConsumerApplication.class, args);    }    @LoadBalanced    @Bean    RestTemplate restTemplate() {        return new RestTemplate();    }}

我们也可以使用一个名为@SpringBootApplication的注解代替这三个注解，@SpringBootApplication注解的定义如下：

@Target(ElementType.TYPE)@Retention(RetentionPolicy.RUNTIME)@Documented@Inherited@SpringBootApplication@EnableDiscoveryClient@EnableCircuitBreakerpublic @interface SpringCloudApplication {}

实际上就是这三个注解的一个整合。

修改Controller

然后我们创建一个HelloService类，如下：

@Servicepublic class HelloService {    @Autowired    private RestTemplate restTemplate;    @HystrixCommand(fallbackMethod = "error")    public String hello() {        ResponseEntity<String> responseEntity = restTemplate.getForEntity("http://HELLO-SERVICE/hello", String.class);        return responseEntity.getBody();    }    public String error() {        return "error";    }}

关于这个HelloService类我说如下几点：

RestTemplate执行网络请求的操作我们放在HelloService中来完成。
2.error方法是一个请求失败时回调的方法。
3.在hello方法上通过@HystrixCommand注解来指定请求失败时回调的方法。

OK，最后我们将ConsumerController的逻辑修改成下面这样：

@RestControllerpublic class ConsumerController {    @Autowired    private HelloService helloService;    @RequestMapping(value = "/ribbon-consumer",method = RequestMethod.GET)    public String helloController() {        return helloService.hello();    }}

此时我们就开启了断路器功能。

测试

我们先确认服务注册中心，两个服务提供者的实例，端口号分别是8080和8081，一个服务消费者，端口号为9000，一共四个实例都启动成功，启动成功之后，我们再关掉一个服务提供者，此时访问http://localhost:9000/ribbon-consumer,结果如下：

“Spring Cloud中的断路器Hystrix怎么使用”的内容就介绍到这里了，感谢大家的阅读。如果想了解更多行业相关的知识可以关注编程网网站，小编将为大家输出更多高质量的实用文章！