当前位置：首页>java>3种方式玩转Sentinel:代码、注解、控制台实战一篇就够

3种方式玩转Sentinel:代码、注解、控制台实战一篇就够

  • 2026-10-21 13:28:19
3种方式玩转Sentinel:代码、注解、控制台实战一篇就够

如果觉得这篇文章对你有帮助，欢迎点赞、在看、转发支持一下，也欢迎关注我，后续会持续分享更多关于高并发、分布式、架构设计等实战干货。！ 🚀

在微服务架构中，如何防止突发流量冲垮服务？如何优雅地应对下游服务不稳定？
Sentinel 正是为此而生。作为阿里巴巴开源的流量治理组件，它提供了流量控制、熔断降级和系统保护等核心能力，是保障系统稳定性的利器。
本文将以 Spring Boot 项目为例，手把手带你掌握 Sentinel 的三大核心用法：

  • 代码定义：通过 SphU.entry定义资源和限流规则。

  • 注解定义：使用 @SentinelResource定义资源、降级及异常处理。

  • 控制台集成：接入 Sentinel Dashboard，实现规则的动态配置与实时监控。

🚀 快速上手：引入 Sentinel
首先，在 pom.xml中引入 Spring Cloud Alibaba Sentinel 的依赖。
xml<dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-sentinel</artifactId></dependency>
然后，在 application.yml中配置应用名和控制台地址。
spring:  application:    name: sentinel-democloud:  sentinel:    transport:      dashboard: localhost:8080 # Sentinel 控制台地址      port: 8719              # 与控制台通信的端口
注意：Sentinel 采用懒加载机制。应用启动后，需至少访问一次被 Sentinel 保护的接口（即触发了 SphU.entry或@SentinelResource的方法），客户端才会将该资源注册到控制台并开始上报数据。
💻 代码方式：定义资源与规则
这种方式不依赖 Spring 注解，通过原生 API 手动埋点，适合对灵活性和性能有极致要求的场景。
  1. 定义资源
使用 SphU.entry("资源名")来定义一个受保护的资源。请求进入时调用entry，正常执行 try块内的业务逻辑；若被限流或熔断，则会抛出 BlockException，进入 catch块执行降级逻辑。
// 常量类，统一管理资源名public class Constants {    public static final String HELLO_CODE = "helloCode";}// Sentinel 资源控制器@RestController@RequestMapping("/code")public class CodeResource {    @GetMapping("/hello")    public String hello() {        Entry entry = null; // 必须在try外声明，以便在finally中访问        try {            entry = SphU.entry(Constants.HELLO_CODE_RESOURCE);            // 业务代码：模拟耗时操作            TimeUnit.MILLISECONDS.sleep(10);            return "hello from code";        } catch (BlockException e) {            // 降级逻辑：被限流或熔断时执行            return "系统繁忙，请稍后再试（code）";        } catch (InterruptedException ie) {            Thread.currentThread().interrupt();            log.warn("请求处理被中断", ie);            return "请求被中断";        } finally {            if (entry != null) {                entry.exit(); // 务必在finally中exit            }        }    }}
2. 定义限流规则
在应用启动时，通过 FlowRuleManager.loadRules()方法加载限流规则。以下示例配置资源 helloCode的 QPS（每秒查询率）阈值为 2。
@Configurationpublic class SentinelConfig {@PostConstructpublic void initFlowRules() {    FlowRule rule = new FlowRule();    rule.setResource(RESOURCE_NAME);           // 资源名，需与 SphU.entry 中一致    rule.setGrade(RuleConstant.FLOW_GRADE_QPS); // 限流阈值类型：QPS    rule.setCount(2);                          // 阈值：每秒最多 2 次请求    FlowRuleManager.loadRules(Collections.singletonList(rule));}}
规则参数说明：

  • resource: 要保护的资源名称。

  • grade: 阈值类型，FLOW_GRADE_QPS(1) 表示按 QPS 限流，FLOW_GRADE_THREAD(0) 表示按并发线程数限流。

