Spring Cloud Sentinel 熔断降级实战：原理与配置详解

2. 配置文件

在 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
      block-handler: com.example.handler.BlockExceptionHandler
      fallback: com.example.handler.FallbackExceptionHandler

代码实战：注解方式集成

3. 业务服务实现

使用 @SentinelResource 注解标记需要保护的资源。注意区分 blockHandler（限流/熔断处理）和 fallback（降级处理）。

@Service
public class OrderService {

    /**
     * 创建订单接口
     * value: 资源名称，唯一标识
     * blockHandler: 限流/熔断时的处理方法
     * fallback: 降级时的处理方法
     */
    @SentinelResource(
        value = "createOrder",
        blockHandler = "handleBlock",
        fallback = "handleFallback"
    )
    public String createOrder(String productId, Integer count) {
        // 模拟业务逻辑
        System.out.println("创建订单：商品 ID=" + productId + ", 数量=" + 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 "服务暂时不可用，已启动降级处理";
    }
}

4. 控制器层

@RestController
@RequestMapping("/order")
public class OrderController {

    @Autowired
    private OrderService orderService;

    @PostMapping("/create")
    public String createOrder(@RequestParam String productId, @RequestParam Integer count) {
        return orderService.createOrder(productId, count);
    }

    /**
     * 测试接口：模拟慢调用（用于测试 RT 熔断）
     */
    @GetMapping("/slow")
    @SentinelResource(value = "slowApi", blockHandler = "handleBlock")
    public String slowApi() throws InterruptedException {
        Thread.sleep(1000); // 模拟慢调用
        return "正常响应";
    }

    public String handleBlock(BlockException ex) {
        return "接口响应太慢，已触发熔断";
    }
}

高级规则配置

5. 动态规则定义

除了注解配置，我们也可以通过代码动态加载规则，或者持久化到 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); // 响应时间超过 500ms 视为慢调用
        rule1.setTimeWindow(10); // 熔断时长 10 秒
        rule1.setMinRequestAmount(5);
        rule1.setSlowRatioThreshold(0.5); // 慢调用比例阈值 50%
        rules.add(rule1);
        DegradeRuleManager.loadRules(rules);
    }
}

6. OpenFeign 集成

若使用 Feign 调用远程服务，需在配置文件中开启 Sentinel 支持：

feign:
  sentinel:
    enabled: true

并在 Feign Client 中指定 fallback 类：

@FeignClient(name = "inventory-service", path = "/inventory", 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 "库存服务暂时不可用，已为您预留库存";
    }
}

7. 规则持久化至 Nacos

生产环境中建议将规则持久化，避免重启丢失。

Nacos 配置示例：

[
  {
    "resource": "createOrder",
    "limitApp": "default",
    "grade": 1,
    "count": 10,
    "strategy": 0,
    "controlBehavior": 0,
    "clusterMode": false
  }
]

全局异常处理

统一捕获 Sentinel 抛出的异常，返回友好的 JSON 格式：

@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;
    }
}

测试验证

压测场景

1. 流控测试：使用 Apache Bench 发送高频请求。

   ab -n 100 -c 20 http://localhost:8080/order/create?productId=123&count=1
   

2. 熔断测试：多次访问慢接口或异常接口，观察控制台变化。

控制台观察

访问 Sentinel 控制台（默认端口 8080），查看实时 QPS、RT 曲线及规则生效情况。

最佳实践建议

1. 阈值设置：核心接口建议 RT 阈值 1s，异常比例 30%；非核心接口可适当放宽。
2. 降级策略：优先返回缓存数据，其次返回默认值，最后返回友好提示。
3. 监控告警：结合 Prometheus 或钉钉机器人，对熔断次数进行告警通知。
4. 生产检查：确保所有降级方法经过测试，规则已持久化，定期演练故障恢复。

总结

熔断降级是微服务高可用的基石。通过 Sentinel，我们可以灵活地定义资源保护策略，在故障发生时快速止损。合理配置阈值、完善降级逻辑、做好监控告警，能让系统在极端情况下依然保持韧性。