Sentinel ParamFlowRule未生效原因及修复方案咨询

1. 参数限流规则缺少核心配置：使用ParamFlowRule（参数/热点限流规则）时，必须指定paramIdx属性标记限流维度，原代码未配置该属性，Sentinel无法识别要针对哪个参数做限流，直接导致规则失效。
2. 限流指标类型不匹配：原规则使用FLOW_GRADE_QPS（QPS限流），但需求是「86400秒内最多2次请求」，属于总调用次数限流，应使用FLOW_GRADE_COUNT指标。
3. 未传入真实用户标识：调用SphU.entry时传入固定值1，而非实际用户ID，无法实现按用户维度的区分限流。
4. 无效配置参数：durationInSec仅在集群参数限流场景下生效，单机参数限流的时间窗口默认由Sentinel控制，原配置的86400秒不会起作用。

步骤1：修正限流规则配置 #

修改RateLimitInit类的规则初始化逻辑，补充参数索引、切换限流指标，并配置天级时间窗口：

@Component
public class RateLimitInit implements ApplicationRunner {
    @Override
    public void run(ApplicationArguments args) {
        rateLimitImpl();
    }

    private void rateLimitImpl(){
        List<ParamFlowRule> paramFlowRules = new ArrayList<>();
        ParamFlowRule ruleAsk = new ParamFlowRule();
        ruleAsk.setResource("ChatGPT-ask-per-user");
        // 切换为总调用次数限流
        ruleAsk.setGrade(RuleConstant.FLOW_GRADE_COUNT);
        // 每个用户每天最多2次请求
        ruleAsk.setCount(2);
        // 指定限流参数索引：对应SphU.entry中第1个自定义参数的索引（从0开始）
        ruleAsk.setParamIdx(0);
        
        // 配置天级时间窗口，通过ClusterFlowConfig实现单机场景的自定义窗口
        ClusterFlowConfig clusterFlowConfig = new ClusterFlowConfig();
        clusterFlowConfig.setDurationInSec(86400);
        clusterFlowConfig.setThresholdType(ClusterFlowConfig.THRESHOLD_TYPE_GLOBAL);
        ruleAsk.setClusterFlowConfig(clusterFlowConfig);
        
        paramFlowRules.add(ruleAsk);
        ParamFlowRuleManager.loadRules(paramFlowRules);
    }
}

步骤2：修改控制器代码，传入用户标识 #

在接口中获取真实用户ID（从请求头、Token等渠道），并作为参数传入Sentinel的entry方法：

@RestController
@RequestMapping("/user")
@Api
@Slf4j
public class DemoController {

    @GetMapping("/chat")
    @ApiOperation(value = "用户聊天接口", tags = "customer")
    void chat(HttpServletRequest request){
        // 实际场景从请求头/Token解析用户ID，此处模拟获取
        String userId = request.getHeader("X-User-Id");
        if (userId == null) {
            userId = "anonymous";
        }
        
        Entry entry = null;
        try {
            // 传入用户ID作为限流参数，对应规则中的paramIdx=0
            entry = SphU.entry("ChatGPT-ask-per-user", EntryType.IN, 1, userId);
            System.out.println("正常处理请求");
        } catch (BlockException ex) {
            log.error("用户{}触发限流，今日请求次数已达上限", userId, ex);
        } finally {
            if (entry != null) {
                // exit需传入与entry一致的参数，保证统计准确
                entry.exit(1, userId);
            }
        }
    }
}

步骤3：确认依赖完整性 #

确保项目引入Sentinel核心与Spring Boot整合依赖：

<dependency>
    <groupId>com.alibaba.csp</groupId>
    <artifactId>sentinel-core</artifactId>
    <version>1.8.6</version>
</dependency>
<dependency>
    <groupId>com.alibaba.csp</groupId>
    <artifactId>sentinel-spring-boot-starter</artifactId>
    <version>1.8.6</version>
</dependency>

• paramIdx对应SphU.entry方法中第4个及之后参数的索引（第4个参数为第一个自定义参数，索引从0开始）。
• 使用FLOW_GRADE_COUNT时，count代表指定时间窗口内的最大调用次数，结合clusterFlowConfig.durationInSec可自定义窗口长度。
• entry与exit传入的参数必须一致，否则会导致Sentinel统计异常。

内容的提问来源于stack exchange，提问作者Dolphin