Sentinel是阿里巴巴开源的分布式系统流量控制组件，它以流量为切入点，从流量控制、熔断降级、系统负载保护等多个维度来保障微服务的稳定性。本文将详细介绍如何在Spring Boot项目中整合Sentinel并实现QPS(每秒查询率)限流功能。

在微服务架构中，服务限流是保障系统稳定性的重要手段。当系统面临突发流量时，无限制的请求可能导致：

可以精确控制接口的访问频率，当请求量超过设定阈值时，会自动拦截额外请求，防止系统过载。

首先需要下载并启动Sentinel控制台(Dashboard)：

wget https://github.com/alibaba/Sentinel/releases/download/1.8.6/sentinel-dashboard-1.8.6.jar
java -Dserver.port=8080 -Dcsp.sentinel.dashboard.server=localhost:8080 -jar sentinel-dashboard-1.8.6.jar

启动后访问 http://localhost:8080 ，默认账号密码为sentinel/sentinel。

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


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


<dependency>
    <groupId>com.alibaba.csp</groupId>
    <artifactId>sentinel-datasource-nacos</artifactId>
</dependency>

在application.yml中配置Sentinel控制台地址：

spring:
  cloud:
    sentinel:
      transport:
        dashboard: localhost:8080 # Sentinel控制台地址
        port: 8719 # 本地启动的HTTP Server端口
      eager: true # 取消Sentinel控制台懒加载

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.RestController;

@RestController
public class FlowLimitController {
    
    @GetMapping("/test")
    @SentinelResource(value = "testResource", blockHandler = "handleBlock")
    public String test() {
        return "正常访问";
    }
    
    // 限流降级方法
    public String handleBlock(BlockException ex) {
        return "请求过于频繁，请稍后再试";
    }
}

Sentinel默认会将所有HTTP接口自动定义为资源，资源名为URL路径：

@RestController
public class AutoFlowController {
    
    @GetMapping("/auto")
    public String auto() {
        return "自动限流资源";
    }
}

访问该接口后，在Sentinel控制台的"簇点链路"中可以看到

资源，可直接为其配置流控规则。

除了注解方式，还可以通过代码实现限流：

import com.alibaba.csp.sentinel.Entry;
import com.alibaba.csp.sentinel.SphU;
import com.alibaba.csp.sentinel.slots.block.BlockException;

public class Service {
    public void doSomething() throws BlockException {
        Entry entry = null;
        try {
            entry = SphU.entry("doSomething");
            // 业务逻辑
        } catch (BlockException e) {
            // 限流逻辑
        } finally {
            if (entry != null) {
                entry.exit();
            }
        }
    }
}

这种方式更灵活，适合非HTTP接口的限流场景。

可以在应用启动时通过代码配置规则：

import com.alibaba.csp.sentinel.slots.block.RuleConstant;
import com.alibaba.csp.sentinel.slots.block.flow.FlowRule;
import com.alibaba.csp.sentinel.slots.block.flow.FlowRuleManager;
import org.springframework.boot.ApplicationArguments;
import org.springframework.boot.ApplicationRunner;
import org.springframework.stereotype.Component;

import java.util.ArrayList;
import java.util.List;

@Component
public class SentinelRuleConfig implements ApplicationRunner {
    @Override
    public void run(ApplicationArguments args) {
        List<FlowRule> rules = new ArrayList<>();
        FlowRule rule = new FlowRule();
        rule.setResource("testResource"); // 资源名
        rule.setGrade(RuleConstant.FLOW_GRADE_QPS); // 限流阈值类型(QPS)
        rule.setCount(2); // 阈值
        rule.setLimitApp("default"); // 默认来源
        rules.add(rule);
        FlowRuleManager.loadRules(rules);
    }
}

这种方式适合需要动态配置规则的场景。

默认情况下，Sentinel的规则存储在内存中，应用重启后规则会丢失。可以通过Nacos等配置中心实现规则持久化：

spring:
  cloud:
    sentinel:
      datasource:
        ds1:
          nacos:
            server-addr: localhost:8848
            data-id: ${spring.application.name}-flow-rules
            group-id: SENTINEL_GROUP
            rule-type: flow

