devbox
神奇cpp
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

Spring Cloud Gateway 集成 Sentinel（二）实现nacos动态保存配置_rule-type: gw-flow

作者：神奇cpp | 2024-06-20 10:04:35

赞

踩

rule-type: gw-flow

按照 （一）部署完成之后

一、改造网关

1. 在网关项目pom文件中新增 持久化依赖

  1.         <!-- Sentinel 持久化配置，支持多种持久化数据源：file、nacos、zookeeper、apollo、redis、consul 非必须，按需选择，这里使用的是 nacos-->
  2.         <dependency>
  3.             <groupId>com.alibaba.csp</groupId>
  4.             <artifactId>sentinel-datasource-nacos</artifactId>
  5.         </dependency>

2. 修改网关yaml配置

新增spring.cloud.sentinel.datasource

其中api代表的为数据源名字，可自主起名，server-addr 为 nacos主机连接ip与端口，可通过${spring.cloud.nacos.config.server-addr} 从注册中心获取

rule-type的配置项对应RuleType 枚举类。

public enum RuleType {
    FLOW("flow", FlowRule.class),
    DEGRADE("degrade", DegradeRule.class),
    PARAM_FLOW("param-flow", ParamFlowRule.class),
    SYSTEM("system", SystemRule.class),
    AUTHORITY("authority", AuthorityRule.class),
    GW_FLOW("gw-flow", "com.alibaba.csp.sentinel.adapter.gateway.common.rule.GatewayFlowRule"),
    GW_API_GROUP("gw-api-group", "com.alibaba.csp.sentinel.adapter.gateway.common.api.ApiDefinition");
}

  1. spring:
  2.   cloud:
  3.     sentinel:
  4.       enable: true
  5.       filter:
  6.         enabled: false
  7.       eager: true #立即加载
  8.       transport:
  9.         port: 9010
  10.         dashboard: 127.0.0.1:8080
  11. #        dashboard: 172.16.10.233:9010
  12.       scg:
  13.       # 限流后的相应配置
  14.         fallback:
  15.           content-type: application/json
  16.           # 模式： response / redirect
  17.           mode: response
  18.           # 相应状态码
  19.           response-status: 200
  20.           # 相应消息体
  21.           response-body: '{"code":0,"message":"服务忙请稍后再试...","data":null}'
  22.       # Sentinel 流控规则持久化
  23.       datasource:
  24.         api:
  25.           nacos:
  26.             server-addr: 127.0.0.1:8848
  27.             namespace: ****************
  28.             # 组名 默认 DEFAULT_GROUP
  29.             group-id: 'SENTINEL_GROUP'
  30.             # Nacos 中配置的Id
  31.             data-id: ${spring.application.name}-api-rules
  32.             # RuleType
  33.             rule-type: gw-api-group
  34.             # 默认就是Json
  35.             data-type: 'json'
  36.         # 自定义命名
  37.         flow:
  38.           # 支持多种持久化数据源：file、nacos、zookeeper、apollo、redis、consul
  39.           nacos:
  40.             # 配置类com.alibaba.cloud.sentinel.datasource.config.NacosDataSourceProperties
  41.             # 连接地址
  42.             server-addr: 127.0.0.1:8848
  43.             namespace: ****************
  44.             # 组名 默认 DEFAULT_GROUP
  45.             group-id: 'SENTINEL_GROUP'
  46.             # Nacos 中配置的Id
  47.             data-id: ${spring.application.name}-flow-rules
  48.             # RuleType
  49.             rule-type: gw-flow
  50.             # 默认就是Json
  51.             data-type: 'json'

 二、改造sentinel-dashboard

1.修改pom 

改

  1. <!-- for Nacos rule publisher sample -->
  2.         <dependency>
  3.             <groupId>com.alibaba.csp</groupId>
  4.             <artifactId>sentinel-datasource-nacos</artifactId>
  5.             <scope>test</scope>
  6.         </dependency>

为

  1. <!-- for Nacos rule publisher sample -->
  2.         <dependency>
  3.             <groupId>com.alibaba.csp</groupId>
  4.             <artifactId>sentinel-datasource-nacos</artifactId>
  5.         </dependency>

2.修改 application.properties 新增

  1. # local
  2. spring.cloud.sentinel.datasource.ds.nacos.serverAddr = 127.0.0.1 #nacos地址
  3. spring.cloud.sentinel.datasource.ds.nacos.groupId=SENTINEL_GROUP 
  4. spring.cloud.sentinel.datasource.ds.nacos.namespace=***** #nacos对应的 namespace

3. 修改代码

1） 将test文件夹下 

com.alibaba.csp.sentinel.dashboard.rule.nacos 拷贝到com.alibaba.csp.sentinel.dashboard.controller.gateway下

并修改 NacosConfig

  1. @Configuration
  2. public class NacosConfig {
  3.  
  4.     @Value("${spring.cloud.sentinel.datasource.ds.nacos.serverAddr}")
  5.     private String serverAddr;
  6.  
  7.     @Value("${spring.cloud.sentinel.datasource.ds.nacos.namespace}")
  8.     private String namespace;
  9.  
  10.     @Bean
  11.     public Converter<List<FlowRuleEntity>, String> flowRuleEntityEncoder() {
  12.         return JSON::toJSONString;
  13.     }
  14.  
  15.     @Bean
  16.     public Converter<String, List<FlowRuleEntity>> flowRuleEntityDecoder() {
  17.         return s -> JSON.parseArray(s, FlowRuleEntity.class);
  18.     }
  19.  
  20.  
  21.     @Bean
  22.     public ConfigService nacosConfigService() throws Exception {
  23.         Properties properties = new Properties();
  24.         properties.setProperty(PropertyKeyConst.SERVER_ADDR,serverAddr);
  25.         properties.setProperty(PropertyKeyConst.NAMESPACE,namespace);
  26.         return ConfigFactory.createConfigService(properties);
  27.     }
  28.  
  29.     @Bean
  30.     public Converter<List<GatewayFlowRuleEntity>, String> gatewayFlowRuleEntityEncoder() {
  31.         return JSON::toJSONString;
  32.     }
  33.  
  34.     @Bean
  35.     public Converter<String, List<GatewayFlowRuleEntity>> gatewayFlowRuleEntityDecoder() {
  36.         return s -> JSON.parseArray(s, GatewayFlowRuleEntity.class);
  37.     }
  38.  
  39.     @Bean
  40.     public Converter<List<ApiDefinitionEntity>, String> gatewayApiEntityEncoder() {
  41.         return JSON::toJSONString;
  42.     }
  43.  
  44.     @Bean
  45.     public Converter<String, List<ApiDefinitionEntity>> gatewayApiEntityDecoder() {
  46.         return s -> JSON.parseArray(s, ApiDefinitionEntity.class);
  47.     }
  48. }

2） 新增 nacos api的数据提供类 用于在nacos 发布 和 获取规则

GatewayFlowRuleNacosProvider
  1. @Component("gatewayFlowRuleNacosProvider")
  2. public class GatewayFlowRuleNacosProvider implements DynamicRuleProvider<List<GatewayFlowRuleEntity>> {
  3.     @Autowired
  4.     private ConfigService configService;
  5.     // 规则对象的转换器，获取到的数据根据使用的数据类型的不同，需要用不同的转换器转化后使用
  6.     @Autowired
  7.     private Converter<String, List<GatewayFlowRuleEntity>> converter;
  9.     @Override
  10.     public List<GatewayFlowRuleEntity> getRules(String appName) throws Exception {
  11.         String rules = configService.getConfig(appName + NacosConfigUtil.FLOW_DATA_ID_POSTFIX,
  12.                 NacosConfigUtil.GROUP_ID, 3000);
  13.         if (StringUtil.isEmpty(rules)) {
  14.             return new ArrayList<>(0);
  15.         }
  16.         return converter.convert(rules);
  17.     }
  18. }
