sentinel 1.8.2 持久化Nacos动态规则热点规则和授权规则不生效的问题

问题：规则持久化到nacos之后,我在本地测试时候只有热点和授权规则不生效，我慢慢的在客户端sentinel-csp-nacos源码下然后推送之后BUG源码一步一步查看，发现 ParamFlowRuleManager 类中map中一直没有规则，慢慢发现里面是实体类ParamFlowRule数据就是初始化类数据，这时候我继续看修改和查看 RulePropertyListener监听器监听到了但是在ParamFlowRuleManager.configUpdate 和configLoad 方法中buildParamRuleMap时候一直返回数据为空。这时候我觉得是不是版本有问题，当时的时候控制台1.8.0版本，

客户端是1.7.1版本，这时候我更换了本地客户端所有的cloudAlibaba boot sentinel 版本。发现还是失效，这时候我就拿出来nacos里面数据结构和客户端数据结构对比。数据结构不一致。查看sentinel-dashboard在自定义ParamFlowRuleNacosPublisher时候推送的数据是ParamFlowRuleEntity。客户端接收的ParamFlowRule类。这时候就需要改一下。

接下来~~~~~~~~~~~~~~~~~~~~~~~~开始

解决方案：

重写ParamFlowRuleEntity与AuthorityRuleEntity

1.热点参数规则

第一步重写ParamFlowRuleEntity

import com.alibaba.csp.sentinel.slots.block.Rule;
import com.alibaba.csp.sentinel.slots.block.flow.param.ParamFlowClusterConfig;
import com.alibaba.csp.sentinel.slots.block.flow.param.ParamFlowItem;
import com.alibaba.csp.sentinel.slots.block.flow.param.ParamFlowRule;import java.util.*;/*** @author 阿志有点坑* @description* @date 2021/2/4 10:04*/
public class ParamFlowRuleCorrectEntity implements RuleEntity {private Long id;private String app;private String ip;private Integer port;private String limitApp;private String resource;private Date gmtCreate;private int grade = 1;private Integer paramIdx;private double count;private int controlBehavior = 0;private int maxQueueingTimeMs = 0;private int burstCount = 0;private long durationInSec = 1L;private List<ParamFlowItem> paramFlowItemList = new ArrayList();private Map<Object, Integer> hotItems = new HashMap();private boolean clusterMode = false;private ParamFlowClusterConfig clusterConfig;public int getGrade() {return grade;}public void setGrade(int grade) {this.grade = grade;}public Integer getParamIdx() {return paramIdx;}public void setParamIdx(Integer paramIdx) {this.paramIdx = paramIdx;}public double getCount() {return count;}public void setCount(double count) {this.count = count;}public int getControlBehavior() {return controlBehavior;}public void setControlBehavior(int controlBehavior) {this.controlBehavior = controlBehavior;}public int getMaxQueueingTimeMs() {return maxQueueingTimeMs;}public void setMaxQueueingTimeMs(int maxQueueingTimeMs) {this.maxQueueingTimeMs = maxQueueingTimeMs;}public int getBurstCount() {return burstCount;}public void setBurstCount(int burstCount) {this.burstCount = burstCount;}public long getDurationInSec() {return durationInSec;}public void setDurationInSec(long durationInSec) {this.durationInSec = durationInSec;}public List<ParamFlowItem> getParamFlowItemList() {return paramFlowItemList;}public void setParamFlowItemList(List<ParamFlowItem> paramFlowItemList) {this.paramFlowItemList = paramFlowItemList;}public Map<Object, Integer> getHotItems() {return hotItems;}public void setHotItems(Map<Object, Integer> hotItems) {this.hotItems = hotItems;}public boolean isClusterMode() {return clusterMode;}public void setClusterMode(boolean clusterMode) {this.clusterMode = clusterMode;}public ParamFlowClusterConfig getClusterConfig() {return clusterConfig;}public void setClusterConfig(ParamFlowClusterConfig clusterConfig) {this.clusterConfig = clusterConfig;}@Overridepublic Date getGmtCreate() {return gmtCreate;}public void setGmtCreate(Date gmtCreate) {this.gmtCreate = gmtCreate;}@Overridepublic Long getId() {return id;}@Overridepublic void setId(Long id) {this.id = id;}@Overridepublic String getApp() {return app;}public void setApp(String app) {this.app = app;}@Overridepublic String getIp() {return ip;}public void setIp(String ip) {this.ip = ip;}@Overridepublic Integer getPort() {return port;}public void setPort(Integer port) {this.port = port;}public String getLimitApp() {return limitApp;}public void setLimitApp(String limitApp) {this.limitApp = limitApp;}public String getResource() {return resource;}public void setResource(String resource) {this.resource = resource;}@Overridepublic Rule toRule(){ParamFlowRule rule=new ParamFlowRule();return rule;}
}

