当前位置：首页 > news >正文

SpringCloud Alibaba Sentinel 限流+熔断完整实战教程

news 2026/6/23 16:13:23

一、前言

在微服务架构中，流量突增、下游服务超时、报错雪崩是线上最常见的稳定性问题。Sentinel作为阿里开源、经过双11大促打磨的流量防护组件，相比 Hystrix 更轻量、功能更强、配置更灵活，是目前国内微服务限流、熔断、降级的主流方案。

本文带来零残缺、可直接运行、可上线的 Sentinel 完整实战案例，包含：

完整 Maven 依赖

全量 YAML 配置

限流 + 熔断双功能代码实现

blockHandler / fallback 精准区分（面试高频）

代码硬编码规则 + 控制台动态规则两种方式

OpenFeign 跨服务调用限流熔断识别实战

全套线上测试场景 & 问题总结

二、核心核心概念

1. 兜底方法区别

blockHandler：Sentinel 框架拦截异常，只处理限流、熔断、系统保护、黑白名单拦截触发的BlockException。

fallback：捕获业务代码所有异常，包含空指针、自定义异常、接口报错等业务异常。

2. 核心能力

限流：QPS 限流、并发线程限流、链路限流、热点参数限流

熔断：慢调用比例、异常比例、异常数三种熔断策略

降级：故障自动隔离，避免服务雪崩

系统防护：整机 CPU、负载、QPS 全局保护

三、环境与依赖

适配版本：SpringBoot 2.7.x + SpringCloud Alibaba 2021.0.1.0（稳定生产版本）

完整 pom.xml 依赖

xml
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.7.15</version>
<relativePath/>
</parent>

<dependencies>

<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>


<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
<version>2021.0.1.0</version>
</dependency>


<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
<version>2021.0.1.0</version>
</dependency>


<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>
</dependencies>

四、项目配置文件 application.yml

配置控制台地址、开启服务预热初始化，适配开发、生产环境

yaml
server:
port: 8080

spring:
application:
name: sentinel-demo-service
cloud:
sentinel:
# Sentinel 控制台地址
transport:
dashboard: 127.0.0.1:8085
port: 8719
# 关闭懒加载，项目启动直接初始化Sentinel
eager: true
nacos:
config:
server-addr: 127.0.0.1:8848

# 开启feign对sentinel的支持
feign:
sentinel:
enabled: true

五、启动类

java
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.openfeign.EnableFeignClients;

@SpringBootApplication
@EnableFeignClients
public class SentinelDemoApplication {
public static void main(String[] args) {
SpringApplication.run(SentinelDemoApplication.class, args);
}
}

六、核心业务代码（限流+熔断+双兜底完整实现）

统一资源名，区分限流熔断兜底、业务异常兜底，代码完全解耦，符合生产规范。

java
import com.alibaba.csp.sentinel.annotation.SentinelResource;
import com.alibaba.csp.sentinel.slots.block.BlockException;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class OrderController {

/**
* Sentinel 资源名：createOrder
* blockHandler：限流、熔断、系统保护、授权拦截兜底（Sentinel 框架异常）
* fallback：业务代码异常兜底（代码报错、自定义异常等）
*/
@GetMapping("/order/create/{goodsId}")
@SentinelResource(
value = "createOrder",
blockHandler = "blockHandlerCreateOrder",
fallback = "fallbackCreateOrder"
)
public String createOrder(@PathVariable Long goodsId) {
// 模拟业务异常场景：商品999无库存
if (goodsId == 999) {
throw new RuntimeException("商品库存不足，下单失败");
}

// 模拟慢接口（用于测试慢调用比例熔断）
try {
Thread.sleep(300);
} catch (InterruptedException e) {
throw new RuntimeException(e);
}

return "下单成功，商品ID：" + goodsId;
}

/**
* 限流、熔断兜底方法
* 规则：参数与原方法一致，最后追加 BlockException
*/
public String blockHandlerCreateOrder(Long goodsId, BlockException ex) {
// 区分限流、熔断异常，返回精准提示
if (ex instanceof com.alibaba.csp.sentinel.slots.block.flow.FlowException) {
return "【限流兜底】当前下单人数过多，请稍后重试";
} else if (ex instanceof com.alibaba.csp.sentinel.slots.block.degrade.DegradeException) {
return "【熔断兜底】服务暂时繁忙，已开启熔断保护，请稍后重试";
} else {
return "【服务防护拦截】请求被限制：" + ex.getClass().getSimpleName();
}
}

/**
* 业务异常兜底方法
* 捕获所有业务代码异常
*/
public String fallbackCreateOrder(Long goodsId, Throwable throwable) {
return "【业务异常兜底】商品" + goodsId + "下单失败：" + throwable.getMessage();
}
}

七、全局异常处理器（生产核心：返回429/503标准状态码）

这是跨服务调用能识别限流/熔断的关键：

1. 限流异常FlowException→ 返回 HTTP 429

2. 熔断异常DegradeException→ 返回 HTTP 503
上游 A 服务可通过状态码精准区分「下游限流」还是「下游熔断」

java
import com.alibaba.csp.sentinel.slots.block.BlockException;
import com.alibaba.csp.sentinel.slots.block.degrade.DegradeException;
import com.alibaba.csp.sentinel.slots.block.flow.FlowException;
import org.springframework.http.HttpStatus;
import org.springframework.web.bind.annotation.ExceptionHandler;
import org.springframework.web.bind.annotation.ResponseStatus;
import org.springframework.web.bind.annotation.RestControllerAdvice;