GatewayFlowRuleNacosPublisher
  1. @Component("gatewayFlowRuleNacosPublisher")
  2. public class GatewayFlowRuleNacosPublisher implements DynamicRulePublisher<List<GatewayFlowRuleEntity>> {
  3.     // 数据源的配置服务
  4.     @Autowired
  5.     private ConfigService configService;
  6.     /**
  7.      * <p>数据通信的转换器。
  8.      * <p>在config包下的NacosConfig类中声明的Spring Bean对象。
  9.      * <p>负责将实体对象转换为json格式的字符串</p>
  10.      */
  11.     @Autowired
  12.     private Converter<List<GatewayFlowRuleEntity>, String> converter;
  13.  
  14.     @Override
  15.     public void publish(String app, List<GatewayFlowRuleEntity> rules) throws Exception {
  16.         AssertUtil.notEmpty(app, "app name cannot be empty");
  17.         if (rules == null) {
  18.             return;
  19.         }
  20.         /*
  21.          * 将规则发布到动态数据源作持久化，第一个参数是app+后缀，此处用的是-flow-rules的后缀；
  22.          * 第二个参数是nacos分组id，这个用默认提供的sentinel预留项即可；最后一个参数是数据转换
  23.          * 器，要将对象转换成统一的格式后，网络传输到nacos。
  24.          */
  25.         configService.publishConfig(app + NacosConfigUtil.FLOW_DATA_ID_POSTFIX,
  26.                 NacosConfigUtil.GROUP_ID, converter.convert(rules));
  27.     }
  28. }

3.） 对照着  GatewayFlowRuleController 新增 GatewayFlowRuleControllerV2

