ParamFlowRuleManager update NPE | 热点参数中包含未被@Sentin

当热点参数中包含未被@SentinelResource注解标记的资源时,如果修改这个资源会包空指针异常,表现出来最大的问题就是,显示修改成功,但是热点参数的值还是显示原来的值,但是实际上这个值在后面持久化的逻辑中已经被生效了,内存里却未生效,如果热点参数规则列表中只要包含一个未被标记的资源,修改所有的规则都会出现这种问题

根源是下面代码中这个for循环:

com.alibaba.csp.sentinel.slots.block.flow.param.ParamFlowRuleManager.RulePropertyListener#aggregateAndPrepareParamRules:

     private Map<String, List<ParamFlowRule>> aggregateAndPrepareParamRules(List<ParamFlowRule> list) {
        ...
        for (Map.Entry<String, List<ParamFlowRule>> entry : PARAM_FLOW_RULES.entrySet()) {
            ...
            for (ParamFlowRule rule : oldRuleList) {
                 // 未被标记的资源 调用 getParamMetricForResource 方法返回null
                ParameterMetricStorage.getParamMetricForResource(resource).clearForRule(rule);
            }
        }
        return newRuleMap;
    }

原提问者GitHub用户zc521106

展开
收起
学习娃 2023-05-19 15:05:46 114 分享 版权
1 条回答
写回答
取消 提交回答
  • Sentinel/sentinel-extension/sentinel-parameter-flow-control/src/main/java/com/alibaba/csp/sentinel/slots/block/flow/param/ParamFlowRuleManager.java

    Lines 121 to 150 in 436a885

     private Map<String, List<ParamFlowRule>> aggregateAndPrepareParamRules(List<ParamFlowRule> list) { 
         Map<String, List<ParamFlowRule>> newRuleMap = ParamFlowRuleUtil.buildParamRuleMap(list); 
         if (newRuleMap == null || newRuleMap.isEmpty()) { 
             // No parameter flow rules, so clear all the metrics. 
             ParameterMetricStorage.getMetricsMap().clear(); 
             RecordLog.info("[ParamFlowRuleManager] No parameter flow rules, clearing all parameter metrics"); 
             return newRuleMap; 
         } 
    
         // Clear unused parameter metrics. 
         for (Map.Entry<String, List<ParamFlowRule>> entry : PARAM_FLOW_RULES.entrySet()) { 
    

    Sentinel 1.8.1. 已修复

    原回答者GitHub用户sczyh30

    2023-05-19 20:13:28
    赞同 展开评论
问答地址:

阿里云拥有国内全面的云原生产品技术以及大规模的云原生应用实践,通过全面容器化、核心技术互联网化、应用 Serverless 化三大范式,助力制造业企业高效上云,实现系统稳定、应用敏捷智能。拥抱云原生,让创新无处不在。

还有其他疑问?
咨询AI助理