SpringCloud Hystrix 服务熔断与降级详解

3. 优化：默认降级策略

如果每个方法都单独配置 fallbackMethod，代码会显得冗余。可以使用 @DefaultProperties 为整个 Controller 设置全局默认降级方法。

package com.study.controller;

import com.netflix.hystrix.contrib.javanica.annotation.DefaultProperties;
import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;

@RestController
@DefaultProperties(defaultFallback = "defaultFallback")
public class HystrixController {

    @GetMapping("/hystrix/demo01/{id}")
    @HystrixCommand
    public String paymentInfo_TimeOut(@PathVariable("id") String id) {
        // 若此处报错且未指定 fallbackMethod，将自动调用 defaultFallback
        throw new RuntimeException("模拟异常");
    }

    public String defaultFallback(String id) {
        return "全局默认降级响应：id=" + id;
    }
}

进阶：服务端限流与 Feign 集成

1. 服务端限流配置

在被调用的服务端（如商品服务），同样可以配置 Hystrix 来限制并发或超时。这能防止外部流量冲垮内部服务。

package com.study.comtroller; // 注意包名修正

import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
import com.netflix.hystrix.contrib.javanica.annotation.HystrixProperty;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.concurrent.TimeUnit;

@RestController
public class ProductsController {
    @GetMapping("/products/timeOut")
    @HystrixCommand(
            fallbackMethod = "timeoutHandler",
            commandProperties = {
                @HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds", value = "1000")
            }
    )
    public String timeout() {
        try {
            TimeUnit.MILLISECONDS.sleep(3000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        return "成功";
    }

    public String timeoutHandler() {
        return "调用超时";
    }
}

2. Feign 远程调用熔断

在使用 OpenFeign 进行服务间调用时，可以通过 fallback 属性指定降级类。这样即使网络波动或服务不可用，也能优雅地返回提示。

package com.study.fegin;

import com.study.hystrix.PaymentFallbackService;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;

@FeignClient(value = "PRODUCTS9981", fallback = PaymentFallbackService.class)
public interface ProductClient {
    @GetMapping("/products/timeOut")
    String paymentInfo_TimeOut();

    @GetMapping("/products/calculate")
    String calculate(@RequestParam("productId") Integer productId);
}

对应的降级实现类：

package com.study.hystrix;

import com.study.fegin.ProductClient;
import org.springframework.stereotype.Component;

@Component
public class PaymentFallbackService implements ProductClient {
    @Override
    public String paymentInfo_TimeOut() {
        return "======== 请求超时 =======";
    }

    @Override
    public String calculate(Integer productId) {
        return "======== 计算异常 =======";
    }
}

服务熔断机制深度实践

熔断不仅仅是降级，它更强调对故障状态的监控和自动恢复。在 Spring Cloud 中，我们可以通过配置 commandProperties 精细控制熔断行为。

@GetMapping("/hystrix/paymentCircuitBreaker/{id}")
@HystrixCommand(fallbackMethod = "paymentCircuitBreaker_fallback", commandProperties = {
    @HystrixProperty(name = "circuitBreaker.enabled", value = "true"),
    @HystrixProperty(name = "circuitBreaker.requestVolumeThreshold", value = "10"),
    @HystrixProperty(name = "circuitBreaker.sleepWindowInMilliseconds", value = "10000"),
    @HystrixProperty(name = "circuitBreaker.errorThresholdPercentage", value = "60")
})
public String paymentCircuitBreaker(@PathVariable("id") Integer id) {
    if (id < 0) {
        throw new RuntimeException("id 不能为负数");
    }
    return "调用成功";
}

public String paymentCircuitBreaker_fallback(@PathVariable("id") Integer id) {
    return "id 无效，请稍后再试";
}

参数解读：

• requestVolumeThreshold: 最小请求数，达到此数量才统计错误率。
• sleepWindowInMilliseconds: 熔断后的休眠时间，期间不发起请求。
• errorThresholdPercentage: 错误率阈值，超过则熔断。

通过合理配置这些参数，我们可以在保护系统的同时，尽量减少误判带来的影响，确保微服务架构既健壮又灵活。