并 修改数据的获取方式 原先为通过  sentinelApiClient 获取 修改为通过 上面创建的 发布和获取类获取

  1. @RestController
  2. @RequestMapping(value = "/v2/gateway/flow")
  3. public class GatewayFlowRuleControllerV2 {
  4.  
  5.     private final Logger logger = LoggerFactory.getLogger(GatewayFlowRuleController.class);
  6.  
  7.     @Autowired
  8.     private InMemGatewayFlowRuleStore repository;
  9.  
  10.     @Autowired
  11.     @Qualifier("gatewayFlowRuleNacosProvider")
  12.     private DynamicRuleProvider<List<GatewayFlowRuleEntity>> ruleProvider;
  13.     @Autowired
  14.     @Qualifier("gatewayFlowRuleNacosPublisher")
  15.     private DynamicRulePublisher<List<GatewayFlowRuleEntity>> rulePublisher;
  17.  
  18.     @Autowired
  19.     private AuthService<HttpServletRequest> authService;
  20.  
  21.     @GetMapping("/list.json")
  22.     public Result<List<GatewayFlowRuleEntity>> queryFlowRules(HttpServletRequest request, String app, String ip, Integer port) {
  23.         AuthService.AuthUser authUser = authService.getAuthUser(request);
  24.         authUser.authTarget(app, AuthService.PrivilegeType.READ_RULE);
  25.  
  26.         if (StringUtil.isEmpty(app)) {
  27.             return Result.ofFail(-1, "app can't be null or empty");
  28.         }
  29.         if (StringUtil.isEmpty(ip)) {
  30.             return Result.ofFail(-1, "ip can't be null or empty");
  31.         }
  32.         if (port == null) {
  33.             return Result.ofFail(-1, "port can't be null");
  34.         }
  35.  
  36.         try {
  37.             List<GatewayFlowRuleEntity> rules = ruleProvider.getRules(app);
  38.             repository.saveAll(rules);
  39.             return Result.ofSuccess(rules);
  40.         } catch (Throwable throwable) {
  41.             logger.error("query gateway flow rules error:", throwable);
  42.             return Result.ofThrowable(-1, throwable);
  43.         }
  44.     }
  45.  
  46.     @PostMapping("/new.json")
  47.     public Result<GatewayFlowRuleEntity> addFlowRule(HttpServletRequest request, @RequestBody AddFlowRuleReqVo reqVo) {
  48.         AuthService.AuthUser authUser = authService.getAuthUser(request);
  49.  
  50.         String app = reqVo.getApp();
  51.         if (StringUtil.isBlank(app)) {
  52.             return Result.ofFail(-1, "app can't be null or empty");
  53.         }
  54.  
  55.         authUser.authTarget(app, AuthService.PrivilegeType.WRITE_RULE);
  56.  
  57.         GatewayFlowRuleEntity entity = new GatewayFlowRuleEntity();
  58.         entity.setApp(app.trim());
  59.  
  60.         String ip = reqVo.getIp();
  61.         if (StringUtil.isBlank(ip)) {
  62.             return Result.ofFail(-1, "ip can't be null or empty");
  63.         }
  64.         entity.setIp(ip.trim());
  65.  
  66.         Integer port = reqVo.getPort();
  67.         if (port == null) {
  68.             return Result.ofFail(-1, "port can't be null");
  69.         }
  70.         entity.setPort(port);
  71.  
  72.         // API类型, Route ID或API分组
  73.         Integer resourceMode = reqVo.getResourceMode();
  74.         if (resourceMode == null) {
  75.             return Result.ofFail(-1, "resourceMode can't be null");
  76.         }
  77.         if (!Arrays.asList(RESOURCE_MODE_ROUTE_ID, RESOURCE_MODE_CUSTOM_API_NAME).contains(resourceMode)) {
  78.             return Result.ofFail(-1, "invalid resourceMode: " + resourceMode);
  79.         }
  80.         entity.setResourceMode(resourceMode);
  81.  
  82.         // API名称
  83.         String resource = reqVo.getResource();
  84.         if (StringUtil.isBlank(resource)) {
  85.             return Result.ofFail(-1, "resource can't be null or empty");
  86.         }
  87.         entity.setResource(resource.trim());
  88.  
  89.         // 针对请求属性
  90.         GatewayParamFlowItemVo paramItem = reqVo.getParamItem();
  91.         if (paramItem != null) {
  92.             GatewayParamFlowItemEntity itemEntity = new GatewayParamFlowItemEntity();
  93.             entity.setParamItem(itemEntity);
  94.  
  95.             // 参数属性 0-ClientIP 1-Remote Host 2-Header 3-URL参数 4-Cookie
  96.             Integer parseStrategy = paramItem.getParseStrategy();
  97.             if (!Arrays.asList(PARAM_PARSE_STRATEGY_CLIENT_IP, PARAM_PARSE_STRATEGY_HOST, PARAM_PARSE_STRATEGY_HEADER
  98.                     , PARAM_PARSE_STRATEGY_URL_PARAM, PARAM_PARSE_STRATEGY_COOKIE).contains(parseStrategy)) {
  99.                 return Result.ofFail(-1, "invalid parseStrategy: " + parseStrategy);
  100.             }
  101.             itemEntity.setParseStrategy(paramItem.getParseStrategy());
  102.  
  103.             // 当参数属性为2-Header 3-URL参数 4-Cookie时，参数名称必填
  104.             if (Arrays.asList(PARAM_PARSE_STRATEGY_HEADER, PARAM_PARSE_STRATEGY_URL_PARAM, PARAM_PARSE_STRATEGY_COOKIE).contains(parseStrategy)) {
  105.                 // 参数名称
  106.                 String fieldName = paramItem.getFieldName();
  107.                 if (StringUtil.isBlank(fieldName)) {
  108.                     return Result.ofFail(-1, "fieldName can't be null or empty");
  109.                 }
  110.                 itemEntity.setFieldName(paramItem.getFieldName());
  111.  
  112.                 String pattern = paramItem.getPattern();
  113.                 // 如果匹配串不为空，验证匹配模式
  114.                 if (StringUtil.isNotEmpty(pattern)) {
  115.                     itemEntity.setPattern(pattern);
  116.  
  117.                     Integer matchStrategy = paramItem.getMatchStrategy();
  118.                     if (!Arrays.asList(PARAM_MATCH_STRATEGY_EXACT, PARAM_MATCH_STRATEGY_CONTAINS, PARAM_MATCH_STRATEGY_REGEX).contains(matchStrategy)) {
  119.                         return Result.ofFail(-1, "invalid matchStrategy: " + matchStrategy);
  120.                     }
  121.                     itemEntity.setMatchStrategy(matchStrategy);
  122.                 }
  123.             }
  124.         }
  125.  
  126.         // 阈值类型 0-线程数 1-QPS
  127.         Integer grade = reqVo.getGrade();
  128.         if (grade == null) {
  129.             return Result.ofFail(-1, "grade can't be null");
  130.         }
  131.         if (!Arrays.asList(FLOW_GRADE_THREAD, FLOW_GRADE_QPS).contains(grade)) {
  132.             return Result.ofFail(-1, "invalid grade: " + grade);
  133.         }
  134.         entity.setGrade(grade);
  135.  
  136.         // QPS阈值
  137.         Double count = reqVo.getCount();
  138.         if (count == null) {
  139.             return Result.ofFail(-1, "count can't be null");
  140.         }
  141.         if (count < 0) {
  142.             return Result.ofFail(-1, "count should be at lease zero");
  143.         }
  144.         entity.setCount(count);
  145.  
  146.         // 间隔
  147.         Long interval = reqVo.getInterval();
  148.         if (interval == null) {
  149.             return Result.ofFail(-1, "interval can't be null");
  150.         }
  151.         if (interval <= 0) {
  152.             return Result.ofFail(-1, "interval should be greater than zero");
  153.         }
  154.         entity.setInterval(interval);
  155.  
  156.         // 间隔单位
  157.         Integer intervalUnit = reqVo.getIntervalUnit();
  158.         if (intervalUnit == null) {
  159.             return Result.ofFail(-1, "intervalUnit can't be null");
  160.         }
  161.         if (!Arrays.asList(INTERVAL_UNIT_SECOND, INTERVAL_UNIT_MINUTE, INTERVAL_UNIT_HOUR, INTERVAL_UNIT_DAY).contains(intervalUnit)) {
  162.             return Result.ofFail(-1, "Invalid intervalUnit: " + intervalUnit);
  163.         }
  164.         entity.setIntervalUnit(intervalUnit);
  165.  
  166.         // 流控方式 0-快速失败 2-匀速排队
  167.         Integer controlBehavior = reqVo.getControlBehavior();
  168.         if (controlBehavior == null) {
  169.             return Result.ofFail(-1, "controlBehavior can't be null");
  170.         }
  171.         if (!Arrays.asList(CONTROL_BEHAVIOR_DEFAULT, CONTROL_BEHAVIOR_RATE_LIMITER).contains(controlBehavior)) {
  172.             return Result.ofFail(-1, "invalid controlBehavior: " + controlBehavior);
  173.         }
  174.         entity.setControlBehavior(controlBehavior);
  175.  
  176.         if (CONTROL_BEHAVIOR_DEFAULT == controlBehavior) {
  177.             // 0-快速失败, 则Burst size必填
  178.             Integer burst = reqVo.getBurst();
  179.             if (burst == null) {
  180.                 return Result.ofFail(-1, "burst can't be null");
  181.             }
  182.             if (burst < 0) {
  183.                 return Result.ofFail(-1, "invalid burst: " + burst);
  184.             }
  185.             entity.setBurst(burst);
  186.         } else if (CONTROL_BEHAVIOR_RATE_LIMITER == controlBehavior) {
  187.             // 1-匀速排队, 则超时时间必填
  188.             Integer maxQueueingTimeoutMs = reqVo.getMaxQueueingTimeoutMs();
  189.             if (maxQueueingTimeoutMs == null) {
  190.                 return Result.ofFail(-1, "maxQueueingTimeoutMs can't be null");
  191.             }
  192.             if (maxQueueingTimeoutMs < 0) {
  193.                 return Result.ofFail(-1, "invalid maxQueueingTimeoutMs: " + maxQueueingTimeoutMs);
  194.             }
  195.             entity.setMaxQueueingTimeoutMs(maxQueueingTimeoutMs);
  196.         }
  197.  
  198.         Date date = new Date();
  199.         entity.setGmtCreate(date);
  200.         entity.setGmtModified(date);
  201.  
  202.         try {
  203.             entity = repository.save(entity);
  204.             publishRules(entity.getApp(), entity.getIp(), entity.getPort());
  205.         } catch (Throwable throwable) {
  206.             logger.error("add gateway flow rule error:", throwable);
  207.             return Result.ofThrowable(-1, throwable);
  208.         }
  209.  
  210.         return Result.ofSuccess(entity);
  211.     }
  212.  
  213.     @PostMapping("/save.json")
  214.     public Result<GatewayFlowRuleEntity> updateFlowRule(HttpServletRequest request, @RequestBody UpdateFlowRuleReqVo reqVo) {
  215.         AuthService.AuthUser authUser = authService.getAuthUser(request);
  216.  
  217.         String app = reqVo.getApp();
  218.         if (StringUtil.isBlank(app)) {
  219.             return Result.ofFail(-1, "app can't be null or empty");
  220.         }
  221.  
  222.         authUser.authTarget(app, AuthService.PrivilegeType.WRITE_RULE);
  223.  
  224.         Long id = reqVo.getId();
  225.         if (id == null) {
  226.             return Result.ofFail(-1, "id can't be null");
  227.         }
  228.  
  229.         GatewayFlowRuleEntity entity = repository.findById(id);
  230.         if (entity == null) {
  231.             return Result.ofFail(-1, "gateway flow rule does not exist, id=" + id);
  232.         }
  233.  
  234.         // 针对请求属性
  235.         GatewayParamFlowItemVo paramItem = reqVo.getParamItem();
  236.         if (paramItem != null) {
  237.             GatewayParamFlowItemEntity itemEntity = new GatewayParamFlowItemEntity();
  238.             entity.setParamItem(itemEntity);
  239.  
  240.             // 参数属性 0-ClientIP 1-Remote Host 2-Header 3-URL参数 4-Cookie
  241.             Integer parseStrategy = paramItem.getParseStrategy();
  242.             if (!Arrays.asList(PARAM_PARSE_STRATEGY_CLIENT_IP, PARAM_PARSE_STRATEGY_HOST, PARAM_PARSE_STRATEGY_HEADER
  243.                     , PARAM_PARSE_STRATEGY_URL_PARAM, PARAM_PARSE_STRATEGY_COOKIE).contains(parseStrategy)) {
  244.                 return Result.ofFail(-1, "invalid parseStrategy: " + parseStrategy);
  245.             }
  246.             itemEntity.setParseStrategy(paramItem.getParseStrategy());
  247.  
  248.             // 当参数属性为2-Header 3-URL参数 4-Cookie时，参数名称必填
  249.             if (Arrays.asList(PARAM_PARSE_STRATEGY_HEADER, PARAM_PARSE_STRATEGY_URL_PARAM, PARAM_PARSE_STRATEGY_COOKIE).contains(parseStrategy)) {
  250.                 // 参数名称
  251.                 String fieldName = paramItem.getFieldName();
  252.                 if (StringUtil.isBlank(fieldName)) {
  253.                     return Result.ofFail(-1, "fieldName can't be null or empty");
  254.                 }
  255.                 itemEntity.setFieldName(paramItem.getFieldName());
  256.  
  257.                 String pattern = paramItem.getPattern();
  258.                 // 如果匹配串不为空，验证匹配模式
  259.                 if (StringUtil.isNotEmpty(pattern)) {
  260.                     itemEntity.setPattern(pattern);
  261.  
  262.                     Integer matchStrategy = paramItem.getMatchStrategy();
  263.                     if (!Arrays.asList(PARAM_MATCH_STRATEGY_EXACT, PARAM_MATCH_STRATEGY_CONTAINS, PARAM_MATCH_STRATEGY_REGEX).contains(matchStrategy)) {
  264.                         return Result.ofFail(-1, "invalid matchStrategy: " + matchStrategy);
  265.                     }
  266.                     itemEntity.setMatchStrategy(matchStrategy);
  267.                 }
  268.             }
  269.         } else {
  270.             entity.setParamItem(null);
  271.         }
  272.  
  273.         // 阈值类型 0-线程数 1-QPS
  274.         Integer grade = reqVo.getGrade();
  275.         if (grade == null) {
  276.             return Result.ofFail(-1, "grade can't be null");
  277.         }
  278.         if (!Arrays.asList(FLOW_GRADE_THREAD, FLOW_GRADE_QPS).contains(grade)) {
  279.             return Result.ofFail(-1, "invalid grade: " + grade);
  280.         }
  281.         entity.setGrade(grade);
  282.  
  283.         // QPS阈值
  284.         Double count = reqVo.getCount();
  285.         if (count == null) {
  286.             return Result.ofFail(-1, "count can't be null");
  287.         }
  288.         if (count < 0) {
  289.             return Result.ofFail(-1, "count should be at lease zero");
  290.         }
  291.         entity.setCount(count);
  292.  
  293.         // 间隔
  294.         Long interval = reqVo.getInterval();
  295.         if (interval == null) {
  296.             return Result.ofFail(-1, "interval can't be null");
  297.         }
  298.         if (interval <= 0) {
  299.             return Result.ofFail(-1, "interval should be greater than zero");
  300.         }
  301.         entity.setInterval(interval);
  302.  
  303.         // 间隔单位
  304.         Integer intervalUnit = reqVo.getIntervalUnit();
  305.         if (intervalUnit == null) {
  306.             return Result.ofFail(-1, "intervalUnit can't be null");
  307.         }
  308.         if (!Arrays.asList(INTERVAL_UNIT_SECOND, INTERVAL_UNIT_MINUTE, INTERVAL_UNIT_HOUR, INTERVAL_UNIT_DAY).contains(intervalUnit)) {
  309.             return Result.ofFail(-1, "Invalid intervalUnit: " + intervalUnit);
  310.         }
  311.         entity.setIntervalUnit(intervalUnit);
  312.  
  313.         // 流控方式 0-快速失败 2-匀速排队
  314.         Integer controlBehavior = reqVo.getControlBehavior();
  315.         if (controlBehavior == null) {
  316.             return Result.ofFail(-1, "controlBehavior can't be null");
  317.         }
  318.         if (!Arrays.asList(CONTROL_BEHAVIOR_DEFAULT, CONTROL_BEHAVIOR_RATE_LIMITER).contains(controlBehavior)) {
  319.             return Result.ofFail(-1, "invalid controlBehavior: " + controlBehavior);
  320.         }
  321.         entity.setControlBehavior(controlBehavior);
  322.  
  323.         if (CONTROL_BEHAVIOR_DEFAULT == controlBehavior) {
  324.             // 0-快速失败, 则Burst size必填
  325.             Integer burst = reqVo.getBurst();
  326.             if (burst == null) {
  327.                 return Result.ofFail(-1, "burst can't be null");
  328.             }
  329.             if (burst < 0) {
  330.                 return Result.ofFail(-1, "invalid burst: " + burst);
  331.             }
  332.             entity.setBurst(burst);
  333.         } else if (CONTROL_BEHAVIOR_RATE_LIMITER == controlBehavior) {
  334.             // 2-匀速排队, 则超时时间必填
  335.             Integer maxQueueingTimeoutMs = reqVo.getMaxQueueingTimeoutMs();
  336.             if (maxQueueingTimeoutMs == null) {
  337.                 return Result.ofFail(-1, "maxQueueingTimeoutMs can't be null");
  338.             }
  339.             if (maxQueueingTimeoutMs < 0) {
  340.                 return Result.ofFail(-1, "invalid maxQueueingTimeoutMs: " + maxQueueingTimeoutMs);
  341.             }
  342.             entity.setMaxQueueingTimeoutMs(maxQueueingTimeoutMs);
  343.         }
  344.  
  345.         Date date = new Date();
  346.         entity.setGmtModified(date);
  347.  
  348.         try {
  349.             entity = repository.save(entity);
  350.             publishRules(entity.getApp(), entity.getIp(), entity.getPort());
  351.         } catch (Throwable throwable) {
  352.             logger.error("update gateway flow rule error:", throwable);
  353.             return Result.ofThrowable(-1, throwable);
  354.         }
  355.  
  356.         return Result.ofSuccess(entity);
  357.     }
  358.  
  359.  
  360.     @PostMapping("/delete.json")
  361.     public Result<Long> deleteFlowRule(HttpServletRequest request, Long id) {
  362.         AuthService.AuthUser authUser = authService.getAuthUser(request);
  363.  
  364.         if (id == null) {
  365.             return Result.ofFail(-1, "id can't be null");
  366.         }
  367.  
  368.         GatewayFlowRuleEntity oldEntity = repository.findById(id);
  369.         if (oldEntity == null) {
  370.             return Result.ofSuccess(null);
  371.         }
  372.  
  373.         authUser.authTarget(oldEntity.getApp(), AuthService.PrivilegeType.DELETE_RULE);
  374.  
  375.         try {
  376.             repository.delete(id);
  377.             publishRules(oldEntity.getApp(), oldEntity.getIp(), oldEntity.getPort());
  378.         } catch (Throwable throwable) {
  379.             logger.error("delete gateway flow rule error:", throwable);
  380.             return Result.ofThrowable(-1, throwable);
  381.         }
  382.  
  383.         return Result.ofSuccess(id);
  384.     }
  385.  
  386.     /**
  387.      * <h3>发布规则统一逻辑</h3>
  388.      *
  389.      * <p>规则都是存在本地内存中的，先从内存中获取所有当前要发布规则应用的规则，是一个List</p>
  390.      * <p>将全量的规则以一定的格式发布到数据源中，进行统一更新</p>
  391.      *
  392.      * @param app  应用名称
  393.      * @param ip   应用IP
  394.      * @param port 应用端口
  395.      * @throws Exception 远程发布，会发生异常，要进行异常处理
  396.      */
  397.     private void publishRules(String app, String ip, Integer port) throws Exception {
  398.         List<GatewayFlowRuleEntity> rules = repository.findAllByMachine(MachineInfo.of(app, ip, port));
  399.         rulePublisher.publish(app, rules);
  400.     }
  401. }