  • count: 具体的阈值，如 QPS 为 2 表示每秒最多通过 2 个请求。

配置完成后，快速访问http://localhost:8080/code/hello，当 QPS 超过 2 时，页面将返回降级信息。
✍️ 注解方式：定义资源与降级
对于 Spring 项目，@SentinelResource注解是更优雅的选择，它能将方法标记为一个 Sentinel 资源，并支持自定义限流和降级处理逻辑。
  1. 基本用法
使用@SentinelResource注解标记方法，并通过 blockHandler属性指定限流/降级时执行的方法。
@Servicepublic class AnnotationService {public static final String RESOURCE_NAME = "helloAnno";@SentinelResource(value = RESOURCE_NAME, blockHandler = "handleBlock")public String hello(String name) {    // 模拟业务异常    if ("error".equals(name)) {        throw new RuntimeException("业务出错了");    }    return "hello " + name + " (anno)";}// 注意：降级方法必须与原方法在同一个类中，参数和返回值类型需一致，最后增加一个 BlockException 参数public String handleBlock(String name, BlockException ex) {    return "请求被限流/降级了（anno），name=" + name;}}
在 Controller 中注入并调用该 Service 即可。
@RestController@RequestMapping("/anno")public class AnnotationController {@Autowiredprivate AnnotationService annotationService;@GetMapping("/hello")public String hello(@RequestParam(defaultValue = "sentinel") String name) {    return annotationService.hello(name);}}
2. 区分业务异常与限流
@SentinelResource还提供了 fallback属性，专门用于处理业务异常，与 blockHandler处理流控/熔断的场景区分开。
@SentinelResource(value = "helloFallback",blockHandler = "handleBlock",fallback = "handleFallback")public String helloFallback(String name) {if ("error".equals(name)) {throw new RuntimeException("业务出错了");}if ("slow".equals(name)) {try { Thread.sleep(200); } catch (InterruptedException e) {}}return "hello " + name + " (fallback)";}// 处理业务异常public String handleFallback(String name, Throwable t) {return "业务异常被捕获：" + t.getMessage();}// 处理限流/熔断public String handleBlock(String name, BlockException ex) {return "请求被限流/降级了（fallback），name=" + name;}
核心区别：

  • blockHandler: 仅在触发限流、熔断、系统保护时执行。

  • fallback: 在业务方法抛出非 BlockException异常时执行，用于业务异常处理。

🖥️ 控制台集成：动态配置与监控
通过引入 sentinel-transport-simple-http依赖并配置 dashboard地址，即可将应用接入 Sentinel 控制台，实现规则的动态管理和实时监控。
  1. 启动控制台
从 Sentinel GitHub Releases 页面下载 sentinel-dashboard.jar并启动。
bash
使用默认端口 8080，账号密码均为 sentinel
java -jar sentinel-dashboard.jar
自定义端口和账号密码
java -Dserver.port=18080 \-Dsentinel.dashboard.auth.username=sentinel \-Dsentinel.dashboard.auth.password=123456 \-jar sentinel-dashboard.jar
访问http://localhost:18080即可登录。
2. 应用接入与规则配置
确保项目中已引入 spring-cloud-starter-alibaba-sentinel并配置了 dashboard地址。启动应用后访问一次其接口，Sentinel 客户端便会自动注册到控制台。
在控制台的 “簇点链路” 菜单中，可以找到所有可配置的接口资源（如/code/hello, /anno/hello）。
点击对应资源右侧的 “+流控” 按钮，即可通过图形化界面配置规则，例如设置 QPS 阈值为 1。
配置完成后，再次快速访问接口，即可在控制台实时看到通过的 QPS 和被拒绝的 QPS 数据，直观地验证限流效果。
💡 总结与实践
本文介绍了 Sentinel 的三种核心用法，它们并非互斥，而是可以根据场景灵活组合：

  • 代码方式 (SphU.entry): 适用于对性能要求极高、需要完全自定义埋点的场景。

  • 注解方式 (@SentinelResource): 适用于大多数 Spring 项目，开发效率高，与业务代码解耦。

  • 控制台方式: 用于规则的动态管理、实时监控和快速验证，是生产环境的标配。

本文来自网友投稿或网络内容，如有侵犯您的权益请联系我们删除，联系邮箱：596563534@qq.com 。

零代码基础适用!7个步骤,教你一天之内用AI辅助完成高质量标书,并且绘制顶刊级别的插图

限制性立方样图条R代码及解释

最新文章

随机文章