Spring Cloud 熔断降级详解：Sentinel 实战指南

配置文件 application.yml 中开启 Sentinel 并指向控制台地址：

server:
  port: 8080
spring:
  application:
    name: order-service
  cloud:
    sentinel:
      enabled: true
      transport:
        dashboard: localhost:8080
        port: 8719
      web-context-unify: false
management:
  endpoints:
    web:
      exposure:
        include: '*'

注解式开发

在业务代码中使用 @SentinelResource 是最直观的方式。这个注解定义了资源名称以及异常发生时的处理逻辑。

@Service
public class OrderService {

    /**
     * 创建订单接口
     * blockHandler: 限流或熔断时的处理方法
     * fallback: 业务异常时的降级处理方法
     */
    @SentinelResource(
        value = "createOrder",
        blockHandler = "handleBlock",
        fallback = "handleFallback"
    )
    public String createOrder(String productId, Integer count) {
        // 模拟业务逻辑
        if ("error".equals(productId)) {
            throw new RuntimeException("商品不存在");
        }
        return "订单创建成功！";
    }

    /**
     * 限流/熔断处理
     * 注意：方法签名需与原方法一致，最后添加 BlockException 参数
     */
    public String handleBlock(String productId, Integer count, BlockException ex) {
        return "系统繁忙，请稍后再试（限流/熔断）";
    }

    /**
     * 降级处理
     * 注意：方法签名需与原方法一致，最后可添加 Throwable 参数
     */
    public String handleFallback(String productId, Integer count, Throwable ex) {
        return "服务暂时不可用，已启动降级处理";
    }
}

控制器层只需正常注入服务即可，无需额外修改。

动态规则管理

硬编码规则不够灵活，通常我们会通过代码初始化或控制台配置。这里展示如何通过 Java 代码动态加载规则，实际生产中建议结合 Nacos 持久化。

@Configuration
public class SentinelRuleConfig {
    @PostConstruct
    public void initRules() {
        initFlowRules();
        initDegradeRules();
    }

    private void initFlowRules() {
        List<FlowRule> rules = new ArrayList<>();
        FlowRule rule1 = new FlowRule();
        rule1.setResource("createOrder");
        rule1.setGrade(RuleConstant.FLOW_GRADE_QPS);
        rule1.setCount(10); // 每秒最多 10 个请求
        rule1.setStrategy(RuleConstant.STRATEGY_DIRECT);
        rules.add(rule1);
        FlowRuleManager.loadRules(rules);
    }

    private void initDegradeRules() {
        List<DegradeRule> rules = new ArrayList<>();
        DegradeRule rule1 = new DegradeRule();
        rule1.setResource("slowApi");
        rule1.setGrade(RuleConstant.DEGRADE_GRADE_RT);
        rule1.setCount(500); // RT 超过 500ms
        rule1.setTimeWindow(10); // 熔断 10 秒
        rule1.setSlowRatioThreshold(0.5); // 慢调用比例 50%
        rules.add(rule1);
        DegradeRuleManager.loadRules(rules);
    }
}

Feign 集成与降级

在微服务调用中，Feign 客户端同样需要接入 Sentinel。配置开启后，Feign 会自动拦截请求。

feign:
  sentinel:
    enabled: true

@FeignClient(name = "inventory-service", fallback = InventoryServiceFallback.class)
public interface InventoryServiceClient {
    @GetMapping("/deduct")
    String deductStock(@RequestParam("productId") String productId,
                       @RequestParam("count") Integer count);
}

@Component
public class InventoryServiceFallback implements InventoryServiceClient {
    @Override
    public String deductStock(String productId, Integer count) {
        return "库存服务暂时不可用，已为您预留库存";
    }
}

全局异常处理

为了让前端收到统一的错误码，建议统一捕获 Sentinel 抛出的异常。

@RestControllerAdvice
public class GlobalExceptionHandler {
    @ExceptionHandler(BlockException.class)
    public Map<String, Object> handleBlockException(BlockException ex) {
        Map<String, Object> result = new HashMap<>();
        result.put("code", 429);
        result.put("message", "服务限流或熔断，请稍后重试");
        if (ex instanceof FlowException) {
            result.put("type", "限流");
        } else if (ex instanceof DegradeException) {
            result.put("type", "熔断降级");
        }
        return result;
    }
}

测试与验证

压测是检验熔断效果的关键。可以使用 Apache Bench 模拟高并发，观察 Sentinel 控制台的实时数据。

# 压测创建订单接口
ab -n 100 -c 20 http://localhost:8080/order/create?productId=123&count=1

# 访问慢接口测试 RT 熔断
for i in {1..10}; do curl http://localhost:8080/order/slow; done

访问 http://localhost:8080 可以看到 QPS、成功率等指标变化。如果触发熔断，控制台会显示资源进入熔断状态。

生产环境建议

阈值设置参考

不同重要程度的接口，熔断策略应有所区别：

降级策略优先级

1. 返回缓存数据（最新缓存或默认值）
2. 返回友好提示
3. 调用备用服务

public String degradeStrategy() {
    String cached = cache.get(key);
    if (cached != null) {
        return cached;
    }
    return "服务繁忙，请稍后重试";
}

检查清单

• 核心接口配置流控规则
• 依赖服务配置熔断规则
• 所有降级方法经过测试
• 规则持久化到配置中心
• 配置监控告警
• 定期演练故障恢复

总结

熔断降级不是简单的开关，而是保障系统可用性的最后一道防线。合理设置阈值、完善降级策略、做好监控告警，才能让系统在极端情况下依然稳健运行。从非核心接口开始实践，逐步完善核心保护，定期进行故障演练，是提升架构稳定性的必经之路。