GatewayApiController 同理。

4） 修改前端代码

复制 resources.app.scripts.controllers.gateway.flow.js

-> resources.app.scripts.controllers.gateway.flow_v2.js

并修改 

GatewayFlowService -> GatewayFlowServiceV2

复制 resources.app.views.gateway.flow.html

-> resources.app.views.gateway.flow_v2.html

复制 resources/app/scripts/services/gateway/flow_service.js

-> resources/app/scripts/services/gateway/flow_service_v2.js

修改 GatewayFlowService -> GatewayFlowServiceV2 并 修改下面的url 加/v

修改 resources/app/scripts/app.js  为

//     .state("dashboard.gatewayFlow", {
//     templateUrl: "app/views/gateway/flow.html",
//     url: "/gateway/flow/:app",
//     controller: "GatewayFlowCtl",
//     resolve: {
//         loadMyFiles: ["$ocLazyLoad", function (e) {
//             return e.load({name: "sentinelDashboardApp", files: ["app/scripts/controllers/gateway/flow.js"]})
//         }]
//     }
// })
    .state('dashboard.gatewayFlowV2', {
        templateUrl: 'app/views/gateway/flow_v2.html',
        url: '/v2/gateway/flow/:app',
        controller: 'GatewayFlowCtlV2',
        resolve: {
            loadMyFiles: ['$ocLazyLoad', function ($ocLazyLoad) {
                return $ocLazyLoad.load({
                    name: 'sentinelDashboardApp',
                    files: [
                        'app/scripts/controllers/gateway/flow_v2.js',
                    ]
                });
            }]
        }
    })