@RestControllerAdvice
public class SentinelGlobalExceptionHandler {

/**
* 下游触发限流：429 Too Many Requests
*/
@ExceptionHandler(FlowException.class)
@ResponseStatus(HttpStatus.TOO_MANY_REQUESTS)
public String handleFlowException(FlowException e) {
return "下游服务触发限流：请求过于频繁，请稍后重试";
}

/**
* 下游触发熔断：503 Service Unavailable
*/
@ExceptionHandler(DegradeException.class)
@ResponseStatus(HttpStatus.SERVICE_UNAVAILABLE)
public String handleDegradeException(DegradeException e) {
return "下游服务触发熔断：服务暂时不可用，已开启故障隔离";
}

/**
* 通用Sentinel拦截异常
*/
@ExceptionHandler(BlockException.class)
@ResponseStatus(HttpStatus.BAD_REQUEST)
public String handleBlockException(BlockException e) {
return "服务流量拦截：" + e.getMessage();
}
}

八、OpenFeign 跨服务调用（A服务调用B服务，精准识别限流/熔断）

场景说明

微服务最经典场景：A服务 OpenFeign 调用 B服务
B服务接口被 Sentinel 限流/熔断后，抛出对应异常，经过全局异常处理器返回标准 HTTP 状态码，A服务可精准捕获、区分限流/熔断/普通报错，做差异化降级策略。

1. Feign客户端定义（A服务）

java
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;

@FeignClient(name = "sentinel-demo-service")
public interface BOrderFeignClient {

@GetMapping("/order/create/{goodsId}")
String createOrder(@PathVariable("goodsId") Long goodsId);
}

2. A服务调用代码（核心：区分429限流 / 503熔断）

java
import feign.FeignException;
import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;

@Slf4j
@RestController
public class AInvokeBController {

@Resource
private BOrderFeignClient bOrderFeignClient;

@GetMapping("/a/call/b/{goodsId}")
public String aCallB(@PathVariable Long goodsId) {
try {
// A服务远程调用B服务带Sentinel防护的接口
return bOrderFeignClient.createOrder(goodsId);
} catch (FeignException e) {
// 通过HTTP状态码精准区分下游异常类型
int status = e.status();
if (status == 429) {
// 下游B服务触发限流
log.warn("【跨服务降级】B服务接口限流，goodsId:{}", goodsId);
return "系统繁忙，当前访问人数过多，请稍后重试（限流降级）";
} else if (status == 503) {
// 下游B服务触发熔断
log.error("【跨服务熔断】B服务接口熔断，服务暂时不可用，goodsId:{}", goodsId);
return "服务暂时异常，已开启熔断保护，请稍后重试（熔断降级）";
} else {
// 其他业务异常
log.error("【远程调用异常】未知错误:{}", e.getMessage());
return "服务调用异常，请稍后重试";
}
}
}
}

九、规则配置方式一：代码硬编码（快速测试）

无需控制台，项目启动自动加载限流、熔断规则，适合单元测试、快速验证场景。

java
import com.alibaba.csp.sentinel.slots.block.RuleConstant;
import com.alibaba.csp.sentinel.slots.block.degrade.DegradeRule;
import com.alibaba.csp.sentinel.slots.block.degrade.DegradeRuleManager;
import com.alibaba.csp.sentinel.slots.block.flow.FlowRule;
import com.alibaba.csp.sentinel.slots.block.flow.FlowRuleManager;
import org.springframework.context.annotation.Configuration;

import javax.annotation.PostConstruct;
import java.util.ArrayList;
import java.util.List;

@Configuration
public class SentinelRuleConfig {

// 与接口资源名保持一致
private static final String RESOURCE = "createOrder";

@PostConstruct
public void initSentinelRule() {
// 1. 限流规则：QPS单机阈值2，每秒最多2次请求
List<FlowRule> flowRuleList = new ArrayList<>();
FlowRule flowRule = new FlowRule();
flowRule.setResource(RESOURCE);
// 限流维度：QPS
flowRule.setGrade(RuleConstant.FLOW_GRADE_QPS);
// 阈值
flowRule.setCount(2);
// 流控效果：快速失败
flowRule.setControlBehavior(RuleConstant.CONTROL_BEHAVIOR_DEFAULT);
flowRuleList.add(flowRule);
FlowRuleManager.loadRules(flowRuleList);

// 2. 熔断规则：慢调用比例熔断
List<DegradeRule> degradeRuleList = new ArrayList<>();
DegradeRule degradeRule = new DegradeRule();
degradeRule.setResource(RESOURCE);
// 熔断策略：慢调用RT
degradeRule.setGrade(RuleConstant.DEGRADE_GRADE_RT);
// 超过250ms判定为慢调用
degradeRule.setCount(250);
// 慢调用比例超过50%触发熔断
degradeRule.setSlowRatioThreshold(0.5);
// 最小统计请求数
degradeRule.setMinRequestAmount(5);
// 熔断窗口期5秒，期间直接降级
degradeRule.setTimeWindow(5);
degradeRuleList.add(degradeRule);
DegradeRuleManager.loadRules(degradeRuleList);
}
}