Spring Cloud - 熔断（Hystrix）

在Spring Cloud中，Hystrix是一个用于处理分布式系统的延迟和容错的库，可以防止系统间的级联故障，提高系统的弹性。

以下是一个使用Hystrix的简单示例：

1. 首先，在Spring Cloud项目的pom.xml中添加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 MyApp {
    public static void main(String[] args) {
        SpringApplication.run(MyApp.class, args);
    }
}

3. 使用HystrixCommand包装可能失败或者执行时间过长的调用：

import com.netflix.hystrix.HystrixCommand;
import com.netflix.hystrix.HystrixCommandGroupKey;
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 ServiceController {
 
    @Autowired
    private RestTemplate restTemplate;
 
    @GetMapping("/service")
    public String service() {
        return new HystrixCommand<String>(HystrixCommandGroupKey.Factory.asKey("ServiceCommand")) {
            @Override
            protected String run() throws Exception {
                return restTemplate.getForObject("http://service-provider/provider", String.class);
            }
 
            @Override
            protected String getFallback() {
                return "Service is unavailable";
            }
        }.execute();
    }
}

在这个例子中，我们创建了一个HystrixCommand，它会调用service-provider服务的/provider端点。如果调用失败，它将执行回退逻辑，返回"Service is unavailable"。