第二步：在NacosConfig添加对应的类型转换配置

@Bean
public Converter<List<ParamFlowRuleCorrectEntity>, String> paramFlowRuleCorrectEntityEncoder() {return JSON::toJSONString;
}@Bean
public Converter<String, List<ParamFlowRuleCorrectEntity>> paramFlowRuleCorrectEntityDecoder() {return s -> JSON.parseArray(s, ParamFlowRuleCorrectEntity.class);
}

第三步：修改对应的ParamFlowRuleNacosProvider


package com.alibaba.csp.sentinel.dashboard.rule.nacos.param;import com.alibaba.csp.sentinel.dashboard.datasource.entity.rule.ParamFlowRuleCorrectEntity;
import com.alibaba.csp.sentinel.dashboard.datasource.entity.rule.ParamFlowRuleEntity;
import com.alibaba.csp.sentinel.dashboard.rule.DynamicRuleProvider;
import com.alibaba.csp.sentinel.dashboard.rule.nacos.NacosConfigUtil;
import com.alibaba.csp.sentinel.datasource.Converter;
import com.alibaba.csp.sentinel.slots.block.flow.param.ParamFlowRule;
import com.alibaba.csp.sentinel.util.StringUtil;
import com.alibaba.nacos.api.config.ConfigService;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;import java.util.ArrayList;
import java.util.List;
import java.util.stream.Collectors;/*** @author 阿志有点坑* @since 1.4.0*/
@Component("paramFlowRuleNacosProvider")
public class ParamFlowRuleNacosProvider implements DynamicRuleProvider<List<ParamFlowRuleEntity>> {@Autowiredprivate ConfigService configService;@Autowiredprivate Converter<String, List<ParamFlowRuleCorrectEntity>> converter;@Overridepublic List<ParamFlowRuleEntity> getRules(String appName) throws Exception {String rules = configService.getConfig(appName + NacosConfigUtil.PARAM_FLOW_DATA_ID_POSTFIX,NacosConfigUtil.GROUP_ID, 3000);if (StringUtil.isEmpty(rules)) {return new ArrayList<>();}List<ParamFlowRuleCorrectEntity> entityList = converter.convert(rules);entityList.forEach(e -> e.setApp(appName));return entityList.stream().map(rule -> {ParamFlowRule paramFlowRule = new ParamFlowRule();BeanUtils.copyProperties(rule, paramFlowRule);ParamFlowRuleEntity entity = ParamFlowRuleEntity.fromParamFlowRule(rule.getApp(), rule.getIp(), rule.getPort(), paramFlowRule);entity.setId(rule.getId());entity.setGmtCreate(rule.getGmtCreate());return entity;}).collect(Collectors.toList());}
}

第四步：修改对应的NacosPublisher