打包启动 发布规则后 在nacos 可查看到  发布的规则

注：

但我本地不适用这个 可以参考修改 resources/dist/js/app.js

resources/dist/js/app.js 修改后的代码为

  1. "use strict";
  2. var app;
  3. angular.module("sentinelDashboardApp", ["oc.lazyLoad", "ui.router", "ui.bootstrap", "angular-loading-bar", "ngDialog", "ui.bootstrap.datetimepicker", "ui-notification", "rzTable", "angular-clipboard", "selectize", "angularUtils.directives.dirPagination"]).factory("AuthInterceptor", ["$window", "$state", function (t, r) {
  4.     return {
  5.         responseError: function (e) {
  6.             return 401 === e.status && (t.localStorage.removeItem("session_sentinel_admin"), r.go("login")), e
  7.         }, response: function (e) {
  8.             return e
  9.         }, request: function (e) {
  10.             return e
  11.         }, requestError: function (e) {
  12.             return e
  13.         }
  14.     }
  15. }]).config(["$stateProvider", "$urlRouterProvider", "$ocLazyLoadProvider", "$httpProvider", function (e, t, r, a) {
  16.     a.interceptors.push("AuthInterceptor"), r.config({
  17.         debug: !1,
  18.         events: !0
  19.     }), t.otherwise("/dashboard/home"), e.state("login", {
  20.         url: "/login",
  21.         templateUrl: "app/views/login.html",
  22.         controller: "LoginCtl",
  23.         resolve: {
  24.             loadMyFiles: ["$ocLazyLoad", function (e) {
  25.                 return e.load({name: "sentinelDashboardApp", files: ["app/scripts/controllers/login.js"]})
  26.             }]
  27.         }
  28.     }).state("dashboard", {
  29.         url: "/dashboard",
  30.         templateUrl: "app/views/dashboard/main.html",
  31.         resolve: {
  32.             loadMyDirectives: ["$ocLazyLoad", function (e) {
  33.                 return e.load({
  34.                     name: "sentinelDashboardApp",
  35.                     files: ["app/scripts/directives/header/header.js", "app/scripts/directives/sidebar/sidebar.js", "app/scripts/directives/sidebar/sidebar-search/sidebar-search.js"]
  36.                 })
  37.             }]
  38.         }
  39.     }).state("dashboard.home", {
  40.         url: "/home",
  41.         templateUrl: "app/views/dashboard/home.html",
  42.         resolve: {
  43.             loadMyFiles: ["$ocLazyLoad", function (e) {
  44.                 return e.load({name: "sentinelDashboardApp", files: ["app/scripts/controllers/main.js"]})
  45.             }]
  46.         }
  47.     }).state("dashboard.flowV1", {
  48.         templateUrl: "app/views/flow_v1.html",
  49.         url: "/flow/:app",
  50.         controller: "FlowControllerV1",
  51.         resolve: {
  52.             loadMyFiles: ["$ocLazyLoad", function (e) {
  53.                 return e.load({name: "sentinelDashboardApp", files: ["app/scripts/controllers/flow_v1.js"]})
  54.             }]
  55.         }
  56.     }).state("dashboard.flow", {
  57.         templateUrl: "app/views/flow_v2.html",
  58.         url: "/v2/flow/:app",
  59.         controller: "FlowControllerV2",
  60.         resolve: {
  61.             loadMyFiles: ["$ocLazyLoad", function (e) {
  62.                 return e.load({name: "sentinelDashboardApp", files: ["app/scripts/controllers/flow_v2.js"]})
  63.             }]
  64.         }
  65.     }).state("dashboard.paramFlow", {
  66.         templateUrl: "app/views/param_flow.html",
  67.         url: "/paramFlow/:app",
  68.         controller: "ParamFlowController",
  69.         resolve: {
  70.             loadMyFiles: ["$ocLazyLoad", function (e) {
  71.                 return e.load({name: "sentinelDashboardApp", files: ["app/scripts/controllers/param_flow.js"]})
  72.             }]
  73.         }
  74.     }).state("dashboard.clusterAppAssignManage", {
  75.         templateUrl: "app/views/cluster_app_assign_manage.html",
  76.         url: "/cluster/assign_manage/:app",
  77.         controller: "SentinelClusterAppAssignManageController",
  78.         resolve: {
  79.             loadMyFiles: ["$ocLazyLoad", function (e) {
  80.                 return e.load({
  81.                     name: "sentinelDashboardApp",
  82.                     files: ["app/scripts/controllers/cluster_app_assign_manage.js"]
  83.                 })
  84.             }]
  85.         }
  86.     }).state("dashboard.clusterAppServerList", {
  87.         templateUrl: "app/views/cluster_app_server_list.html",
  88.         url: "/cluster/server/:app",
  89.         controller: "SentinelClusterAppServerListController",
  90.         resolve: {
  91.             loadMyFiles: ["$ocLazyLoad", function (e) {
  92.                 return e.load({
  93.                     name: "sentinelDashboardApp",
  94.                     files: ["app/scripts/controllers/cluster_app_server_list.js"]
  95.                 })
  96.             }]
  97.         }
  98.     }).state("dashboard.clusterAppClientList", {
  99.         templateUrl: "app/views/cluster_app_client_list.html",
  100.         url: "/cluster/client/:app",
  101.         controller: "SentinelClusterAppTokenClientListController",
  102.         resolve: {
  103.             loadMyFiles: ["$ocLazyLoad", function (e) {
  104.                 return e.load({
  105.                     name: "sentinelDashboardApp",
  106.                     files: ["app/scripts/controllers/cluster_app_token_client_list.js"]
  107.                 })
  108.             }]
  109.         }
  110.     }).state("dashboard.clusterSingle", {
  111.         templateUrl: "app/views/cluster_single_config.html",
  112.         url: "/cluster/single/:app",
  113.         controller: "SentinelClusterSingleController",
  114.         resolve: {
  115.             loadMyFiles: ["$ocLazyLoad", function (e) {
  116.                 return e.load({name: "sentinelDashboardApp", files: ["app/scripts/controllers/cluster_single.js"]})
  117.             }]
  118.         }
  119.     }).state("dashboard.authority", {
  120.         templateUrl: "app/views/authority.html",
  121.         url: "/authority/:app",
  122.         controller: "AuthorityRuleController",
  123.         resolve: {
  124.             loadMyFiles: ["$ocLazyLoad", function (e) {
  125.                 return e.load({name: "sentinelDashboardApp", files: ["app/scripts/controllers/authority.js"]})
  126.             }]
  127.         }
  128.     }).state("dashboard.degrade", {
  129.         templateUrl: "app/views/degrade.html",
  130.         url: "/degrade/:app",
  131.         controller: "DegradeCtl",
  132.         resolve: {
  133.             loadMyFiles: ["$ocLazyLoad", function (e) {
  134.                 return e.load({name: "sentinelDashboardApp", files: ["app/scripts/controllers/degrade.js"]})
  135.             }]
  136.         }
  137.     }).state("dashboard.system", {
  138.         templateUrl: "app/views/system.html",
  139.         url: "/system/:app",
  140.         controller: "SystemCtl",
  141.         resolve: {
  142.             loadMyFiles: ["$ocLazyLoad", function (e) {
  143.                 return e.load({name: "sentinelDashboardApp", files: ["app/scripts/controllers/system.js"]})
  144.             }]
  145.         }
  146.     }).state("dashboard.machine", {
  147.         templateUrl: "app/views/machine.html",
  148.         url: "/app/:app",
  149.         controller: "MachineCtl",
  150.         resolve: {
  151.             loadMyFiles: ["$ocLazyLoad", function (e) {
  152.                 return e.load({name: "sentinelDashboardApp", files: ["app/scripts/controllers/machine.js"]})
  153.             }]
  154.         }
  155.     }).state("dashboard.identity", {
  156.         templateUrl: "app/views/identity.html",
  157.         url: "/identity/:app",
  158.         controller: "IdentityCtl",
  159.         resolve: {
  160.             loadMyFiles: ["$ocLazyLoad", function (e) {
  161.                 return e.load({name: "sentinelDashboardApp", files: ["app/scripts/controllers/identity.js"]})
  162.             }]
  163.         }
  164.     }).state("dashboard.gatewayIdentity", {
  165.         templateUrl: "app/views/gateway/identity.html",
  166.         url: "/gateway/identity/:app",
  167.         controller: "GatewayIdentityCtl",
  168.         resolve: {
  169.             loadMyFiles: ["$ocLazyLoad", function (e) {
  170.                 return e.load({name: "sentinelDashboardApp", files: ["app/scripts/controllers/gateway/identity.js"]})
  171.             }]
  172.         }
  173.     }).state("dashboard.metric", {
  174.         templateUrl: "app/views/metric.html",
  175.         url: "/metric/:app",
  176.         controller: "MetricCtl",
  177.         resolve: {
  178.             loadMyFiles: ["$ocLazyLoad", function (e) {
  179.                 return e.load({name: "sentinelDashboardApp", files: ["app/scripts/controllers/metric.js"]})
  180.             }]
  181.         }
  182.     }).state("dashboard.gatewayApi", {
  183.         templateUrl: "app/views/gateway/api.html",
  184.         url: "/gateway/api/:app",
  185.         controller: "GatewayApiCtl",
  186.         resolve: {
  187.             loadMyFiles: ["$ocLazyLoad", function (e) {
  188.                 return e.load({name: "sentinelDashboardApp", files: ["app/scripts/controllers/gateway/api.js"]})
  189.             }]
  190.         }
  191.     })
  192.     //     .state("dashboard.gatewayFlow", {
  193.     //     templateUrl: "app/views/gateway/flow.html",
  194.     //     url: "/gateway/flow/:app",
  195.     //     controller: "GatewayFlowCtl",
  196.     //     resolve: {
  197.     //         loadMyFiles: ["$ocLazyLoad", function (e) {
  198.     //             return e.load({name: "sentinelDashboardApp", files: ["app/scripts/controllers/gateway/flow.js"]})
  199.     //         }]
  200.     //     }
  201.     // })
  202.         .state('dashboard.gatewayFlowV2', {
  203.             templateUrl: 'app/views/gateway/flow_v2.html',
  204.             url: '/v2/gateway/flow/:app',
  205.             controller: 'GatewayFlowCtlV2',
  206.             resolve: {
  207.                 loadMyFiles: ['$ocLazyLoad', function ($ocLazyLoad) {
  208.                     return $ocLazyLoad.load({
  209.                         name: 'sentinelDashboardApp',
  210.                         files: [
  211.                             'app/scripts/controllers/gateway/flow_v2.js',
  212.                         ]
  213.                     });
  214.                 }]
  215.             }
  216.         })
  217. }]), (app = angular.module("sentinelDashboardApp")).filter("range", [function () {
  218.     return function (e, t) {
  219.         if (isNaN(t) || t <= 0) return [];
  220.         e = [];
  221.         for (var r = 1; r <= t; r++) e.push(r);
  222.         return e
  223.     }
  224. }]), (app = angular.module("sentinelDashboardApp")).service("AuthService", ["$http", function (t) {
  225.     this.login = function (e) {
  226.         return t({url: "/auth/login", params: e, method: "POST"})
  227.     }, this.logout = function () {
  228.         return t({url: "/auth/logout", method: "POST"})
  229.     }
  230. }]), (app = angular.module("sentinelDashboardApp")).service("AppService", ["$http", function (e) {
  231.     this.getApps = function () {
  232.         return e({url: "app/briefinfos.json", method: "GET"})
  233.     }
  234. }]), (app = angular.module("sentinelDashboardApp")).service("FlowServiceV1", ["$http", function (a) {
  235.     function t(e) {
  236.         return void 0 === e || "" === e || isNaN(e) || e <= 0
  237.     }
  238.  
  239.     this.queryMachineRules = function (e, t, r) {
  240.         return a({url: "/v1/flow/rules", params: {app: e, ip: t, port: r}, method: "GET"})
  241.     }, this.newRule = function (e) {
  242.         e.resource, e.limitApp, e.grade, e.count, e.strategy, e.refResource, e.controlBehavior, e.warmUpPeriodSec, e.maxQueueingTimeMs, e.app, e.ip, e.port;
  243.         return a({url: "/v1/flow/rule", data: e, method: "POST"})
  244.     }, this.saveRule = function (e) {
  245.         var t = {
  246.             id: e.id,
  247.             resource: e.resource,
  248.             limitApp: e.limitApp,
  249.             grade: e.grade,
  250.             count: e.count,
  251.             strategy: e.strategy,
  252.             refResource: e.refResource,
  253.             controlBehavior: e.controlBehavior,
  254.             warmUpPeriodSec: e.warmUpPeriodSec,
  255.             maxQueueingTimeMs: e.maxQueueingTimeMs
  256.         };
  257.         return a({url: "/v1/flow/save.json", params: t, method: "PUT"})
  258.     }, this.deleteRule = function (e) {
  259.         var t = {id: e.id, app: e.app};
  260.         return a({url: "/v1/flow/delete.json", params: t, method: "DELETE"})
  261.     }, this.checkRuleValid = function (e) {
  262.         return void 0 === e.resource || "" === e.resource ? (alert("资源名称不能为空"), !1) : void 0 === e.count || e.count < 0 ? (alert("限流阈值必须大于等于 0"), !1) : void 0 === e.strategy || e.strategy < 0 ? (alert("无效的流控模式"), !1) : 1 != e.strategy && 2 != e.strategy || void 0 !== e.refResource && "" != e.refResource ? void 0 === e.controlBehavior || e.controlBehavior < 0 ? (alert("无效的流控整形方式"), !1) : 1 == e.controlBehavior && t(e.warmUpPeriodSec) ? (alert("预热时长必须大于 0"), !1) : 2 == e.controlBehavior && t(e.maxQueueingTimeMs) ? (alert("排队超时时间必须大于 0"), !1) : !e.clusterMode || void 0 !== e.clusterConfig && void 0 !== e.clusterConfig.thresholdType || (alert("集群限流配置不正确"), !1) : (alert("请填写关联资源或入口"), !1)
  263.     }
  264. }]), (app = angular.module("sentinelDashboardApp")).service("FlowServiceV2", ["$http", function (a) {
  265.     function t(e) {
  266.         return void 0 === e || "" === e || isNaN(e) || e <= 0
  267.     }
  268.  
  269.     this.queryMachineRules = function (e, t, r) {
  270.         return a({url: "/v2/flow/rules", params: {app: e, ip: t, port: r}, method: "GET"})
  271.     }, this.newRule = function (e) {
  272.         return a({url: "/v2/flow/rule", data: e, method: "POST"})
  273.     }, this.saveRule = function (e) {
  274.         return a({url: "/v2/flow/rule/" + e.id, data: e, method: "PUT"})
  275.     }, this.deleteRule = function (e) {
  276.         return a({url: "/v2/flow/rule/" + e.id, method: "DELETE"})
  277.     }, this.checkRuleValid = function (e) {
  278.         return void 0 === e.resource || "" === e.resource ? (alert("资源名称不能为空"), !1) : void 0 === e.count || e.count < 0 ? (alert("限流阈值必须大于等于 0"), !1) : void 0 === e.strategy || e.strategy < 0 ? (alert("无效的流控模式"), !1) : 1 != e.strategy && 2 != e.strategy || void 0 !== e.refResource && "" != e.refResource ? void 0 === e.controlBehavior || e.controlBehavior < 0 ? (alert("无效的流控整形方式"), !1) : 1 == e.controlBehavior && t(e.warmUpPeriodSec) ? (alert("预热时长必须大于 0"), !1) : 2 == e.controlBehavior && t(e.maxQueueingTimeMs) ? (alert("排队超时时间必须大于 0"), !1) : !e.clusterMode || void 0 !== e.clusterConfig && void 0 !== e.clusterConfig.thresholdType || (alert("集群限流配置不正确"), !1) : (alert("请填写关联资源或入口"), !1)
  279.     }
  280. }]), (app = angular.module("sentinelDashboardApp")).service("DegradeService", ["$http", function (a) {
  281.     this.queryMachineRules = function (e, t, r) {
  282.         return a({url: "degrade/rules.json", params: {app: e, ip: t, port: r}, method: "GET"})
  283.     }, this.newRule = function (e) {
  284.         var t = {
  285.             id: e.id,
  286.             resource: e.resource,
  287.             limitApp: e.limitApp,
  288.             count: e.count,
  289.             timeWindow: e.timeWindow,
  290.             grade: e.grade,
  291.             app: e.app,
  292.             ip: e.ip,
  293.             port: e.port
  294.         };
  295.         return a({url: "/degrade/new.json", params: t, method: "GET"})
  296.     }, this.saveRule = function (e) {
  297.         var t = {
  298.             id: e.id,
  299.             resource: e.resource,
  300.             limitApp: e.limitApp,
  301.             grade: e.grade,
  302.             count: e.count,
  303.             timeWindow: e.timeWindow
  304.         };
  305.         return a({url: "/degrade/save.json", params: t, method: "GET"})
  306.     }, this.deleteRule = function (e) {
  307.         var t = {id: e.id, app: e.app};
  308.         return a({url: "/degrade/delete.json", params: t, method: "GET"})
  309.     }, this.checkRuleValid = function (e) {
  310.         return void 0 === e.resource || "" === e.resource ? (alert("资源名称不能为空"), !1) : void 0 === e.grade || e.grade < 0 ? (alert("未知的降级策略"), !1) : void 0 === e.count || "" === e.count || e.count < 0 ? (alert("降级阈值不能为空或小于 0"), !1) : void 0 === e.timeWindow || "" === e.timeWindow || e.timeWindow <= 0 ? (alert("降级时间窗口必须大于 0"), !1) : !(1 == e.grade && 1 < e.count) || (alert("异常比率超出范围：[0.0 - 1.0]"), !1)
  311.     }
  312. }]), (app = angular.module("sentinelDashboardApp")).service("SystemService", ["$http", function (a) {
  313.     this.queryMachineRules = function (e, t, r) {
  314.         return a({url: "system/rules.json", params: {app: e, ip: t, port: r}, method: "GET"})
  315.     }, this.newRule = function (e) {
  316.         var t = {app: e.app, ip: e.ip, port: e.port};
  317.         return 0 == e.grade ? t.avgLoad = e.avgLoad : 1 == e.grade ? t.avgRt = e.avgRt : 2 == e.grade ? t.maxThread = e.maxThread : 3 == e.grade && (t.qps = e.qps), a({
  318.             url: "/system/new.json",
  319.             params: t,
  320.             method: "GET"
  321.         })
  322.     }, this.saveRule = function (e) {
  323.         var t = {id: e.id};
  324.         return 0 == e.grade ? t.avgLoad = e.avgLoad : 1 == e.grade ? t.avgRt = e.avgRt : 2 == e.grade ? t.maxThread = e.maxThread : 3 == e.grade && (t.qps = e.qps), a({
  325.             url: "/system/save.json",
  326.             params: t,
  327.             method: "GET"
  328.         })
  329.     }, this.deleteRule = function (e) {
  330.         var t = {id: e.id, app: e.app};
  331.         return a({url: "/system/delete.json", params: t, method: "GET"})
  332.     }
  333. }]), (app = angular.module("sentinelDashboardApp")).service("MachineService", ["$http", "$httpParamSerializerJQLike", function (a, o) {
  334.     this.getAppMachines = function (e) {
  335.         return a({url: "app/" + e + "/machines.json", method: "GET"})
  336.     }, this.removeAppMachine = function (e, t, r) {
  337.         return a({
  338.             url: "app/" + e + "/machine/remove.json",
  339.             method: "POST",
  340.             headers: {"Content-type": "application/x-www-form-urlencoded; charset=UTF-8"},
  341.             data: o({ip: t, port: r})
  342.         })
  343.     }
  344. }]), (app = angular.module("sentinelDashboardApp")).service("IdentityService", ["$http", function (a) {
  345.     this.fetchIdentityOfMachine = function (e, t, r) {
  346.         return a({url: "resource/machineResource.json", params: {ip: e, port: t, searchKey: r}, method: "GET"})
  347.     }, this.fetchClusterNodeOfMachine = function (e, t, r) {
  348.         return a({
  349.             url: "resource/machineResource.json",
  350.             params: {ip: e, port: t, type: "cluster", searchKey: r},
  351.             method: "GET"
  352.         })
  353.     }
  354. }]), (app = angular.module("sentinelDashboardApp")).service("MetricService", ["$http", function (i) {
  355.     this.queryAppSortedIdentities = function (e) {
  356.         return i({url: "/metric/queryTopResourceMetric.json", params: e, method: "GET"})
  357.     }, this.queryByAppAndIdentity = function (e) {
  358.         return i({url: "/metric/queryByAppAndResource.json", params: e, method: "GET"})
  359.     }, this.queryByMachineAndIdentity = function (e, t, r, a, o) {
  360.         var l = {ip: e, port: t, identity: r, startTime: a.getTime(), endTime: o.getTime()};
  361.         return i({url: "/metric/queryByAppAndResource.json", params: l, method: "GET"})
  362.     }
  363. }]), angular.module("sentinelDashboardApp").service("ParamFlowService", ["$http", function (a) {
  364.     function o(e) {
  365.         return !("int" !== (r = e.classType) && "double" !== r && "float" !== r && "long" !== r && "short" !== r || void 0 !== (t = e.object) && "" !== t && !isNaN(t)) || (!!("byte" === e.classType && (a = e.object, o = -128, l = 127, void 0 === a || "" === a || isNaN(a) || a < o || l < a)) || (void 0 === e.object || void 0 === e.classType || (void 0 === (i = e.count) || "" === i || isNaN(i) || i < 0)));
  366.         var t, r, a, o, l, i
  367.     }
  368.  
  369.     this.queryMachineRules = function (e, t, r) {
  370.         return a({url: "/paramFlow/rules", params: {app: e, ip: t, port: r}, method: "GET"})
  371.     }, this.addNewRule = function (e) {
  372.         return a({url: "/paramFlow/rule", data: e, method: "POST"})
  373.     }, this.saveRule = function (e) {
  374.         return a({url: "/paramFlow/rule/" + e.id, data: e, method: "PUT"})
  375.     }, this.deleteRule = function (e) {
  376.         return a({url: "/paramFlow/rule/" + e.id, method: "DELETE"})
  377.     }, this.checkRuleValid = function (e) {
  378.         if (!e.resource || "" === e.resource) return alert("资源名称不能为空"), !1;
  379.         if (1 != e.grade) return alert("未知的限流模式"), !1;
  380.         if (e.count < 0) return alert("限流阈值必须大于等于 0"), !1;
  381.         if (void 0 === e.paramIdx || "" === e.paramIdx || isNaN(e.paramIdx) || e.paramIdx < 0) return alert("热点参数索引必须大于等于 0"), !1;
  382.         if (void 0 !== e.paramFlowItemList) for (var t = 0; t < e.paramFlowItemList.length; t++) {
  383.             var r = e.paramFlowItemList[t];
  384.             if (o(r)) return alert("热点参数例外项不合法，请检查值和类型是否正确：参数为 " + r.object + ", 类型为 " + r.classType + ", 限流阈值为 " + r.count), !1
  385.         }
  386.         return !0
  387.     }
  388. }]), angular.module("sentinelDashboardApp").service("AuthorityRuleService", ["$http", function (a) {
  389.     this.queryMachineRules = function (e, t, r) {
  390.         return a({url: "/authority/rules", params: {app: e, ip: t, port: r}, method: "GET"})
  391.     }, this.addNewRule = function (e) {
  392.         return a({url: "/authority/rule", data: e, method: "POST"})
  393.     }, this.saveRule = function (e) {
  394.         return a({url: "/authority/rule/" + e.id, data: e, method: "PUT"})
  395.     }, this.deleteRule = function (e) {
  396.         return a({url: "/authority/rule/" + e.id, method: "DELETE"})
  397.     }, this.checkRuleValid = function (e) {
  398.         return void 0 === e.resource || "" === e.resource ? (alert("资源名称不能为空"), !1) : void 0 === e.limitApp || "" === e.limitApp ? (alert("流控针对应用不能为空"), !1) : void 0 !== e.strategy || (alert("必须选择黑白名单模式"), !1)
  399.     }
  400. }]), angular.module("sentinelDashboardApp").service("ClusterStateService", ["$http", function (a) {
  401.     this.fetchClusterUniversalStateSingle = function (e, t, r) {
  402.         return a({url: "/cluster/state_single", params: {app: e, ip: t, port: r}, method: "GET"})
  403.     }, this.fetchClusterUniversalStateOfApp = function (e) {
  404.         return a({url: "/cluster/state/" + e, method: "GET"})
  405.     }, this.fetchClusterServerStateOfApp = function (e) {
  406.         return a({url: "/cluster/server_state/" + e, method: "GET"})
  407.     }, this.fetchClusterClientStateOfApp = function (e) {
  408.         return a({url: "/cluster/client_state/" + e, method: "GET"})
  409.     }, this.modifyClusterConfig = function (e) {
  410.         return a({url: "/cluster/config/modify_single", data: e, method: "POST"})
  411.     }, this.applyClusterFullAssignOfApp = function (e, t) {
  412.         return a({url: "/cluster/assign/all_server/" + e, data: t, method: "POST"})
  413.     }, this.applyClusterSingleServerAssignOfApp = function (e, t) {
  414.         return a({url: "/cluster/assign/single_server/" + e, data: t, method: "POST"})
  415.     }, this.applyClusterServerBatchUnbind = function (e, t) {
  416.         return a({url: "/cluster/assign/unbind_server/" + e, data: t, method: "POST"})
  417.     }
  418. }]), (app = angular.module("sentinelDashboardApp")).service("GatewayApiService", ["$http", function (a) {
  419.     this.queryApis = function (e, t, r) {
  420.         return a({url: "/gateway/api/list.json", params: {app: e, ip: t, port: r}, method: "GET"})
  421.     }, this.newApi = function (e) {
  422.         return a({url: "/gateway/api/new.json", data: e, method: "POST"})
  423.     }, this.saveApi = function (e) {
  424.         return a({url: "/gateway/api/save.json", data: e, method: "POST"})
  425.     }, this.deleteApi = function (e) {
  426.         var t = {id: e.id, app: e.app};
  427.         return a({url: "/gateway/api/delete.json", params: t, method: "POST"})
  428.     }, this.checkApiValid = function (e, t) {
  429.         if (void 0 === e.apiName || "" === e.apiName) return alert("API名称不能为空"), !1;
  430.         if (null == e.predicateItems || 0 === e.predicateItems.length) return alert("至少有一个匹配规则"), !1;
  431.         for (var r = 0; r < e.predicateItems.length; r++) {
  432.             var a = e.predicateItems[r].pattern;
  433.             if (void 0 === a || "" === a) return alert("匹配串不能为空，请检查"), !1
  434.         }
  435.         return -1 === t.indexOf(e.apiName) || (alert("API名称(" + e.apiName + ")已存在"), !1)
  436.     }
  437. }]), (app = angular.module("sentinelDashboardApp")).service("GatewayFlowService", ["$http", function (a) {
  438.     this.queryRules = function (e, t, r) {
  439.         return a({url: "/gateway/flow/list.json", params: {app: e, ip: t, port: r}, method: "GET"})
  440.     }, this.newRule = function (e) {
  441.         return a({url: "/gateway/flow/new.json", data: e, method: "POST"})
  442.     }, this.saveRule = function (e) {
  443.         return a({url: "/gateway/flow/save.json", data: e, method: "POST"})
  444.     }, this.deleteRule = function (e) {
  445.         var t = {id: e.id, app: e.app};
  446.         return a({url: "/gateway/flow/delete.json", params: t, method: "POST"})
  447.     }, this.checkRuleValid = function (e) {
  448.         if (void 0 === e.resource || "" === e.resource) return alert("API名称不能为空"), !1;
  449.         if (null != e.paramItem && (2 == e.paramItem.parseStrategy || 3 == e.paramItem.parseStrategy || 4 == e.paramItem.parseStrategy)) {
  450.             if (void 0 === e.paramItem.fieldName || "" === e.paramItem.fieldName) return alert("当参数属性为Header、URL参数、Cookie时，参数名称不能为空"), !1;
  451.             if ("" === e.paramItem.pattern) return alert("匹配串不能为空"), !1
  452.         }
  453.         return !(void 0 === e.count || e.count < 0) || (alert((1 === e.grade ? "QPS阈值" : "线程数") + "必须大于等于 0"), !1)
  454.     }
  455. }]), (app = angular.module("sentinelDashboardApp")).service("GatewayFlowServiceV2", ["$http", function (a) {
  456.     this.queryRules = function (e, t, r) {
  457.         return a({url: "/v2/gateway/flow/list.json", params: {app: e, ip: t, port: r}, method: "GET"})
  458.     }, this.newRule = function (e) {
  459.         return a({url: "/v2/gateway/flow/new.json", data: e, method: "POST"})
  460.     }, this.saveRule = function (e) {
  461.         return a({url: "/v2/gateway/flow/save.json", data: e, method: "POST"})
  462.     }, this.deleteRule = function (e) {
  463.         var t = {id: e.id, app: e.app};
  464.         return a({url: "/v2/gateway/flow/delete.json", params: t, method: "POST"})
  465.     }, this.checkRuleValid = function (e) {
  466.         if (void 0 === e.resource || "" === e.resource) return alert("API名称不能为空"), !1;
  467.         if (null != e.paramItem && (2 == e.paramItem.parseStrategy || 3 == e.paramItem.parseStrategy || 4 == e.paramItem.parseStrategy)) {
  468.             if (void 0 === e.paramItem.fieldName || "" === e.paramItem.fieldName) return alert("当参数属性为Header、URL参数、Cookie时，参数名称不能为空"), !1;
  469.             if ("" === e.paramItem.pattern) return alert("匹配串不能为空"), !1
  470.         }
  471.         return !(void 0 === e.count || e.count < 0) || (alert((1 === e.grade ? "QPS阈值" : "线程数") + "必须大于等于 0"), !1)
  472.     }
  473. }]);

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/神奇cpp/article/detail/739417
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号