给个能看的网站,企业做网站系统,重庆免费建站,个人作品网站本次修改的源码在#xff1a;https://gitee.com/stonic-open-source/sentinel-parent
一
下载源码 地址#xff1a;https://github.com/alibaba/Sentinel/releases/tag/1.8.6 二
导入idea#xff0c;等待maven下载好各种依赖
三
打开sentile-dashboard这个模块#xf…本次修改的源码在https://gitee.com/stonic-open-source/sentinel-parent
一
下载源码 地址https://github.com/alibaba/Sentinel/releases/tag/1.8.6 二
导入idea等待maven下载好各种依赖
三
打开sentile-dashboard这个模块打开resources下的application.properties配置
把下列配置加进去
#你的nacos地址
nacos.server-addrlocalhost:8148
#准备把sentinel配置同步到的nacos命名空间
nacos.namespacezixun_dev
#你的nacos用户名
nacos.usernamenacos
#你的nacos密码
nacos.passwordnacos
四
打开sentile-dashboard下的pom把sentinel-datasource-nacos的scopetest/scope删掉(记得刷新一下maven) 五
rule文件夹下新建一个nacos目录
把图中test的NacosConfig和Util复制到nacos目录下 六
然后在nacos下新建一个NacosInfoConfig类用于读取配置文件
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component;/*** author 刘辉* description* since 2024/5/17 上午10:26*/
Component
ConfigurationProperties(prefix nacos)
public class NacosInfoConfig {private String serverAddr;private String username;private String password;private String namespace;public String getServerAddr() {return serverAddr;}public void setServerAddr(String serverAddr) {this.serverAddr serverAddr;}public String getUsername() {return username;}public void setUsername(String username) {this.username username;}public String getPassword() {return password;}public void setPassword(String password) {this.password password;}public String getNamespace() {return namespace;}public void setNamespace(String namespace) {this.namespace namespace;}
}
七
然后修改一下NacosConfigUtil的内容 其中group_id需要和你springcloud项目配置的nacos中sentinel的groupId一致
public final class NacosConfigUtil {/*** 同步到nacos生成的groupId 没有可不填*/public static final String GROUP_ID zixun_sentinel;/*** 同步到nacos生成的sentinel api规则的后缀*/public static final String API_DATA_ID_POSTFIX -api-rules;/*** 同步到nacos生成的sentinel 流控规则的后缀*/public static final String FLOW_DATA_ID_POSTFIX -flow-rules;/*** 同步到nacos生成的sentinel 参数规则的后缀*/public static final String PARAM_FLOW_DATA_ID_POSTFIX -param-rules;public static final String CLUSTER_MAP_DATA_ID_POSTFIX -cluster-map;/*** cc for cluster-client*/public static final String CLIENT_CONFIG_DATA_ID_POSTFIX -cc-config;/*** cs for cluster-server*/public static final String SERVER_TRANSPORT_CONFIG_DATA_ID_POSTFIX -cs-transport-config;public static final String SERVER_FLOW_CONFIG_DATA_ID_POSTFIX -cs-flow-config;public static final String SERVER_NAMESPACE_SET_DATA_ID_POSTFIX -cs-namespace-set;private NacosConfigUtil() {}
}八
修改NacosConfig文件
将配置的nacos信息注入进去且新增gateway流控配置和sentinel全局规则的配置
import java.util.List;
import java.util.Properties;import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;import com.alibaba.csp.sentinel.dashboard.datasource.entity.gateway.ApiDefinitionEntity;
import com.alibaba.csp.sentinel.dashboard.datasource.entity.gateway.GatewayFlowRuleEntity;
import com.alibaba.csp.sentinel.dashboard.datasource.entity.rule.FlowRuleEntity;
import com.alibaba.csp.sentinel.datasource.Converter;
import com.alibaba.fastjson.JSON;
import com.alibaba.nacos.api.config.ConfigFactory;
import com.alibaba.nacos.api.config.ConfigService;/*** author Eric Zhao* since 1.4.0*/
Configuration
public class NacosConfig {Autowiredprivate NacosInfoConfig nacosInfoConfig;/*** sentinel本地流控 编码器* return*/Beanpublic ConverterListFlowRuleEntity, String flowRuleEntityEncoder() {return JSON::toJSONString;}/*** sentinel 针对gateway流控配置 编码器* return*/Beanpublic ConverterListGatewayFlowRuleEntity, String flowRuleGatewayEntityEncoder() {return JSON::toJSONString;}/*** sentinel 针对全局流控配置 编码器* return*/Beanpublic ConverterListApiDefinitionEntity, String flowRuleNacosEntityEncoder() {return JSON::toJSONString;}/*** sentinel本地流控 解码器* return*/Beanpublic ConverterString, ListFlowRuleEntity flowRuleEntityDecoder() {return s - JSON.parseArray(s, FlowRuleEntity.class);}/*** sentinel 针对gateway流控配置 解码器* return*/Beanpublic ConverterString, ListGatewayFlowRuleEntity flowRuleGatewayEntityDecoder() {return s - JSON.parseArray(s, GatewayFlowRuleEntity.class);}/*** sentinel 针对全局流控配置 解码器* return*/Beanpublic ConverterString, ListApiDefinitionEntity flowRuleNacosEntityDecoder() {return s - JSON.parseArray(s, ApiDefinitionEntity.class);}Beanpublic ConfigService nacosConfigService() throws Exception {Properties properties new Properties();//Nacos地址properties.put(serverAddr, nacosInfoConfig.getServerAddr());//Nacos用户名properties.put(username, nacosInfoConfig.getUsername());//Nacos密码properties.put(password, nacosInfoConfig.getPassword());properties.put(namespace, nacosInfoConfig.getNamespace());return ConfigFactory.createConfigService(properties);}
}
九
新建FlowRuleGatewayProvider和FlowRuleGatewayPublisher 分别提供gateway添加和查询的操作
import java.util.ArrayList;
import java.util.List;import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.stereotype.Component;import com.alibaba.csp.sentinel.dashboard.datasource.entity.gateway.GatewayFlowRuleEntity;
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.util.StringUtil;
import com.alibaba.nacos.api.config.ConfigService;/*** author Eric Zhao* since 1.4.0*/
Component(flowRuleGatewayProvider)
public class FlowRuleGatewayProvider implements DynamicRuleProviderListGatewayFlowRuleEntity {Autowiredprivate ConfigService configService;AutowiredQualifier(flowRuleGatewayEntityDecoder)private ConverterString, ListGatewayFlowRuleEntity converter;Overridepublic ListGatewayFlowRuleEntity getRules(String appName) throws Exception {String rules configService.getConfig(appName NacosConfigUtil.FLOW_DATA_ID_POSTFIX,NacosConfigUtil.GROUP_ID, 3000);if (StringUtil.isEmpty(rules)) {return new ArrayList();}return converter.convert(rules);}
}
import java.util.List;import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.stereotype.Component;import com.alibaba.csp.sentinel.dashboard.datasource.entity.gateway.GatewayFlowRuleEntity;
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 com.alibaba.nacos.api.config.ConfigType;/*** author Eric Zhao* since 1.4.0*/
Component(flowRuleGatewayPublisher)
public class FlowRuleGatewayPublisher implements DynamicRulePublisherListGatewayFlowRuleEntity {Autowiredprivate ConfigService configService;AutowiredQualifier(flowRuleGatewayEntityEncoder)private ConverterListGatewayFlowRuleEntity, String converter;Overridepublic void publish(String app, ListGatewayFlowRuleEntity rules) throws Exception {AssertUtil.notEmpty(app, app name cannot be empty);if (rules null) {return;}configService.publishConfig(app NacosConfigUtil.FLOW_DATA_ID_POSTFIX,NacosConfigUtil.GROUP_ID, converter.convert(rules), ConfigType.JSON.getType());}
}新建FlowRuleApiProvider和FlowRuleApiPublisher 分别提供sentinel全局规则 查询和编辑
import java.util.ArrayList;
import java.util.List;import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.stereotype.Component;import com.alibaba.csp.sentinel.dashboard.datasource.entity.gateway.ApiDefinitionEntity;
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.util.StringUtil;
import com.alibaba.nacos.api.config.ConfigService;/*** author Eric Zhao* since 1.4.0*/
Component(flowRuleNacosProvider)
public class FlowRuleApiProvider implements DynamicRuleProviderListApiDefinitionEntity {Autowiredprivate ConfigService configService;AutowiredQualifier(flowRuleNacosEntityDecoder)private ConverterString, ListApiDefinitionEntity converter;Overridepublic ListApiDefinitionEntity getRules(String appName) throws Exception {String rules configService.getConfig(appName NacosConfigUtil.API_DATA_ID_POSTFIX,NacosConfigUtil.GROUP_ID, 3000);if (StringUtil.isEmpty(rules)) {return new ArrayList();}return converter.convert(rules);}
}import java.util.List;import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.stereotype.Component;import com.alibaba.csp.sentinel.dashboard.datasource.entity.gateway.ApiDefinitionEntity;
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 com.alibaba.nacos.api.config.ConfigType;/*** author Eric Zhao* since 1.4.0*/
Component(flowRuleNacosPublisher)
public class FlowRuleApiPublisher implements DynamicRulePublisherListApiDefinitionEntity {Autowiredprivate ConfigService configService;AutowiredQualifier(flowRuleNacosEntityEncoder)private ConverterListApiDefinitionEntity, String converter;Overridepublic void publish(String app, ListApiDefinitionEntity rules) throws Exception {AssertUtil.notEmpty(app, app name cannot be empty);if (rules null) {return;}configService.publishConfig(app NacosConfigUtil.API_DATA_ID_POSTFIX,NacosConfigUtil.GROUP_ID, converter.convert(rules), ConfigType.JSON.getType());}
}自此配置方面就结束了接下来上controller代码
十
找到controller下的gateway目录两个controller 下边的增删改查方法都有修改修改的地方比较多这里我直接贴主要替换的代码和controller全部代码大家直接粘贴
GatewayApiController修改处 AutowiredQualifier(flowRuleNacosProvider)private DynamicRuleProviderListApiDefinitionEntity ruleProvider;AutowiredQualifier(flowRuleNacosPublisher)private DynamicRulePublisherListApiDefinitionEntity rulePublisher; package com.alibaba.csp.sentinel.dashboard.controller.gateway;import com.alibaba.csp.sentinel.dashboard.auth.AuthAction;
import com.alibaba.csp.sentinel.dashboard.auth.AuthService;
import com.alibaba.csp.sentinel.dashboard.client.SentinelApiClient;
import com.alibaba.csp.sentinel.dashboard.datasource.entity.gateway.ApiDefinitionEntity;
import com.alibaba.csp.sentinel.dashboard.datasource.entity.gateway.ApiPredicateItemEntity;
import com.alibaba.csp.sentinel.dashboard.discovery.MachineInfo;
import com.alibaba.csp.sentinel.dashboard.domain.Result;
import com.alibaba.csp.sentinel.dashboard.domain.vo.gateway.api.AddApiReqVo;
import com.alibaba.csp.sentinel.dashboard.domain.vo.gateway.api.ApiPredicateItemVo;
import com.alibaba.csp.sentinel.dashboard.domain.vo.gateway.api.UpdateApiReqVo;
import com.alibaba.csp.sentinel.dashboard.repository.gateway.InMemApiDefinitionStore;
import com.alibaba.csp.sentinel.dashboard.rule.DynamicRuleProvider;
import com.alibaba.csp.sentinel.dashboard.rule.DynamicRulePublisher;
import com.alibaba.csp.sentinel.util.StringUtil;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.util.CollectionUtils;
import org.springframework.web.bind.annotation.*;import javax.servlet.http.HttpServletRequest;
import java.util.*;import static com.alibaba.csp.sentinel.adapter.gateway.common.SentinelGatewayConstants.*;/*** Gateway api Controller for manage gateway api definitions.** author cdfive* since 1.7.0*/
RestController
RequestMapping(value /gateway/api)
public class GatewayApiController {private final Logger logger LoggerFactory.getLogger(GatewayApiController.class);Autowiredprivate InMemApiDefinitionStore repository;Autowiredprivate SentinelApiClient sentinelApiClient;AutowiredQualifier(flowRuleNacosProvider)private DynamicRuleProviderListApiDefinitionEntity ruleProvider;AutowiredQualifier(flowRuleNacosPublisher)private DynamicRulePublisherListApiDefinitionEntity rulePublisher;GetMapping(/list.json)AuthAction(AuthService.PrivilegeType.READ_RULE)public ResultListApiDefinitionEntity queryApis(String app, String ip, Integer port) {if (StringUtil.isEmpty(app)) {return Result.ofFail(-1, app cant be null or empty);}if (StringUtil.isEmpty(ip)) {return Result.ofFail(-1, ip cant be null or empty);}if (port null) {return Result.ofFail(-1, port cant be null);}try {ListApiDefinitionEntity apis ruleProvider.getRules(app);
// ListApiDefinitionEntity apis sentinelApiClient.fetchApis(app, ip, port).get();repository.saveAll(apis);return Result.ofSuccess(apis);} catch (Throwable throwable) {logger.error(queryApis error:, throwable);return Result.ofThrowable(-1, throwable);}}PostMapping(/new.json)AuthAction(AuthService.PrivilegeType.WRITE_RULE)public ResultApiDefinitionEntity addApi(HttpServletRequest request, RequestBody AddApiReqVo reqVo) {String app reqVo.getApp();if (StringUtil.isBlank(app)) {return Result.ofFail(-1, app cant be null or empty);}ApiDefinitionEntity entity new ApiDefinitionEntity();entity.setApp(app.trim());String ip reqVo.getIp();if (StringUtil.isBlank(ip)) {return Result.ofFail(-1, ip cant be null or empty);}entity.setIp(ip.trim());Integer port reqVo.getPort();if (port null) {return Result.ofFail(-1, port cant be null);}entity.setPort(port);// API名称String apiName reqVo.getApiName();if (StringUtil.isBlank(apiName)) {return Result.ofFail(-1, apiName cant be null or empty);}entity.setApiName(apiName.trim());// 匹配规则列表ListApiPredicateItemVo predicateItems reqVo.getPredicateItems();if (CollectionUtils.isEmpty(predicateItems)) {return Result.ofFail(-1, predicateItems cant empty);}ListApiPredicateItemEntity predicateItemEntities new ArrayList();for (ApiPredicateItemVo predicateItem : predicateItems) {ApiPredicateItemEntity predicateItemEntity new ApiPredicateItemEntity();// 匹配模式Integer matchStrategy predicateItem.getMatchStrategy();if (!Arrays.asList(URL_MATCH_STRATEGY_EXACT, URL_MATCH_STRATEGY_PREFIX, URL_MATCH_STRATEGY_REGEX).contains(matchStrategy)) {return Result.ofFail(-1, invalid matchStrategy: matchStrategy);}predicateItemEntity.setMatchStrategy(matchStrategy);// 匹配串String pattern predicateItem.getPattern();if (StringUtil.isBlank(pattern)) {return Result.ofFail(-1, pattern cant be null or empty);}predicateItemEntity.setPattern(pattern);predicateItemEntities.add(predicateItemEntity);}entity.setPredicateItems(new LinkedHashSet(predicateItemEntities));// 检查API名称不能重复ListApiDefinitionEntity allApis repository.findAllByMachine(MachineInfo.of(app.trim(), ip.trim(), port));if (allApis.stream().map(o - o.getApiName()).anyMatch(o - o.equals(apiName.trim()))) {return Result.ofFail(-1, apiName exists: apiName);}Date date new Date();entity.setGmtCreate(date);entity.setGmtModified(date);try {entity repository.save(entity);publishApis(entity.getApp());} catch (Throwable throwable) {logger.error(add gateway api error:, throwable);return Result.ofThrowable(-1, throwable);}// if (!publishApis(app, ip, port)) {
// logger.warn(publish gateway apis fail after add);
// }return Result.ofSuccess(entity);}PostMapping(/save.json)AuthAction(AuthService.PrivilegeType.WRITE_RULE)public ResultApiDefinitionEntity updateApi(RequestBody UpdateApiReqVo reqVo) {String app reqVo.getApp();if (StringUtil.isBlank(app)) {return Result.ofFail(-1, app cant be null or empty);}Long id reqVo.getId();if (id null) {return Result.ofFail(-1, id cant be null);}ApiDefinitionEntity entity repository.findById(id);if (entity null) {return Result.ofFail(-1, api does not exist, id id);}// 匹配规则列表ListApiPredicateItemVo predicateItems reqVo.getPredicateItems();if (CollectionUtils.isEmpty(predicateItems)) {return Result.ofFail(-1, predicateItems cant empty);}ListApiPredicateItemEntity predicateItemEntities new ArrayList();for (ApiPredicateItemVo predicateItem : predicateItems) {ApiPredicateItemEntity predicateItemEntity new ApiPredicateItemEntity();// 匹配模式int matchStrategy predicateItem.getMatchStrategy();if (!Arrays.asList(URL_MATCH_STRATEGY_EXACT, URL_MATCH_STRATEGY_PREFIX, URL_MATCH_STRATEGY_REGEX).contains(matchStrategy)) {return Result.ofFail(-1, Invalid matchStrategy: matchStrategy);}predicateItemEntity.setMatchStrategy(matchStrategy);// 匹配串String pattern predicateItem.getPattern();if (StringUtil.isBlank(pattern)) {return Result.ofFail(-1, pattern cant be null or empty);}predicateItemEntity.setPattern(pattern);predicateItemEntities.add(predicateItemEntity);}entity.setPredicateItems(new LinkedHashSet(predicateItemEntities));Date date new Date();entity.setGmtModified(date);try {entity repository.save(entity);publishApis(entity.getApp());} catch (Throwable throwable) {logger.error(update gateway api error:, throwable);return Result.ofThrowable(-1, throwable);}// if (!publishApis(app, entity.getIp(), entity.getPort())) {
// logger.warn(publish gateway apis fail after update);
// }return Result.ofSuccess(entity);}PostMapping(/delete.json)AuthAction(AuthService.PrivilegeType.DELETE_RULE)public ResultLong deleteApi(Long id) {if (id null) {return Result.ofFail(-1, id cant be null);}ApiDefinitionEntity oldEntity repository.findById(id);if (oldEntity null) {return Result.ofSuccess(null);}try {repository.delete(id);publishApis(oldEntity.getApp());} catch (Throwable throwable) {logger.error(delete gateway api error:, throwable);return Result.ofThrowable(-1, throwable);}// if (!publishApis(oldEntity.getApp(), oldEntity.getIp(), oldEntity.getPort())) {
// logger.warn(publish gateway apis fail after delete);
// }return Result.ofSuccess(id);}// private boolean publishApis(String app, String ip, Integer port) {
// ListApiDefinitionEntity apis repository.findAllByMachine(MachineInfo.of(app, ip, port));
// return sentinelApiClient.modifyApis(app, ip, port, apis);
// }private void publishApis(/*NonNull*/ String app) throws Exception {ListApiDefinitionEntity rules repository.findAllByApp(app);rulePublisher.publish(app, rules);}
}GatewayFlowRuleController修改为 AutowiredQualifier(flowRuleGatewayProvider)private DynamicRuleProviderListGatewayFlowRuleEntity ruleProvider;AutowiredQualifier(flowRuleGatewayPublisher)private DynamicRulePublisherListGatewayFlowRuleEntity rulePublisher; package com.alibaba.csp.sentinel.dashboard.controller.gateway;import com.alibaba.csp.sentinel.dashboard.auth.AuthAction;
import com.alibaba.csp.sentinel.dashboard.auth.AuthService;
import com.alibaba.csp.sentinel.dashboard.client.SentinelApiClient;
import com.alibaba.csp.sentinel.dashboard.datasource.entity.gateway.GatewayFlowRuleEntity;
import com.alibaba.csp.sentinel.dashboard.datasource.entity.gateway.GatewayParamFlowItemEntity;
import com.alibaba.csp.sentinel.dashboard.datasource.entity.rule.FlowRuleEntity;
import com.alibaba.csp.sentinel.dashboard.discovery.MachineInfo;
import com.alibaba.csp.sentinel.dashboard.domain.Result;
import com.alibaba.csp.sentinel.dashboard.domain.vo.gateway.rule.AddFlowRuleReqVo;
import com.alibaba.csp.sentinel.dashboard.domain.vo.gateway.rule.GatewayParamFlowItemVo;
import com.alibaba.csp.sentinel.dashboard.domain.vo.gateway.rule.UpdateFlowRuleReqVo;
import com.alibaba.csp.sentinel.dashboard.repository.gateway.InMemGatewayFlowRuleStore;
import com.alibaba.csp.sentinel.dashboard.rule.DynamicRuleProvider;
import com.alibaba.csp.sentinel.dashboard.rule.DynamicRulePublisher;
import com.alibaba.csp.sentinel.util.StringUtil;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.web.bind.annotation.*;import java.util.Arrays;
import java.util.Date;
import java.util.List;import static com.alibaba.csp.sentinel.slots.block.RuleConstant.*;
import static com.alibaba.csp.sentinel.adapter.gateway.common.SentinelGatewayConstants.*;
import static com.alibaba.csp.sentinel.dashboard.datasource.entity.gateway.GatewayFlowRuleEntity.*;/*** Gateway flow rule Controller for manage gateway flow rules.** author cdfive* since 1.7.0*/
RestController
RequestMapping(value /gateway/flow)
public class GatewayFlowRuleController {private final Logger logger LoggerFactory.getLogger(GatewayFlowRuleController.class);Autowiredprivate InMemGatewayFlowRuleStore repository;Autowiredprivate SentinelApiClient sentinelApiClient;AutowiredQualifier(flowRuleGatewayProvider)private DynamicRuleProviderListGatewayFlowRuleEntity ruleProvider;AutowiredQualifier(flowRuleGatewayPublisher)private DynamicRulePublisherListGatewayFlowRuleEntity rulePublisher;GetMapping(/list.json)AuthAction(AuthService.PrivilegeType.READ_RULE)public ResultListGatewayFlowRuleEntity queryFlowRules(String app, String ip, Integer port) {if (StringUtil.isEmpty(app)) {return Result.ofFail(-1, app cant be null or empty);}if (StringUtil.isEmpty(ip)) {return Result.ofFail(-1, ip cant be null or empty);}if (port null) {return Result.ofFail(-1, port cant be null);}// try {
// ListGatewayFlowRuleEntity rules sentinelApiClient.fetchGatewayFlowRules(app, ip, port).get();
// repository.saveAll(rules);
// return Result.ofSuccess(rules);
// } catch (Throwable throwable) {
// logger.error(query gateway flow rules error:, throwable);
// return Result.ofThrowable(-1, throwable);
// }try {ListGatewayFlowRuleEntity rules ruleProvider.getRules(app);rules repository.saveAll(rules);return Result.ofSuccess(rules);} catch (Throwable throwable) {logger.error(Error when querying flow rules, throwable);return Result.ofThrowable(-1, throwable);}}PostMapping(/new.json)AuthAction(AuthService.PrivilegeType.WRITE_RULE)public ResultGatewayFlowRuleEntity addFlowRule(RequestBody AddFlowRuleReqVo reqVo) {String app reqVo.getApp();if (StringUtil.isBlank(app)) {return Result.ofFail(-1, app cant be null or empty);}GatewayFlowRuleEntity entity new GatewayFlowRuleEntity();entity.setApp(app.trim());String ip reqVo.getIp();if (StringUtil.isBlank(ip)) {return Result.ofFail(-1, ip cant be null or empty);}entity.setIp(ip.trim());Integer port reqVo.getPort();if (port null) {return Result.ofFail(-1, port cant be null);}entity.setPort(port);// API类型, Route ID或API分组Integer resourceMode reqVo.getResourceMode();if (resourceMode null) {return Result.ofFail(-1, resourceMode cant be null);}if (!Arrays.asList(RESOURCE_MODE_ROUTE_ID, RESOURCE_MODE_CUSTOM_API_NAME).contains(resourceMode)) {return Result.ofFail(-1, invalid resourceMode: resourceMode);}entity.setResourceMode(resourceMode);// API名称String resource reqVo.getResource();if (StringUtil.isBlank(resource)) {return Result.ofFail(-1, resource cant be null or empty);}entity.setResource(resource.trim());// 针对请求属性GatewayParamFlowItemVo paramItem reqVo.getParamItem();if (paramItem ! null) {GatewayParamFlowItemEntity itemEntity new GatewayParamFlowItemEntity();entity.setParamItem(itemEntity);// 参数属性 0-ClientIP 1-Remote Host 2-Header 3-URL参数 4-CookieInteger parseStrategy paramItem.getParseStrategy();if (!Arrays.asList(PARAM_PARSE_STRATEGY_CLIENT_IP, PARAM_PARSE_STRATEGY_HOST, PARAM_PARSE_STRATEGY_HEADER, PARAM_PARSE_STRATEGY_URL_PARAM, PARAM_PARSE_STRATEGY_COOKIE).contains(parseStrategy)) {return Result.ofFail(-1, invalid parseStrategy: parseStrategy);}itemEntity.setParseStrategy(paramItem.getParseStrategy());// 当参数属性为2-Header 3-URL参数 4-Cookie时参数名称必填if (Arrays.asList(PARAM_PARSE_STRATEGY_HEADER, PARAM_PARSE_STRATEGY_URL_PARAM, PARAM_PARSE_STRATEGY_COOKIE).contains(parseStrategy)) {// 参数名称String fieldName paramItem.getFieldName();if (StringUtil.isBlank(fieldName)) {return Result.ofFail(-1, fieldName cant be null or empty);}itemEntity.setFieldName(paramItem.getFieldName());}String pattern paramItem.getPattern();// 如果匹配串不为空验证匹配模式if (StringUtil.isNotEmpty(pattern)) {itemEntity.setPattern(pattern);Integer matchStrategy paramItem.getMatchStrategy();if (!Arrays.asList(PARAM_MATCH_STRATEGY_EXACT, PARAM_MATCH_STRATEGY_CONTAINS, PARAM_MATCH_STRATEGY_REGEX).contains(matchStrategy)) {return Result.ofFail(-1, invalid matchStrategy: matchStrategy);}itemEntity.setMatchStrategy(matchStrategy);}}// 阈值类型 0-线程数 1-QPSInteger grade reqVo.getGrade();if (grade null) {return Result.ofFail(-1, grade cant be null);}if (!Arrays.asList(FLOW_GRADE_THREAD, FLOW_GRADE_QPS).contains(grade)) {return Result.ofFail(-1, invalid grade: grade);}entity.setGrade(grade);// QPS阈值Double count reqVo.getCount();if (count null) {return Result.ofFail(-1, count cant be null);}if (count 0) {return Result.ofFail(-1, count should be at lease zero);}entity.setCount(count);// 间隔Long interval reqVo.getInterval();if (interval null) {return Result.ofFail(-1, interval cant be null);}if (interval 0) {return Result.ofFail(-1, interval should be greater than zero);}entity.setInterval(interval);// 间隔单位Integer intervalUnit reqVo.getIntervalUnit();if (intervalUnit null) {return Result.ofFail(-1, intervalUnit cant be null);}if (!Arrays.asList(INTERVAL_UNIT_SECOND, INTERVAL_UNIT_MINUTE, INTERVAL_UNIT_HOUR, INTERVAL_UNIT_DAY).contains(intervalUnit)) {return Result.ofFail(-1, Invalid intervalUnit: intervalUnit);}entity.setIntervalUnit(intervalUnit);// 流控方式 0-快速失败 2-匀速排队Integer controlBehavior reqVo.getControlBehavior();if (controlBehavior null) {return Result.ofFail(-1, controlBehavior cant be null);}if (!Arrays.asList(CONTROL_BEHAVIOR_DEFAULT, CONTROL_BEHAVIOR_RATE_LIMITER).contains(controlBehavior)) {return Result.ofFail(-1, invalid controlBehavior: controlBehavior);}entity.setControlBehavior(controlBehavior);if (CONTROL_BEHAVIOR_DEFAULT controlBehavior) {// 0-快速失败, 则Burst size必填Integer burst reqVo.getBurst();if (burst null) {return Result.ofFail(-1, burst cant be null);}if (burst 0) {return Result.ofFail(-1, invalid burst: burst);}entity.setBurst(burst);} else if (CONTROL_BEHAVIOR_RATE_LIMITER controlBehavior) {// 1-匀速排队, 则超时时间必填Integer maxQueueingTimeoutMs reqVo.getMaxQueueingTimeoutMs();if (maxQueueingTimeoutMs null) {return Result.ofFail(-1, maxQueueingTimeoutMs cant be null);}if (maxQueueingTimeoutMs 0) {return Result.ofFail(-1, invalid maxQueueingTimeoutMs: maxQueueingTimeoutMs);}entity.setMaxQueueingTimeoutMs(maxQueueingTimeoutMs);}Date date new Date();entity.setGmtCreate(date);entity.setGmtModified(date);try {entity repository.save(entity);publishRules(entity.getApp());} catch (Throwable throwable) {logger.error(add gateway flow rule error:, throwable);return Result.ofThrowable(-1, throwable);}// if (!publishRules(app, ip, port)) {
// logger.warn(publish gateway flow rules fail after add);
// }return Result.ofSuccess(entity);}PostMapping(/save.json)AuthAction(AuthService.PrivilegeType.WRITE_RULE)public ResultGatewayFlowRuleEntity updateFlowRule(RequestBody UpdateFlowRuleReqVo reqVo) {String app reqVo.getApp();if (StringUtil.isBlank(app)) {return Result.ofFail(-1, app cant be null or empty);}Long id reqVo.getId();if (id null) {return Result.ofFail(-1, id cant be null);}GatewayFlowRuleEntity entity repository.findById(id);if (entity null) {return Result.ofFail(-1, gateway flow rule does not exist, id id);}// 针对请求属性GatewayParamFlowItemVo paramItem reqVo.getParamItem();if (paramItem ! null) {GatewayParamFlowItemEntity itemEntity new GatewayParamFlowItemEntity();entity.setParamItem(itemEntity);// 参数属性 0-ClientIP 1-Remote Host 2-Header 3-URL参数 4-CookieInteger parseStrategy paramItem.getParseStrategy();if (!Arrays.asList(PARAM_PARSE_STRATEGY_CLIENT_IP, PARAM_PARSE_STRATEGY_HOST, PARAM_PARSE_STRATEGY_HEADER, PARAM_PARSE_STRATEGY_URL_PARAM, PARAM_PARSE_STRATEGY_COOKIE).contains(parseStrategy)) {return Result.ofFail(-1, invalid parseStrategy: parseStrategy);}itemEntity.setParseStrategy(paramItem.getParseStrategy());// 当参数属性为2-Header 3-URL参数 4-Cookie时参数名称必填if (Arrays.asList(PARAM_PARSE_STRATEGY_HEADER, PARAM_PARSE_STRATEGY_URL_PARAM, PARAM_PARSE_STRATEGY_COOKIE).contains(parseStrategy)) {// 参数名称String fieldName paramItem.getFieldName();if (StringUtil.isBlank(fieldName)) {return Result.ofFail(-1, fieldName cant be null or empty);}itemEntity.setFieldName(paramItem.getFieldName());}String pattern paramItem.getPattern();// 如果匹配串不为空验证匹配模式if (StringUtil.isNotEmpty(pattern)) {itemEntity.setPattern(pattern);Integer matchStrategy paramItem.getMatchStrategy();if (!Arrays.asList(PARAM_MATCH_STRATEGY_EXACT, PARAM_MATCH_STRATEGY_CONTAINS, PARAM_MATCH_STRATEGY_REGEX).contains(matchStrategy)) {return Result.ofFail(-1, invalid matchStrategy: matchStrategy);}itemEntity.setMatchStrategy(matchStrategy);}} else {entity.setParamItem(null);}// 阈值类型 0-线程数 1-QPSInteger grade reqVo.getGrade();if (grade null) {return Result.ofFail(-1, grade cant be null);}if (!Arrays.asList(FLOW_GRADE_THREAD, FLOW_GRADE_QPS).contains(grade)) {return Result.ofFail(-1, invalid grade: grade);}entity.setGrade(grade);// QPS阈值Double count reqVo.getCount();if (count null) {return Result.ofFail(-1, count cant be null);}if (count 0) {return Result.ofFail(-1, count should be at lease zero);}entity.setCount(count);// 间隔Long interval reqVo.getInterval();if (interval null) {return Result.ofFail(-1, interval cant be null);}if (interval 0) {return Result.ofFail(-1, interval should be greater than zero);}entity.setInterval(interval);// 间隔单位Integer intervalUnit reqVo.getIntervalUnit();if (intervalUnit null) {return Result.ofFail(-1, intervalUnit cant be null);}if (!Arrays.asList(INTERVAL_UNIT_SECOND, INTERVAL_UNIT_MINUTE, INTERVAL_UNIT_HOUR, INTERVAL_UNIT_DAY).contains(intervalUnit)) {return Result.ofFail(-1, Invalid intervalUnit: intervalUnit);}entity.setIntervalUnit(intervalUnit);// 流控方式 0-快速失败 2-匀速排队Integer controlBehavior reqVo.getControlBehavior();if (controlBehavior null) {return Result.ofFail(-1, controlBehavior cant be null);}if (!Arrays.asList(CONTROL_BEHAVIOR_DEFAULT, CONTROL_BEHAVIOR_RATE_LIMITER).contains(controlBehavior)) {return Result.ofFail(-1, invalid controlBehavior: controlBehavior);}entity.setControlBehavior(controlBehavior);if (CONTROL_BEHAVIOR_DEFAULT controlBehavior) {// 0-快速失败, 则Burst size必填Integer burst reqVo.getBurst();if (burst null) {return Result.ofFail(-1, burst cant be null);}if (burst 0) {return Result.ofFail(-1, invalid burst: burst);}entity.setBurst(burst);} else if (CONTROL_BEHAVIOR_RATE_LIMITER controlBehavior) {// 2-匀速排队, 则超时时间必填Integer maxQueueingTimeoutMs reqVo.getMaxQueueingTimeoutMs();if (maxQueueingTimeoutMs null) {return Result.ofFail(-1, maxQueueingTimeoutMs cant be null);}if (maxQueueingTimeoutMs 0) {return Result.ofFail(-1, invalid maxQueueingTimeoutMs: maxQueueingTimeoutMs);}entity.setMaxQueueingTimeoutMs(maxQueueingTimeoutMs);}Date date new Date();entity.setGmtModified(date);try {entity repository.save(entity);publishRules(entity.getApp());} catch (Throwable throwable) {logger.error(update gateway flow rule error:, throwable);return Result.ofThrowable(-1, throwable);}// if (!publishRules(app, entity.getIp(), entity.getPort())) {
// logger.warn(publish gateway flow rules fail after update);
// }return Result.ofSuccess(entity);}PostMapping(/delete.json)AuthAction(AuthService.PrivilegeType.DELETE_RULE)public ResultLong deleteFlowRule(Long id) {if (id null) {return Result.ofFail(-1, id cant be null);}GatewayFlowRuleEntity oldEntity repository.findById(id);if (oldEntity null) {return Result.ofSuccess(null);}try {repository.delete(id);publishRules(oldEntity.getApp());} catch (Throwable throwable) {logger.error(delete gateway flow rule error:, throwable);return Result.ofThrowable(-1, throwable);}// if (!publishRules(oldEntity.getApp(), oldEntity.getIp(), oldEntity.getPort())) {
// logger.warn(publish gateway flow rules fail after delete);
// }return Result.ofSuccess(id);}// private boolean publishRules(String app, String ip, Integer port) {
// ListGatewayFlowRuleEntity rules repository.findAllByMachine(MachineInfo.of(app, ip, port));
// return sentinelApiClient.modifyGatewayFlowRules(app, ip, port, rules);
// }
private void publishRules(/*NonNull*/ String app) throws Exception {ListGatewayFlowRuleEntity rules repository.findAllByApp(app);rulePublisher.publish(app, rules);
}
}十一
启动程序 然后添加流控规则查询规则都从nacos获取 至此就没问题了