/** Copyright 1999-2018 Alibaba Group Holding Ltd.** Licensed under the Apache License, Version 2.0 (the "License");* you may not use this file except in compliance with the License.* You may obtain a copy of the License at**      http://www.apache.org/licenses/LICENSE-2.0** Unless required by applicable law or agreed to in writing, software* distributed under the License is distributed on an "AS IS" BASIS,* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.* See the License for the specific language governing permissions and* limitations under the License.*/
package com.alibaba.csp.sentinel.dashboard.rule.nacos.param;import com.alibaba.csp.sentinel.dashboard.datasource.entity.rule.ParamFlowRuleCorrectEntity;
import com.alibaba.csp.sentinel.dashboard.datasource.entity.rule.ParamFlowRuleEntity;
import com.alibaba.csp.sentinel.dashboard.rule.DynamicRulePublisher;
import com.alibaba.csp.sentinel.dashboard.rule.nacos.NacosConfigUtil;
import com.alibaba.csp.sentinel.datasource.Converter;
import com.alibaba.csp.sentinel.util.AssertUtil;
import com.alibaba.nacos.api.config.ConfigService;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;import java.util.List;
import java.util.stream.Collectors;/*** @author Eric Zhao* @since 1.4.0*/
@Component("paramFlowRuleNacosPublisher")
public class ParamFlowRuleNacosPublisher implements DynamicRulePublisher<List<ParamFlowRuleEntity>> {@Autowiredprivate ConfigService configService;@Autowiredprivate Converter<List<ParamFlowRuleCorrectEntity>, String> converter;@Overridepublic void publish(String app, List<ParamFlowRuleEntity> rules) throws Exception {AssertUtil.notEmpty(app, "app name cannot be empty");if (rules == null) {return;}rules.forEach(e -> e.setApp(app));//  转换List<ParamFlowRuleCorrectEntity> list = rules.stream().map(rule -> {ParamFlowRuleCorrectEntity entity = new ParamFlowRuleCorrectEntity();BeanUtils.copyProperties(rule, entity);return entity;}).collect(Collectors.toList());configService.publishConfig(app + NacosConfigUtil.PARAM_FLOW_DATA_ID_POSTFIX,NacosConfigUtil.GROUP_ID, converter.convert(list));}}

授权规则也一样.

2.权限规则

第一步：重写AuthorityRuleEntity

package com.alibaba.csp.sentinel.dashboard.datasource.entity.rule;import com.alibaba.csp.sentinel.slots.block.Rule;
import com.alibaba.csp.sentinel.slots.block.authority.AuthorityRule;import java.util.Date;/**- @author chengmeng- @description- @date 2021/2/4 14:08*/public class AuthorityRuleCorrectEntity implements RuleEntity{private Long id;private String app;private String ip;private Integer port;private String limitApp;private String resource;private Date gmtCreate;private Date gmtModified;private int strategy;@Overridepublic Long getId() {return id;}@Overridepublic void setId(Long id) {this.id = id;}@Overridepublic String getApp() {return app;}public void setApp(String app) {this.app = app;}@Overridepublic String getIp() {return ip;}public void setIp(String ip) {this.ip = ip;}@Overridepublic Integer getPort() {return port;}public void setPort(Integer port) {this.port = port;}public String getLimitApp() {return limitApp;}public void setLimitApp(String limitApp) {this.limitApp = limitApp;}public String getResource() {return resource;}public void setResource(String resource) {this.resource = resource;}@Overridepublic Date getGmtCreate() {return gmtCreate;}public void setGmtCreate(Date gmtCreate) {this.gmtCreate = gmtCreate;}public Date getGmtModified() {return gmtModified;}public void setGmtModified(Date gmtModified) {this.gmtModified = gmtModified;}public int getStrategy() {return strategy;}public void setStrategy(int strategy) {this.strategy = strategy;}@Overridepublic Rule toRule(){AuthorityRule rule=new AuthorityRule();return rule;}}

@Bean
public Converter<java.util.List<AuthorityRuleCorrectEntity>, String> authorityRuleCorrectEntityEncoder() {return JSON::toJSONString;
}@Bean
public Converter<String, java.util.List<AuthorityRuleCorrectEntity>> authorityRuleCorrectEntityDecoder() {return s -> JSON.parseArray(s, AuthorityRuleCorrectEntity.class);
}

1.2.3.4 步和热点一样

总结：

sentinel 在往nacos推送时候转换成客户端想要的格式。在控制台返回时候将其自定义的类转换成sentinel想要的格式。就完事了