1024程序员节特辑 | 解密Spring Cloud Hystrix熔断提高系统的可用性和容错能力

import com.netflix.hystrix.HystrixCommand;
import com.netflix.hystrix.HystrixCommandGroupKey;
import com.netflix.hystrix.HystrixCommandProperties;
import org.springframework.cloud.client.ServiceInstance;
import org.springframework.cloud.client.discovery.DiscoveryClient;
 
// 以下代码示例展示了如何使用Hystrix命令模式封装服务调用，以及如何设置熔断器的策略。
public class ServiceCallCommand extends HystrixCommand<String> {
    private final DiscoveryClient discoveryClient;
    private final RestTemplate restTemplate;
    private final String serviceId;
    private final Object... args;
 
    public ServiceCallCommand(DiscoveryClient discoveryClient, RestTemplate restTemplate, String serviceId, Object... args) {
        super(Setter.withGroupKey(HystrixCommandGroupKey.Factory.asKey("ServiceCallGroup"))
                .andCommandPropertiesDefaults(
                        HystrixCommandProperties.Setter()
                                .withCircuitBreakerRequestVolumeThreshold(10) // 在10秒内至少有10个请求才进行熔断判断
                                .withCircuitBreakerSleepWindowInMilliseconds(5000) // 5秒钟的时间窗口，断路器关闭后过了这个时间窗口才重新尝试请求
                                .withCircuitBreakerErrorThresholdPercentage(50) // 错误率达到50%后触发熔断
                                .withExecutionTimeoutInMilliseconds(1000) // 设置命令执行超时时间
                ));
        this.discoveryClient = discoveryClient;
        this.restTemplate = restTemplate;
        this.serviceId = serviceId;
        this.args = args;
    }
 
    @Override
    protected String run() throws Exception {
        ServiceInstance instance = discoveryClient.getInstances(serviceId).get(0);
        String url = String.format("http://%s:%s/%s", instance.getHost(), instance.getPort(), String.format(serviceId, args));
        return restTemplate.getForObject(url, String.class);
    }
 
    @Override
    protected String getFallback() {
        // 返回一个备用响应，当服务调用失败时使用
        return "Service is unavailable, please try again later.";
    }
}

这段代码示例展示了如何使用Hystrix的Setter来配置熔断器的策略，包括请求量阈值、错误率阈值、超时时间以及断路器开启后的休眠时间窗口。同时，它提供了一个简单的服务调用方法，并定义了熔断发生时的备用响应。这些策略可以帮助提高系统的可用性和容错能力。