解析springcloud中的Hystrix

解析Spring Cloud中的Hystrix

简介

Hystrix是Netflix公司开发的一种用于处理分布式系统的延迟和容错的库。它实现了断路器模式，通过添加延迟阈值、容错和回退机制来增加系统的鲁棒性。在Spring Cloud中使用Hystrix，我们可以轻松地实现断路器模式。本文将介绍如何在Spring Cloud中使用Hystrix。

Hystrix使用流程

添加依赖

我们需要在pom.xml文件中添加以下依赖：

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

定义服务调用

定义一个服务调用的类，使用@HystrixCommand注解来定义一个需要进行容错的方法，并且在注解中指定一个fallback方法来实现容错处理：

@Service
public class HelloService {

    @Autowired
    RestTemplate restTemplate;

    @HystrixCommand(fallbackMethod = "helloFallback")
    public String helloService(){
        long start = System.currentTimeMillis();
        String result = restTemplate.getForEntity("http://SERVICE-HELLO/hello", String.class).getBody();
        long end = System.currentTimeMillis();
        System.out.println("Spend time : " + (end - start));
        return result;
    }

    public String helloFallback(){
        return "error";
    }
}

配置Hystrix

在application.yml中设置Hystrix的配置：

hystrix:
  command:
    default:
      execution:
        isolation:
          thread:
            timeoutInMilliseconds: 3000

为了让Hystrix能够监控我们的服务，我们需要在@SpringBootApplication注解中添加@EnableHystrix注解：

@SpringBootApplication
@EnableDiscoveryClient
@EnableHystrix
public class ConsumerApplication {

    public static void main(String[] args) {
        SpringApplication.run(ConsumerApplication.class, args);
    }
}

Hystrix的指标监控

添加依赖

我们需要在pom.xml文件中添加以下依赖：

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

配置Hystrix监控

在application.yml中添加以下配置：

management:
  endpoints:
    web:
      exposure:
        include: hystrix.stream

启动监控

启动项目后，在浏览器中输入http://localhost:9001/hystrix进入Hystrix监控页面，输入http://localhost:9001/actuator/hystrix.stream作为监控流地址，并点击Monitor Stream按钮，即可查看到服务的监控数据。

示例说明

示例一

在本地启动两个服务，一个是消费者服务，一个是提供者服务，然后向消费者服务发起请求，使其调用提供者服务。在提供者服务返回前，手动关闭提供者服务，观察消费者服务使用Hystrix进行容错处理后返回的结果。

示例二

在本地启动两个服务，一个是消费者服务，一个是提供者服务。然后在提供者服务方法中添加一个延迟操作，使得提供者服务返回的时间变长。观察消费者服务使用Hystrix进行容错处理的效果和延迟时间。