【Spring Cloud 六】Hystrix熔断

在Spring Cloud中，Hystrix是一个提供熔断器功能的库，用于防止系统雪崩，当一个服务依赖的服务出现故障时，通过熔断器的故障监控，向调用方返回一个错误响应，而不是长时间等待或者尝试重试。

以下是一个简单的使用Hystrix熔断器的例子：

1. 首先，在Spring Cloud项目中添加Hystrix依赖：

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

2. 在启动类上添加@EnableCircuitBreaker注解来启用Hystrix：

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
 
@SpringBootApplication
@EnableCircuitBreaker
@EnableDiscoveryClient
public class MyServiceApplication {
 
    public static void main(String[] args) {
        SpringApplication.run(MyServiceApplication.class, args);
    }
}

3. 使用@HystrixCommand注解定义熔断逻辑：

import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;
 
@RestController
public class MyController {
 
    @Autowired
    private RestTemplate restTemplate;
 
    @GetMapping("/service-a")
    @HystrixCommand(fallbackMethod = "fallbackMethod")
    public String serviceA() {
        return restTemplate.getForObject("http://SERVICE-A/service-a", String.class);
    }
 
    public String fallbackMethod() {
        return "Service A is not available";
    }
}

在上面的例子中，当调用serviceA()方法时，会尝试调用服务A。如果服务A不可用，Hystrix会执行定义的fallback方法fallbackMethod()，而不是等待服务A的响应。这样可以防止雪崩效应，保护系统的整体可用性。