这样配置后，限流规则会保存在Nacos中，应用重启后规则不会丢失。

在Spring Cloud Gateway中集成Sentinel可以实现网关层限流：

<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-alibaba-sentinel-gateway</artifactId>
</dependency>

@PostConstruct
public void initGatewayRules() {
    Set<GatewayFlowRule> rules = new HashSet<>();
    rules.add(new GatewayFlowRule("user_service_route")
        .setResourceMode(SentinelGatewayConstants.RESOURCE_MODE_ROUTE_ID)
        .setCount(2)
        .setIntervalSec(1));
    GatewayRuleManager.loadRules(rules);
}

这样可以对整个路由进行限流控制。

Sentinel不仅可以限流，还可以实现熔断降级：

@Service
public class UserService {

    @SentinelResource(
        value = "getUserById", 
        blockHandler = "handleBlock",   // 限流/降级处理
        fallback = "handleFallback"      // 异常处理
    )
    public User getUserById(Long id) {
        // 业务逻辑
    }

    // 限流/降级处理逻辑
    public User handleBlock(Long id, BlockException ex) {
        return new User(-1L, "blocked_user", "请求过于频繁，请稍后重试！");
    }

    // 异常处理逻辑
    public User handleFallback(Long id, Throwable t) {
        return new User(-1L, "fallback_user", "服务暂时不可用：" + t.getMessage());
    }
}

可以在Sentinel控制台配置熔断规则，如基于异常比例触发熔断。

创建JMeter测试计划，模拟高并发请求：

# 连续发送请求测试限流
for i in {1..20}; do curl http://localhost:8080/test; echo; done

正常情况会看到部分请求返回"请求过于频繁，请稍后再试"的限流提示。

通过本文的介绍，我们了解了如何在Spring Boot项目中整合Sentinel实现QPS限流。主要步骤包括：

Sentinel提供了丰富的流量控制功能，可以帮助我们构建更加健壮的微服务系统。在实际项目中，可以根据业务需求选择合适的限流策略和配置方式。

通过合理的限流配置，我们可以有效防止系统过载，保障核心业务的稳定性，提升整体系统的可用性和用户体验。

Spring Boot 整合 Sentinel 实现 QPS 限流

先锋会员

后端

架构设计

云计算

本文详细介绍如何在SpringBoot项目中整合阿里Sentinel实现QPS限流，包含环境配置、注解与编程两种实现方式、规则持久化方案及高级配置技巧。通过Sentinel的流量控制功能，可有效防止微服务系统过载，保障核心业务稳定性，提升系统可用性。

微服务架构

数据库

路由

AI驱动 智领未来

tencentdb-catalog

文章

问答

视频

教程

学习中心

腾讯云实验室

直播

竞赛

腾讯云代码分析专区

腾讯iOA零信任安全管理系统专区

腾讯云架构师技术同盟交流圈

腾讯云数据库专区

腾讯云智能顾问专区

腾讯云原生专区

腾讯混元专区

腾讯云TCE专区

腾讯云Lighthouse专区

腾讯云HAI专区

腾讯云Edgeone专区

腾讯云存储专区

腾讯云智能专区

腾讯轻联专区 

腾讯云开发专区

TAPD专区

腾讯轻量云游戏服专区

腾讯云最具价值专家

腾讯云架构师技术同盟

腾讯云创作之星

腾讯云开发者先锋

腾讯云代码助手

云原生构建

TAPD 敏捷项目管理

Cloud Studio

SDK中心

API中心

命令行工具

涵盖代码开发、场景应用、自动测试全流程，助你从零构建专属AI助手

一站式MCP教程库，解锁AI应用新玩法

聚焦“写作效率、视觉美观与运行性能”三方面进行全面升级，为您提供更高效、稳定的创作环境

社区富文本&Markdown编辑器全新改版上线，欢迎大家体验!

诚挚邀请您参与本次调研，分享您的真实使用感受与建议。您的反馈至关重要，感谢您的支持与参与！

Spring Boot 整合 Sentinel 实现 QPS 限流

Spring Boot 整合 Sentinel 实现 QPS 限流

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