api这个服务通过openFeign调用business，但是business这个服务没有启动，会报错，然后走的是降级方法。
/** * @author: 顶风少年 * @Description: * @date: 2022/7/1 15:48 **/@RestControllerpublic class DemoController { @Autowired private BusinessService businessService; @SentinelResource(fallback = \"demo1Fallback\") @GetMapping(value = \"demo1\") public String demo1(){ businessService.demo1(); return \"\"; } public String demo1Fallback(){ return \"方法降级~~~~~~~~~~~~\"; }}View Code
需要创建降级类，在需要降级的方法上声明降级类和降级方法。
package com.datang.api.controller;/** * @author: 顶风少年 * @Description: * @date: 2022/7/1 16:03 **/public class DemoControllerFallBack { public static String demo1Fallback(){ return \"类降级~~~~~~~~~~~~\"; }}View Code
package com.datang.api.controller;import com.alibaba.csp.sentinel.annotation.SentinelResource;import com.datang.api.service.BusinessService;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.web.bind.annotation.GetMapping;import org.springframework.web.bind.annotation.RestController;/** * @author: 顶风少年 * @Description: * @date: 2022/7/1 15:48 **/@RestControllerpublic class DemoController { @Autowired private BusinessService businessService; @SentinelResource(fallback = \"demo1Fallback\",fallbackClass = DemoControllerFallBack.class) @GetMapping(value = \"demo1\") public String demo1(){ return businessService.demo1(); }}View Code
https://www.fransesoap.com/alibaba/Sentinel/releases 下载控制台
启动jar包命令
java -Dserver.port=8888 -Dcsp.sentinel.dashboard.server=localhost:8888 -www.fransesoap.com=sentinel-dashboard -Dsentinel.dashboard.auth.username=sentinel -Dsentinel.dashboard.auth.password=111 -jar sentinel-dashboard-1.8.4.jar
工程配置，sentinel.transport.dashboard 控制台地址 sentinel.transport.port 监控服务端口 sentinel.eager 项目启动就注册到控制台
server: port: 8080spring: application: name: api cloud: nacos: discovery: server-addr: 127.00.1:8848 sentinel: transport: dashboard: localhost:8888 port: 8720 eager: trueView Code
1000毫秒内10个请求中有50%的请求相应时间超过500毫秒则熔断10秒钟。
package com.datang.api.controller;import com.alibaba.csp.sentinel.annotation.SentinelResource;import com.datang.api.service.BusinessService;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.web.bind.annotation.GetMapping;import org.springframework.web.bind.annotation.RestController;/** * @author: 顶风少年 * @Description: * @date: 2022/7/1 15:48 **/@RestControllerpublic class DemoController { @Autowired private BusinessService businessService; @SentinelResource(value = \"slowRequest\", fallback = \"demo1Fallback\") @GetMapping(value = \"demo1\") public String demo1() { try { Thread.sleep(1000); }catch (Exception e){} return \"success\"; } public String demo1Fallback(){ return \"方法降级~~~~~~~~~~~~\"; }}View Code
使用API的方式设置
package com.datang.api;import com.alibaba.csp.sentinel.slots.block.RuleConstant;import com.alibaba.csp.sentinel.slots.block.degrade.DegradeRule;import com.alibaba.csp.sentinel.slots.block.degrade.DegradeRuleManager;import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;import org.springframework.cloud.openfeign.EnableFeignClients;import java.util.ArrayList;import java.util.List;@SpringBootApplication@EnableFeignClientspublic class ApiServer { public static void main(String[] args) { www.fransesoap.com(ApiServer.class, args); initRule(); } public static void initRule(){ List rules = new ArrayList<>(); DegradeRule slowRequest = ApiServer.slowRequest(); rules.add(slowRequest); DegradeRuleManager.loadRules(rules); } //慢调用比例 public static DegradeRule slowRequest(){ DegradeRule rule = new DegradeRule(); rule.setResource(\"slowRequest2\");//资源名，即规则的作用对象 rule.setGrade(RuleConstant.DEGRADE_GRADE_RT);//慢调用比例 rule.setCount(1000);//最大RT rule.setSlowRatioThreshold(0.5);//比例阈值 rule.setTimeWindow(5000);//熔断时长 rule.setMinRequestAmount(50);//最小请求数 rule.setStatIntervalMs(3000);//统计时长 return rule; }} View Code
1000毫秒内10个请求50%抛出异常则熔断10秒。
package com.datang.api.controller;import com.alibaba.csp.sentinel.annotation.SentinelResource;import com.datang.api.service.BusinessService;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.web.bind.annotation.GetMapping;import org.springframework.web.bind.annotation.RestController;/** * @author: 顶风少年 * @Description: * @date: 2022/7/1 15:48 **/@RestControllerpublic class DemoController { @Autowired private BusinessService businessService; @SentinelResource(value = \"errorRatio\", fallback = \"demo1Fallback\") @GetMapping(value = \"demo1\") public String demo1() { System.out.println(\"正常请求\"); int i = 1/0; return \"success\"; } public String demo1Fallback(){ return \"方法降级~~~~~~~~~~~~\"; }}View Code
使用API的方式设置
package com.datang.api;import com.alibaba.csp.sentinel.slots.block.RuleConstant;import com.alibaba.csp.sentinel.slots.block.degrade.DegradeRule;import com.alibaba.csp.sentinel.slots.block.degrade.DegradeRuleManager;import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;import org.springframework.cloud.openfeign.EnableFeignClients;import java.util.ArrayList;import java.util.List;@SpringBootApplication@EnableFeignClientspublic class ApiServer { public static void main(String[] args) { www.fransesoap.com(ApiServer.class, args); initRule(); } public static void initRule(){ List rules = new ArrayList<>(); rules.add(ApiServer.slowRequest()); rules.add(ApiServer.errorRatio()); DegradeRuleManager.loadRules(rules); } //慢调用比例 public static DegradeRule slowRequest(){ DegradeRule rule = new DegradeRule(); rule.setResource(\"RuleConstant\");//资源名，即规则的作用对象 rule.setGrade(RuleConstant.DEGRADE_GRADE_RT);//慢调用比例 rule.setCount(1000);//最大RT rule.setSlowRatioThreshold(0.5);//比例阈值 rule.setTimeWindow(5000);//熔断时长 rule.setMinRequestAmount(50);//最小请求数 rule.setStatIntervalMs(3000);//统计时长 return rule; } //异常比例 public static DegradeRule errorRatio(){ DegradeRule rule = new DegradeRule(); rule.setResource(\"errorRatio\");//资源名，即规则的作用对象 rule.setGrade(RuleConstant.DEGRADE_GRADE_EXCEPTION_RATIO);//异常比例 rule.setCount(0.6);//比例阈值 rule.setTimeWindow(20);//熔断时长 rule.setMinRequestAmount(50);//最小请求数 rule.setStatIntervalMs(3000);//统计时长 return rule; }} View Code
1000毫秒内10个请求中5个抛出异常则熔断10秒。
package com.datang.api.controller;import com.alibaba.csp.sentinel.annotation.SentinelResource;import com.datang.api.service.BusinessService;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.web.bind.annotation.GetMapping;import org.springframework.web.bind.annotation.RestController;/** * @author: 顶风少年 * @Description: * @date: 2022/7/1 15:48 **/@RestControllerpublic class DemoController { @Autowired private BusinessService businessService; @SentinelResource(value = \"errorCount\", fallback = \"demo1Fallback\") @GetMapping(value = \"demo1\") public String demo1() { System.out.println(\"正常请求\"); int i = 1/0; return \"success\"; } public String demo1Fallback(){ return \"方法降级~~~~~~~~~~~~\"; }}View Code
使用API的方式设置
package com.datang.api;import com.alibaba.csp.sentinel.slots.block.RuleConstant;import com.alibaba.csp.sentinel.slots.block.degrade.DegradeRule;import com.alibaba.csp.sentinel.slots.block.degrade.DegradeRuleManager;import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;import org.springframework.cloud.openfeign.EnableFeignClients;import java.util.ArrayList;import java.util.List;@SpringBootApplication@EnableFeignClientspublic class ApiServer { public static void main(String[] args) { www.fransesoap.com(ApiServer.class, args); initRule(); } public static void initRule(){ List rules = new ArrayList<>(); rules.add(ApiServer.slowRequest()); rules.add(ApiServer.errorRatio()); rules.add(ApiServer.errorCount()); DegradeRuleManager.loadRules(rules); } //慢调用比例 public static DegradeRule slowRequest(){ DegradeRule rule = new DegradeRule(); rule.setResource(\"slowRequest\");//资源名，即规则的作用对象 rule.setGrade(RuleConstant.DEGRADE_GRADE_RT);//慢调用比例 rule.setCount(1000);//最大RT rule.setSlowRatioThreshold(0.5);//比例阈值 rule.setTimeWindow(5000);//熔断时长 rule.setMinRequestAmount(50);//最小请求数 rule.setStatIntervalMs(3000);//统计时长 return rule; } //异常比例 public static DegradeRule errorRatio(){ DegradeRule rule = new DegradeRule(); rule.setResource(\"errorRatio\");//资源名，即规则的作用对象 rule.setGrade(RuleConstant.DEGRADE_GRADE_EXCEPTION_RATIO);//异常比例 rule.setCount(0.6);//比例阈值 rule.setTimeWindow(20);//熔断时长 rule.setMinRequestAmount(50);//最小请求数 rule.setStatIntervalMs(3000);//统计时长 return rule; } //异常数 public static DegradeRule errorCount(){ DegradeRule rule = new DegradeRule(); rule.setResource(\"errorCount\");//资源名，即规则的作用对象 rule.setGrade(RuleConstant.DEGRADE_GRADE_EXCEPTION_COUNT);//异常数 rule.setCount(5);//异常数 rule.setTimeWindow(10);//熔断时长 rule.setMinRequestAmount(10);//最小请求数 rule.setStatIntervalMs(1000);//统计时长 return rule; }} View Code
对qps这个资源做QPS阈值类型限流，针对来源为default（全部来源，稍后会介绍来源）1秒只能访问1次流控模式是直接，直接就是不牵扯其他的资源，流控效果是快速失败，也就是直接走限流的回调。
package com.datang.api.controller;import com.alibaba.csp.sentinel.annotation.SentinelResource;import com.alibaba.csp.sentinel.slots.block.BlockException;import com.datang.api.service.BusinessService;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.web.bind.annotation.GetMapping;import org.springframework.web.bind.annotation.RestController;/** * @author: 顶风少年 * @Description: * @date: 2022/7/1 15:48 **/@RestControllerpublic class DemoController { @Autowired private BusinessService businessService; @GetMapping(value = \"demo1\") @SentinelResource(value = \"qps\", blockHandler = \"demoBlockHandler\", fallback = \"demoFallback\") public String demo1() { return \"success\"; } public String demoFallback() { return \"方法降级~~~~~~~~~~~~\"; } public String demoBlockHandler(BlockException e) { return \"方法限流~~~~~~~~~~~~\"; }}View Code
使用API的方式设置
package com.datang.api;import com.alibaba.csp.sentinel.slots.block.RuleConstant;import www.fransesoap.comityRule;import www.fransesoap.comityRuleManager;import com.alibaba.csp.sentinel.slots.block.degrade.DegradeRule;import com.alibaba.csp.sentinel.slots.block.degrade.DegradeRuleManager;import com.alibaba.csp.sentinel.slots.block.flow.FlowRule;import com.alibaba.csp.sentinel.slots.block.flow.FlowRuleManager;import org.checkerframework.checker.units.qual.A;import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;import org.springframework.cloud.openfeign.EnableFeignClients;import java.util.ArrayList;import java.util.List;@SpringBootApplication@EnableFeignClientspublic class ApiServer { public static void main(String[] args) { www.fransesoap.com(ApiServer.class, args); initRule(); } public static void initRule() { //熔断规则 List degradeRules = new ArrayList<>(); degradeRules.add(ApiServer.slowRequest()); degradeRules.add(ApiServer.errorRatio()); degradeRules.add(ApiServer.errorCount()); DegradeRuleManager.loadRules(degradeRules); List flowRules = new ArrayList<>(); flowRules.add(ApiServer.qpsDirectConnectionFailFast()); FlowRuleManager.loadRules(flowRules); } //慢调用比例 public static DegradeRule slowRequest() { DegradeRule rule = new DegradeRule(); rule.setResource(\"slowRequest\");//资源名，即规则的作用对象 rule.setGrade(RuleConstant.DEGRADE_GRADE_RT);//慢调用比例 rule.setCount(1000);//最大RT rule.setSlowRatioThreshold(0.5);//比例阈值 rule.setTimeWindow(5000);//熔断时长 rule.setMinRequestAmount(50);//最小请求数 rule.setStatIntervalMs(3000);//统计时长 return rule; } //异常比例 public static DegradeRule errorRatio() { DegradeRule rule = new DegradeRule(); rule.setResource(\"errorRatio\");//资源名，即规则的作用对象 rule.setGrade(RuleConstant.DEGRADE_GRADE_EXCEPTION_RATIO);//异常比例 rule.setCount(0.6);//比例阈值 rule.setTimeWindow(20);//熔断时长 rule.setMinRequestAmount(50);//最小请求数 rule.setStatIntervalMs(3000);//统计时长 return rule; } //异常数 public static DegradeRule errorCount() { DegradeRule rule = new DegradeRule(); rule.setResource(\"errorCount\");//资源名，即规则的作用对象 rule.setGrade(RuleConstant.DEGRADE_GRADE_EXCEPTION_COUNT);//异常数 rule.setCount(5);//异常数 rule.setTimeWindow(10);//熔断时长 rule.setMinRequestAmount(10);//最小请求数 rule.setStatIntervalMs(1000);//统计时长 return rule; } //QPS-直接-快速失败 public static FlowRule qpsDirectConnectionFailFast(){ FlowRule rule = new FlowRule(); rule.setResource(\"qpsDirectConnectionFailFast\");//资源名，即规则的作用对象 rule.setLimitApp(\"aaa\");//针对来源 rule.setGrade(RuleConstant.FLOW_GRADE_QPS);//阈值类型 rule.setCount(10);//单机阈值 rule.setStrategy(RuleConstant.STRATEGY_DIRECT);//流控模式 rule.setControlBehavior(RuleConstant.CONTROL_BEHAVIOR_DEFAULT);//流控效果 return rule; }} View Code
来源应用指的是对接口访问者进行身份鉴定。需要先在代码中设定一个token，然后通过传递参数方式将token和value传入。
package com.datang.api.config;import com.alibaba.csp.sentinel.adapter.spring.webmvc.callback.RequestOriginParser;import org.springframework.stereotype.Component;import javax.servlet.http.HttpServletRequest;/** * @author: 顶风少年 * @Description: * @date: 2022/7/3 17:27 **/@Componentpublic class TokenRequestOriginParser implements RequestOriginParser { @Override public String parseOrigin(HttpServletRequest httpServletRequest) { String authority = httpServletRequest.getParameter(\"auth\"); return authority; }}View Code
以上的设置需要来源为aaa,我们可以在参数添加auth=aaa这样流控规则才可以生效。
如果不设置auth或者auth的value不是aaa,则流控规则不会生效，默认的流控规则是default针对所有来源。
Warm Up模式应对突如其来的高并发，当并发来临时并不会立刻将单机阈值直接拉到最高，而是预热一段时间后单机阈值才会到达预设值的。以下设置3QPS其实真正能做到3QPS需要等到8秒预热后。8秒预热前大概是1QPS-2QPS。
package com.datang.api.controller;import com.alibaba.csp.sentinel.annotation.SentinelResource;import com.alibaba.csp.sentinel.slots.block.BlockException;import com.datang.api.service.BusinessService;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.web.bind.annotation.GetMapping;import org.springframework.web.bind.annotation.RestController;/** * @author: 顶风少年 * @Description: * @date: 2022/7/1 15:48 **/@RestControllerpublic class DemoController { @Autowired private BusinessService businessService; @GetMapping(value = \"demo1\") @SentinelResource(value = \"qpsDirectConnectionWarmUp\", blockHandler = \"demoBlockHandler\", fallback = \"demoFallback\") public String demo1() { return \"success\"; } public String demoFallback() { return \"方法降级~~~~~~~~~~~~\"; } public String demoBlockHandler(BlockException e) { return \"方法限流~~~~~~~~~~~~\"; }}View Code
使用API的方式设置
package com.datang.api;import com.alibaba.csp.sentinel.slots.block.RuleConstant;import www.fransesoap.comityRule;import www.fransesoap.comityRuleManager;import com.alibaba.csp.sentinel.slots.block.degrade.DegradeRule;import com.alibaba.csp.sentinel.slots.block.degrade.DegradeRuleManager;import com.alibaba.csp.sentinel.slots.block.flow.FlowRule;import com.alibaba.csp.sentinel.slots.block.flow.FlowRuleManager;import org.checkerframework.checker.units.qual.A;import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;import org.springframework.cloud.openfeign.EnableFeignClients;import java.util.ArrayList;import java.util.List;@SpringBootApplication@EnableFeignClientspublic class ApiServer { public static void main(String[] args) { www.fransesoap.com(ApiServer.class, args); initRule(); } public static void initRule() { //熔断规则 List degradeRules = new ArrayList<>(); degradeRules.add(ApiServer.slowRequest()); degradeRules.add(ApiServer.errorRatio()); degradeRules.add(ApiServer.errorCount()); DegradeRuleManager.loadRules(degradeRules); List flowRules = new ArrayList<>(); flowRules.add(ApiServer.qpsDirectConnectionFailFast()); flowRules.add(ApiServer.qpsDirectConnectionWarmUp()); FlowRuleManager.loadRules(flowRules); } //慢调用比例 public static DegradeRule slowRequest() { DegradeRule rule = new DegradeRule(); rule.setResource(\"slowRequest\");//资源名，即规则的作用对象 rule.setGrade(RuleConstant.DEGRADE_GRADE_RT);//慢调用比例 rule.setCount(1000);//最大RT rule.setSlowRatioThreshold(0.5);//比例阈值 rule.setTimeWindow(5000);//熔断时长 rule.setMinRequestAmount(50);//最小请求数 rule.setStatIntervalMs(3000);//统计时长 return rule; } //异常比例 public static DegradeRule errorRatio() { DegradeRule rule = new DegradeRule(); rule.setResource(\"errorRatio\");//资源名，即规则的作用对象 rule.setGrade(RuleConstant.DEGRADE_GRADE_EXCEPTION_RATIO);//异常比例 rule.setCount(0.6);//比例阈值 rule.setTimeWindow(20);//熔断时长 rule.setMinRequestAmount(50);//最小请求数 rule.setStatIntervalMs(3000);//统计时长 return rule; } //异常数 public static DegradeRule errorCount() { DegradeRule rule = new DegradeRule(); rule.setResource(\"errorCount\");//资源名，即规则的作用对象 rule.setGrade(RuleConstant.DEGRADE_GRADE_EXCEPTION_COUNT);//异常数 rule.setCount(5);//异常数 rule.setTimeWindow(10);//熔断时长 rule.setMinRequestAmount(10);//最小请求数 rule.setStatIntervalMs(1000);//统计时长 return rule; } //QPS-直接-快速失败 public static FlowRule qpsDirectConnectionFailFast(){ FlowRule rule = new FlowRule(); rule.setResource(\"qpsDirectConnectionFailFast\");//资源名，即规则的作用对象 rule.setLimitApp(\"aaa\");//针对来源 rule.setGrade(RuleConstant.FLOW_GRADE_QPS);//阈值类型 rule.setCount(1);//单机阈值 rule.setStrategy(RuleConstant.STRATEGY_DIRECT);//流控模式 rule.setControlBehavior(RuleConstant.CONTROL_BEHAVIOR_DEFAULT);//流控效果 return rule; } //QPS-直接-Warm Up public static FlowRule qpsDirectConnectionWarmUp(){ FlowRule rule = new FlowRule(); rule.setResource(\"qpsDirectConnectionWarmUp\");//资源名，即规则的作用对象 rule.setLimitApp(\"default\");//针对来源 rule.setGrade(RuleConstant.FLOW_GRADE_QPS);//阈值类型 rule.setCount(1);//单机阈值 rule.setStrategy(RuleConstant.STRATEGY_DIRECT);//流控模式 rule.setControlBehavior(RuleConstant.CONTROL_BEHAVIOR_WARM_UP);//流控效果 rule.setWarmUpPeriodSec(10);//预热时长 return rule; }} View Code
当QPS超过阈值后，不会立刻限流而是等待一段时间。
package com.datang.api.controller;import com.alibaba.csp.sentinel.annotation.SentinelResource;import com.alibaba.csp.sentinel.slots.block.BlockException;import com.datang.api.service.BusinessService;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.web.bind.annotation.GetMapping;import org.springframework.web.bind.annotation.RestController;/** * @author: 顶风少年 * @Description: * @date: 2022/7/1 15:48 **/@RestControllerpublic class DemoController { @Autowired private BusinessService businessService; @GetMapping(value = \"demo1\") @SentinelResource(value = \"qpsDirectConnectionQueueUp\", blockHandler = \"demoBlockHandler\", fallback = \"demoFallback\") public String demo1() { return \"success\"; } public String demoFallback() { return \"方法降级~~~~~~~~~~~~\"; } public String demoBlockHandler(BlockException e) { return \"方法限流~~~~~~~~~~~~\"; }}View Code
使用API的方式设置
package com.datang.api;import com.alibaba.csp.sentinel.slots.block.RuleConstant;import www.fransesoap.comityRule;import www.fransesoap.comityRuleManager;import com.alibaba.csp.sentinel.slots.block.degrade.DegradeRule;import com.alibaba.csp.sentinel.slots.block.degrade.DegradeRuleManager;import com.alibaba.csp.sentinel.slots.block.flow.FlowRule;import com.alibaba.csp.sentinel.slots.block.flow.FlowRuleManager;import org.checkerframework.checker.units.qual.A;import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;import org.springframework.cloud.openfeign.EnableFeignClients;import java.util.ArrayList;import java.util.List;@SpringBootApplication@EnableFeignClientspublic class ApiServer { public static void main(String[] args) { www.fransesoap.com(ApiServer.class, args); initRule(); } public static void initRule() { //熔断规则 List degradeRules = new ArrayList<>(); degradeRules.add(ApiServer.slowRequest()); degradeRules.add(ApiServer.errorRatio()); degradeRules.add(ApiServer.errorCount()); DegradeRuleManager.loadRules(degradeRules); List flowRules = new ArrayList<>(); flowRules.add(ApiServer.qpsDirectConnectionFailFast()); flowRules.add(ApiServer.qpsDirectConnectionWarmUp()); flowRules.add(ApiServer.qpsDirectConnectionQueueUp()); FlowRuleManager.loadRules(flowRules); } //慢调用比例 public static DegradeRule slowRequest() { DegradeRule rule = new DegradeRule(); rule.setResource(\"slowRequest\");//资源名，即规则的作用对象 rule.setGrade(RuleConstant.DEGRADE_GRADE_RT);//慢调用比例 rule.setCount(1000);//最大RT rule.setSlowRatioThreshold(0.5);//比例阈值 rule.setTimeWindow(5000);//熔断时长 rule.setMinRequestAmount(50);//最小请求数 rule.setStatIntervalMs(3000);//统计时长 return rule; } //异常比例 public static DegradeRule errorRatio() { DegradeRule rule = new DegradeRule(); rule.setResource(\"errorRatio\");//资源名，即规则的作用对象 rule.setGrade(RuleConstant.DEGRADE_GRADE_EXCEPTION_RATIO);//异常比例 rule.setCount(0.6);//比例阈值 rule.setTimeWindow(20);//熔断时长 rule.setMinRequestAmount(50);//最小请求数 rule.setStatIntervalMs(3000);//统计时长 return rule; } //异常数 public static DegradeRule errorCount() { DegradeRule rule = new DegradeRule(); rule.setResource(\"errorCount\");//资源名，即规则的作用对象 rule.setGrade(RuleConstant.DEGRADE_GRADE_EXCEPTION_COUNT);//异常数 rule.setCount(5);//异常数 rule.setTimeWindow(10);//熔断时长 rule.setMinRequestAmount(10);//最小请求数 rule.setStatIntervalMs(1000);//统计时长 return rule; } //QPS-直接-快速失败 public static FlowRule qpsDirectConnectionFailFast(){ FlowRule rule = new FlowRule(); rule.setResource(\"qpsDirectConnectionFailFast\");//资源名，即规则的作用对象 rule.setLimitApp(\"aaa\");//针对来源 rule.setGrade(RuleConstant.FLOW_GRADE_QPS);//阈值类型 rule.setCount(1);//单机阈值 rule.setStrategy(RuleConstant.STRATEGY_DIRECT);//流控模式 rule.setControlBehavior(RuleConstant.CONTROL_BEHAVIOR_DEFAULT);//流控效果 return rule; } //QPS-直接-Warm Up public static FlowRule qpsDirectConnectionWarmUp(){ FlowRule rule = new FlowRule(); rule.setResource(\"qpsDirectConnectionWarmUp\");//资源名，即规则的作用对象 rule.setLimitApp(\"default\");//针对来源 rule.setGrade(RuleConstant.FLOW_GRADE_QPS);//阈值类型 rule.setCount(1);//单机阈值 rule.setStrategy(RuleConstant.STRATEGY_DIRECT);//流控模式 rule.setControlBehavior(RuleConstant.CONTROL_BEHAVIOR_WARM_UP);//流控效果 rule.setWarmUpPeriodSec(10);//预热时长 return rule; } //QPS-直接-排队等待 public static FlowRule qpsDirectConnectionQueueUp(){ FlowRule rule = new FlowRule(); rule.setResource(\"qpsDirectConnectionQueueUp\");//资源名，即规则的作用对象 rule.setLimitApp(\"default\");//针对来源 rule.setGrade(RuleConstant.FLOW_GRADE_QPS);//阈值类型 rule.setCount(3);//单机阈值 rule.setStrategy(RuleConstant.STRATEGY_DIRECT);//流控模式 rule.setControlBehavior(RuleConstant.CONTROL_BEHAVIOR_RATE_LIMITER);//流控效果 rule.setMaxQueueingTimeMs(300);//超时时间 return rule; }} View Code
当关联资源B并发量超过单机阈值后，关联资源B不会限流但资源A会被限流。
package com.datang.api.controller;import com.alibaba.csp.sentinel.annotation.SentinelResource;import com.alibaba.csp.sentinel.slots.block.BlockException;import com.datang.api.service.BusinessService;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.web.bind.annotation.GetMapping;import org.springframework.web.bind.annotation.RestController;/** * @author: 顶风少年 * @Description: * @date: 2022/7/1 15:48 **/@RestControllerpublic class DemoController { @Autowired private BusinessService businessService; @GetMapping(value = \"demo1\") @SentinelResource(value = \"qpsCorrelationFailFast\", blockHandler = \"demoBlockHandler\", fallback = \"demoFallback\") public String demo1() { return \"success\"; } @GetMapping(value = \"demo2\") @SentinelResource(value = \"qpsCorrelationFailFast2\", blockHandler = \"demoBlockHandler\", fallback = \"demoFallback\") public String demo2() { return \"success\"; } public String demoFallback() { return \"方法降级~~~~~~~~~~~~\"; } public String demoBlockHandler(BlockException e) { return \"方法限流~~~~~~~~~~~~\"; }}View Code
使用API的方式设置
package com.datang.api;import com.alibaba.csp.sentinel.slots.block.RuleConstant;import www.fransesoap.comityRule;import www.fransesoap.comityRuleManager;import com.alibaba.csp.sentinel.slots.block.degrade.DegradeRule;import com.alibaba.csp.sentinel.slots.block.degrade.DegradeRuleManager;import com.alibaba.csp.sentinel.slots.block.flow.FlowRule;import com.alibaba.csp.sentinel.slots.block.flow.FlowRuleManager;import org.checkerframework.checker.units.qual.A;import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;import org.springframework.cloud.openfeign.EnableFeignClients;import java.util.ArrayList;import java.util.List;@SpringBootApplication@EnableFeignClientspublic class ApiServer { public static void main(String[] args) { www.fransesoap.com(ApiServer.class, args); initRule(); } public static void initRule() { //熔断规则 List degradeRules = new ArrayList<>(); degradeRules.add(ApiServer.slowRequest()); degradeRules.add(ApiServer.errorRatio()); degradeRules.add(ApiServer.errorCount()); DegradeRuleManager.loadRules(degradeRules); List flowRules = new ArrayList<>(); flowRules.add(ApiServer.qpsDirectConnectionFailFast()); flowRules.add(ApiServer.qpsDirectConnectionWarmUp()); flowRules.add(ApiServer.qpsDirectConnectionQueueUp()); flowRules.add(ApiServer.qpsCorrelationFailFast()); FlowRuleManager.loadRules(flowRules); } //慢调用比例 public static DegradeRule slowRequest() { DegradeRule rule = new DegradeRule(); rule.setResource(\"slowRequest\");//资源名，即规则的作用对象 rule.setGrade(RuleConstant.DEGRADE_GRADE_RT);//慢调用比例 rule.setCount(1000);//最大RT rule.setSlowRatioThreshold(0.5);//比例阈值 rule.setTimeWindow(5000);//熔断时长 rule.setMinRequestAmount(50);//最小请求数 rule.setStatIntervalMs(3000);//统计时长 return rule; } //异常比例 public static DegradeRule errorRatio() { DegradeRule rule = new DegradeRule(); rule.setResource(\"errorRatio\");//资源名，即规则的作用对象 rule.setGrade(RuleConstant.DEGRADE_GRADE_EXCEPTION_RATIO);//异常比例 rule.setCount(0.6);//比例阈值 rule.setTimeWindow(20);//熔断时长 rule.setMinRequestAmount(50);//最小请求数 rule.setStatIntervalMs(3000);//统计时长 return rule; } //异常数 public static DegradeRule errorCount() { DegradeRule rule = new DegradeRule(); rule.setResource(\"errorCount\");//资源名，即规则的作用对象 rule.setGrade(RuleConstant.DEGRADE_GRADE_EXCEPTION_COUNT);//异常数 rule.setCount(5);//异常数 rule.setTimeWindow(10);//熔断时长 rule.setMinRequestAmount(10);//最小请求数 rule.setStatIntervalMs(1000);//统计时长 return rule; } //QPS-直接-快速失败 public static FlowRule qpsDirectConnectionFailFast(){ FlowRule rule = new FlowRule(); rule.setResource(\"qpsDirectConnectionFailFast\");//资源名，即规则的作用对象 rule.setLimitApp(\"default\");//针对来源 rule.setGrade(RuleConstant.FLOW_GRADE_QPS);//阈值类型 rule.setCount(1);//单机阈值 rule.setStrategy(RuleConstant.STRATEGY_DIRECT);//流控模式 rule.setControlBehavior(RuleConstant.CONTROL_BEHAVIOR_DEFAULT);//流控效果 return rule; } //QPS-直接-Warm Up public static FlowRule qpsDirectConnectionWarmUp(){ FlowRule rule = new FlowRule(); rule.setResource(\"qpsDirectConnectionWarmUp\");//资源名，即规则的作用对象 rule.setLimitApp(\"default\");//针对来源 rule.setGrade(RuleConstant.FLOW_GRADE_QPS);//阈值类型 rule.setCount(1);//单机阈值 rule.setStrategy(RuleConstant.STRATEGY_DIRECT);//流控模式 rule.setControlBehavior(RuleConstant.CONTROL_BEHAVIOR_WARM_UP);//流控效果 rule.setWarmUpPeriodSec(10);//预热时长 return rule; } //QPS-直接-排队等待 public static FlowRule qpsDirectConnectionQueueUp(){ FlowRule rule = new FlowRule(); rule.setResource(\"qpsDirectConnectionQueueUp\");//资源名，即规则的作用对象 rule.setLimitApp(\"default\");//针对来源 rule.setGrade(RuleConstant.FLOW_GRADE_QPS);//阈值类型 rule.setCount(3);//单机阈值 rule.setStrategy(RuleConstant.STRATEGY_DIRECT);//流控模式 rule.setControlBehavior(RuleConstant.CONTROL_BEHAVIOR_RATE_LIMITER);//流控效果 rule.setMaxQueueingTimeMs(300);//超时时间 return rule; } //QPS-关联-快速失败 public static FlowRule qpsCorrelationFailFast(){ FlowRule rule = new FlowRule(); rule.setResource(\"qpsCorrelationFailFast\");//资源名，即规则的作用对象 rule.setLimitApp(\"default\");//针对来源 rule.setGrade(RuleConstant.FLOW_GRADE_QPS);//阈值类型 rule.setCount(5);//单机阈值 rule.setStrategy(RuleConstant.STRATEGY_RELATE);//流控模式 rule.setRefResource(\"qpsCorrelationFailFast2\");//关联资源 rule.setControlBehavior(RuleConstant.CONTROL_BEHAVIOR_DEFAULT);//流控效果 return rule; }} View Code
只有从A入口访问B才会触发限流，而从其他的入口则不会触发。yml中需要配置 web-context-unify: false 被限流的资源不能在Controler里，只能在Service中。
server: port: 8080spring: application: name: api cloud: nacos: discovery: server-addr: 127.00.1:8848 sentinel: transport: dashboard: localhost:8888 port: 8720 eager: true web-context-unify: falseribbon: ReadTimeout: 5000 ConnectTimeout: 5000feign: client: config: default: connectTimeout: 5000 readTimeout: 5000eureka: client: register-with-eureka: true fetch-registry: true service-url: defaultZone: http://localhost:7001/eurekaView Code
package com.datang.api.controller;import com.alibaba.csp.sentinel.annotation.SentinelResource;import com.alibaba.csp.sentinel.slots.block.BlockException;import com.datang.api.service.BusinessService;import com.datang.api.service.DemoService;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.web.bind.annotation.GetMapping;import org.springframework.web.bind.annotation.RestController;/** * @author: 顶风少年 * @Description: * @date: 2022/7/1 15:48 **/@RestControllerpublic class DemoController { @Autowired private BusinessService businessService; @Autowired private DemoService service; @GetMapping(value = \"/demo2\") public String demo2() { System.out.println(\"demo2!!!!!!!!!!\"); return service.demo1(); } @GetMapping(value = \"/demo3\") public String demo3() { System.out.println(\"demo3!!!!!!!!!!\"); return service.demo1(); }}View Code
package com.datang.api.service;import com.alibaba.csp.sentinel.annotation.SentinelResource;import com.alibaba.csp.sentinel.slots.block.BlockException;import org.springframework.stereotype.Service;import org.springframework.web.bind.annotation.GetMapping;/** * @author: 顶风少年 * @Description: * @date: 2022/7/5 17:00 **/@Servicepublic class DemoService { @SentinelResource(value = \"qpsLikeFailFast\", blockHandler = \"demoBlockHandler\", fallback = \"demoFallback\") public String demo1() { return \"success\"; } public String demoFallback() { return \"方法降级~~~~~~~~~~~~\"; } public String demoBlockHandler(BlockException e) { return \"方法限流~~~~~~~~~~~~\"; }}View Code
使用API的方式设置
threadDirectConnectionFailFast资源只能有5个线程并发访问。
package com.datang.api.controller;import com.alibaba.csp.sentinel.annotation.SentinelResource;import com.alibaba.csp.sentinel.slots.block.BlockException;import com.datang.api.service.BusinessService;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.web.bind.annotation.GetMapping;import org.springframework.web.bind.annotation.RestController;/** * @author: 顶风少年 * @Description: * @date: 2022/7/1 15:48 **/@RestControllerpublic class DemoController { @Autowired private BusinessService businessService; @GetMapping(value = \"demo1\") @SentinelResource(value = \"threadDirectConnectionFailFast\", blockHandler = \"demoBlockHandler\", fallback = \"demoFallback\") public String demo1() { try { Thread.sleep(1000*10); }catch (Exception e){} return \"success\"; } public String demoFallback() { return \"方法降级~~~~~~~~~~~~\"; } public String demoBlockHandler(BlockException e) { return \"方法限流~~~~~~~~~~~~\"; }}View Code
使用API的方式设置
package com.datang.api;import com.alibaba.csp.sentinel.slots.block.RuleConstant;import www.fransesoap.comityRule;import www.fransesoap.comityRuleManager;import com.alibaba.csp.sentinel.slots.block.degrade.DegradeRule;import com.alibaba.csp.sentinel.slots.block.degrade.DegradeRuleManager;import com.alibaba.csp.sentinel.slots.block.flow.FlowRule;import com.alibaba.csp.sentinel.slots.block.flow.FlowRuleManager;import org.checkerframework.checker.units.qual.A;import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;import org.springframework.cloud.openfeign.EnableFeignClients;import java.util.ArrayList;import java.util.List;@SpringBootApplication@EnableFeignClientspublic class ApiServer { public static void main(String[] args) { www.fransesoap.com(ApiServer.class, args); initRule(); } public static void initRule() { //熔断规则 List degradeRules = new ArrayList<>(); degradeRules.add(ApiServer.slowRequest()); degradeRules.add(ApiServer.errorRatio()); degradeRules.add(ApiServer.errorCount()); DegradeRuleManager.loadRules(degradeRules); List flowRules = new ArrayList<>(); flowRules.add(ApiServer.qpsDirectConnectionFailFast()); flowRules.add(ApiServer.qpsDirectConnectionWarmUp()); flowRules.add(ApiServer.qpsDirectConnectionQueueUp()); flowRules.add(ApiServer.qpsCorrelationFailFast()); flowRules.add(ApiServer.qpsLikeFailFast()); flowRules.add(ApiServer.threadDirectConnectionFailFast()); FlowRuleManager.loadRules(flowRules); } //慢调用比例 public static DegradeRule slowRequest() { DegradeRule rule = new DegradeRule(); rule.setResource(\"slowRequest\");//资源名，即规则的作用对象 rule.setGrade(RuleConstant.DEGRADE_GRADE_RT);//慢调用比例 rule.setCount(1000);//最大RT rule.setSlowRatioThreshold(0.5);//比例阈值 rule.setTimeWindow(5000);//熔断时长 rule.setMinRequestAmount(50);//最小请求数 rule.setStatIntervalMs(3000);//统计时长 return rule; } //异常比例 public static DegradeRule errorRatio() { DegradeRule rule = new DegradeRule(); rule.setResource(\"errorRatio\");//资源名，即规则的作用对象 rule.setGrade(RuleConstant.DEGRADE_GRADE_EXCEPTION_RATIO);//异常比例 rule.setCount(0.6);//比例阈值 rule.setTimeWindow(20);//熔断时长 rule.setMinRequestAmount(50);//最小请求数 rule.setStatIntervalMs(3000);//统计时长 return rule; } //异常数 public static DegradeRule errorCount() { DegradeRule rule = new DegradeRule(); rule.setResource(\"errorCount\");//资源名，即规则的作用对象 rule.setGrade(RuleConstant.DEGRADE_GRADE_EXCEPTION_COUNT);//异常数 rule.setCount(5);//异常数 rule.setTimeWindow(10);//熔断时长 rule.setMinRequestAmount(10);//最小请求数 rule.setStatIntervalMs(1000);//统计时长 return rule; } //QPS-直接-快速失败 public static FlowRule qpsDirectConnectionFailFast(){ FlowRule rule = new FlowRule(); rule.setResource(\"qpsDirectConnectionFailFast\");//资源名，即规则的作用对象 rule.setLimitApp(\"default\");//针对来源 rule.setGrade(RuleConstant.FLOW_GRADE_QPS);//阈值类型 rule.setCount(1);//单机阈值 rule.setStrategy(RuleConstant.STRATEGY_DIRECT);//流控模式 rule.setControlBehavior(RuleConstant.CONTROL_BEHAVIOR_DEFAULT);//流控效果 return rule; } //QPS-直接-Warm Up public static FlowRule qpsDirectConnectionWarmUp(){ FlowRule rule = new FlowRule(); rule.setResource(\"qpsDirectConnectionWarmUp\");//资源名，即规则的作用对象 rule.setLimitApp(\"default\");//针对来源 rule.setGrade(RuleConstant.FLOW_GRADE_QPS);//阈值类型 rule.setCount(1);//单机阈值 rule.setStrategy(RuleConstant.STRATEGY_DIRECT);//流控模式 rule.setControlBehavior(RuleConstant.CONTROL_BEHAVIOR_WARM_UP);//流控效果 rule.setWarmUpPeriodSec(10);//预热时长 return rule; } //QPS-直接-排队等待 public static FlowRule qpsDirectConnectionQueueUp(){ FlowRule rule = new FlowRule(); rule.setResource(\"qpsDirectConnectionQueueUp\");//资源名，即规则的作用对象 rule.setLimitApp(\"default\");//针对来源 rule.setGrade(RuleConstant.FLOW_GRADE_QPS);//阈值类型 rule.setCount(3);//单机阈值 rule.setStrategy(RuleConstant.STRATEGY_DIRECT);//流控模式 rule.setControlBehavior(RuleConstant.CONTROL_BEHAVIOR_RATE_LIMITER);//流控效果 rule.setMaxQueueingTimeMs(300);//超时时间 return rule; } //QPS-关联-快速失败 public static FlowRule qpsCorrelationFailFast(){ FlowRule rule = new FlowRule(); rule.setResource(\"qpsCorrelationFailFast\");//资源名，即规则的作用对象 rule.setLimitApp(\"default\");//针对来源 rule.setGrade(RuleConstant.FLOW_GRADE_QPS);//阈值类型 rule.setCount(5);//单机阈值 rule.setStrategy(RuleConstant.STRATEGY_RELATE);//流控模式 rule.setRefResource(\"qpsCorrelationFailFast2\");//关联资源 rule.setControlBehavior(RuleConstant.CONTROL_BEHAVIOR_DEFAULT);//流控效果 return rule; } //QPS-链路-快速失败 public static FlowRule qpsLikeFailFast(){ FlowRule rule = new FlowRule(); rule.setResource(\"qpsLikeFailFast\");//资源名，即规则的作用对象 rule.setLimitApp(\"default\");//针对来源 rule.setGrade(RuleConstant.FLOW_GRADE_QPS);//阈值类型 rule.setCount(1);//单机阈值 rule.setStrategy(RuleConstant.STRATEGY_CHAIN);//流控模式 rule.setRefResource(\"/demo2\");//入口资源 rule.setControlBehavior(RuleConstant.CONTROL_BEHAVIOR_DEFAULT);//流控效果 return rule; } //并发线程数-直接-快速失败 public static FlowRule threadDirectConnectionFailFast(){ FlowRule rule = new FlowRule(); rule.setResource(\"threadDirectConnectionFailFast\");//资源名，即规则的作用对象 rule.setLimitApp(\"default\");//针对来源 rule.setGrade(RuleConstant.FLOW_GRADE_THREAD);//阈值类型 rule.setCount(5);//单机阈值 rule.setStrategy(RuleConstant.STRATEGY_DIRECT);//流控模式 rule.setControlBehavior(RuleConstant.CONTROL_BEHAVIOR_DEFAULT);//流控效果 return rule; }} View Code
只有访问来源是 a 的才能访问该资源，同样需要实现 RequestOriginParser 接口，在流控规则中我们是从参数中获取token，这次我们从head中获取，同样的如果访问来源没有带token是无法触发授权规则的。
package com.datang.api.controller;import com.alibaba.csp.sentinel.annotation.SentinelResource;import com.alibaba.csp.sentinel.slots.block.BlockException;import com.datang.api.service.BusinessService;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.web.bind.annotation.GetMapping;import org.springframework.web.bind.annotation.RestController;/** * @author: 顶风少年 * @Description: * @date: 2022/7/1 15:48 **/@RestControllerpublic class DemoController { @Autowired private BusinessService businessService; @GetMapping(value = \"demo1\") @SentinelResource(value = \"whiteList\", blockHandler = \"demoBlockHandler\", fallback = \"demoFallback\") public String demo1() { return \"success\"; } public String demoFallback() { return \"方法降级~~~~~~~~~~~~\"; } public String demoBlockHandler(BlockException e) { return \"方法限流~~~~~~~~~~~~\"; }}View Code
package com.datang.api.config;import com.alibaba.csp.sentinel.adapter.spring.webmvc.callback.RequestOriginParser;import org.springframework.stereotype.Component;import javax.servlet.http.HttpServletRequest;/** * @author: 顶风少年 * @Description: * @date: 2022/7/3 17:27 **/@Componentpublic class TokenRequestOriginParser implements RequestOriginParser { @Override public String parseOrigin(HttpServletRequest httpServletRequest) { String authority = httpServletRequest.getHeader(\"auth\"); return authority; }}View Code
使用API的方式设置
package com.datang.api;import com.alibaba.csp.sentinel.slots.block.RuleConstant;import www.fransesoap.comityRule;import www.fransesoap.comityRuleManager;import com.alibaba.csp.sentinel.slots.block.degrade.DegradeRule;import com.alibaba.csp.sentinel.slots.block.degrade.DegradeRuleManager;import com.alibaba.csp.sentinel.slots.block.flow.FlowRule;import com.alibaba.csp.sentinel.slots.block.flow.FlowRuleManager;import org.checkerframework.checker.units.qual.A;import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;import org.springframework.cloud.openfeign.EnableFeignClients;import java.util.ArrayList;import java.util.List;@SpringBootApplication@EnableFeignClientspublic class ApiServer { public static void main(String[] args) { www.fransesoap.com(ApiServer.class, args); initRule(); } public static void initRule() { //熔断规则 List degradeRules = new ArrayList<>(); degradeRules.add(ApiServer.slowRequest()); degradeRules.add(ApiServer.errorRatio()); degradeRules.add(ApiServer.errorCount()); DegradeRuleManager.loadRules(degradeRules); List flowRules = new ArrayList<>(); flowRules.add(ApiServer.qpsDirectConnectionFailFast()); flowRules.add(ApiServer.qpsDirectConnectionWarmUp()); flowRules.add(ApiServer.qpsDirectConnectionQueueUp()); flowRules.add(ApiServer.qpsCorrelationFailFast()); flowRules.add(ApiServer.qpsLikeFailFast()); flowRules.add(ApiServer.threadDirectConnectionFailFast()); FlowRuleManager.loadRules(flowRules); List authorityRules = new ArrayList<>(); authorityRules.add(ApiServer.whiteList()); AuthorityRuleManager.loadRules(authorityRules); } //慢调用比例 public static DegradeRule slowRequest() { DegradeRule rule = new DegradeRule(); rule.setResource(\"slowRequest\");//资源名，即规则的作用对象 rule.setGrade(RuleConstant.DEGRADE_GRADE_RT);//慢调用比例 rule.setCount(1000);//最大RT rule.setSlowRatioThreshold(0.5);//比例阈值 rule.setTimeWindow(5000);//熔断时长 rule.setMinRequestAmount(50);//最小请求数 rule.setStatIntervalMs(3000);//统计时长 return rule; } //异常比例 public static DegradeRule errorRatio() { DegradeRule rule = new DegradeRule(); rule.setResource(\"errorRatio\");//资源名，即规则的作用对象 rule.setGrade(RuleConstant.DEGRADE_GRADE_EXCEPTION_RATIO);//异常比例 rule.setCount(0.6);//比例阈值 rule.setTimeWindow(20);//熔断时长 rule.setMinRequestAmount(50);//最小请求数 rule.setStatIntervalMs(3000);//统计时长 return rule; } //异常数 public static DegradeRule errorCount() { DegradeRule rule = new DegradeRule(); rule.setResource(\"errorCount\");//资源名，即规则的作用对象 rule.setGrade(RuleConstant.DEGRADE_GRADE_EXCEPTION_COUNT);//异常数 rule.setCount(5);//异常数 rule.setTimeWindow(10);//熔断时长 rule.setMinRequestAmount(10);//最小请求数 rule.setStatIntervalMs(1000);//统计时长 return rule; } //QPS-直接-快速失败 public static FlowRule qpsDirectConnectionFailFast(){ FlowRule rule = new FlowRule(); rule.setResource(\"qpsDirectConnectionFailFast\");//资源名，即规则的作用对象 rule.setLimitApp(\"default\");//针对来源 rule.setGrade(RuleConstant.FLOW_GRADE_QPS);//阈值类型 rule.setCount(1);//单机阈值 rule.setStrategy(RuleConstant.STRATEGY_DIRECT);//流控模式 rule.setControlBehavior(RuleConstant.CONTROL_BEHAVIOR_DEFAULT);//流控效果 return rule; } //QPS-直接-Warm Up public static FlowRule qpsDirectConnectionWarmUp(){ FlowRule rule = new FlowRule(); rule.setResource(\"qpsDirectConnectionWarmUp\");//资源名，即规则的作用对象 rule.setLimitApp(\"default\");//针对来源 rule.setGrade(RuleConstant.FLOW_GRADE_QPS);//阈值类型 rule.setCount(1);//单机阈值 rule.setStrategy(RuleConstant.STRATEGY_DIRECT);//流控模式 rule.setControlBehavior(RuleConstant.CONTROL_BEHAVIOR_WARM_UP);//流控效果 rule.setWarmUpPeriodSec(10);//预热时长 return rule; } //QPS-直接-排队等待 public static FlowRule qpsDirectConnectionQueueUp(){ FlowRule rule = new FlowRule(); rule.setResource(\"qpsDirectConnectionQueueUp\");//资源名，即规则的作用对象 rule.setLimitApp(\"default\");//针对来源 rule.setGrade(RuleConstant.FLOW_GRADE_QPS);//阈值类型 rule.setCount(3);//单机阈值 rule.setStrategy(RuleConstant.STRATEGY_DIRECT);//流控模式 rule.setControlBehavior(RuleConstant.CONTROL_BEHAVIOR_RATE_LIMITER);//流控效果 rule.setMaxQueueingTimeMs(300);//超时时间 return rule; } //QPS-关联-快速失败 public static FlowRule qpsCorrelationFailFast(){ FlowRule rule = new FlowRule(); rule.setResource(\"qpsCorrelationFailFast\");//资源名，即规则的作用对象 rule.setLimitApp(\"default\");//针对来源 rule.setGrade(RuleConstant.FLOW_GRADE_QPS);//阈值类型 rule.setCount(5);//单机阈值 rule.setStrategy(RuleConstant.STRATEGY_RELATE);//流控模式 rule.setRefResource(\"qpsCorrelationFailFast2\");//关联资源 rule.setControlBehavior(RuleConstant.CONTROL_BEHAVIOR_DEFAULT);//流控效果 return rule; } //QPS-链路-快速失败 public static FlowRule qpsLikeFailFast(){ FlowRule rule = new FlowRule(); rule.setResource(\"qpsLikeFailFast\");//资源名，即规则的作用对象 rule.setLimitApp(\"default\");//针对来源 rule.setGrade(RuleConstant.FLOW_GRADE_QPS);//阈值类型 rule.setCount(1);//单机阈值 rule.setStrategy(RuleConstant.STRATEGY_CHAIN);//流控模式 rule.setRefResource(\"/demo2\");//入口资源 rule.setControlBehavior(RuleConstant.CONTROL_BEHAVIOR_DEFAULT);//流控效果 return rule; } //并发线程数-直接-快速失败 public static FlowRule threadDirectConnectionFailFast(){ FlowRule rule = new FlowRule(); rule.setResource(\"threadDirectConnectionFailFast\");//资源名，即规则的作用对象 rule.setLimitApp(\"default\");//针对来源 rule.setGrade(RuleConstant.FLOW_GRADE_THREAD);//阈值类型 rule.setCount(5);//单机阈值 rule.setStrategy(RuleConstant.STRATEGY_DIRECT);//流控模式 rule.setControlBehavior(RuleConstant.CONTROL_BEHAVIOR_DEFAULT);//流控效果 return rule; } //白名单 private static AuthorityRule whiteList(){ AuthorityRule rule = new AuthorityRule(); rule.setResource(\"whiteList\");//资源名，即规则的作用对象 rule.setLimitApp(\"a\");//流控应用 rule.setStrategy(www.fransesoap.comITY_WHITE);//授权类型 return rule; } } View Code
如果访问来源是 b 则触发黑名单，其他的访问来源则不会限制。同样需要实现 RequestOriginParser 接口，同样的如果访问来源没有带token是无法触发授权规则的。
package com.datang.api.controller;import com.alibaba.csp.sentinel.annotation.SentinelResource;import com.alibaba.csp.sentinel.slots.block.BlockException;import com.datang.api.service.BusinessService;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.web.bind.annotation.GetMapping;import org.springframework.web.bind.annotation.RestController;/** * @author: 顶风少年 * @Description: * @date: 2022/7/1 15:48 **/@RestControllerpublic class DemoController { @Autowired private BusinessService businessService; @GetMapping(value = \"demo1\") @SentinelResource(value = \"blackList\", blockHandler = \"demoBlockHandler\", fallback = \"demoFallback\") public String demo1() { return \"success\"; } public String demoFallback() { return \"方法降级~~~~~~~~~~~~\"; } public String demoBlockHandler(BlockException e) { return \"方法限流~~~~~~~~~~~~\"; }}View Code
package com.datang.api.config;import com.alibaba.csp.sentinel.adapter.spring.webmvc.callback.RequestOriginParser;import org.springframework.stereotype.Component;import javax.servlet.http.HttpServletRequest;/** * @author: 顶风少年 * @Description: * @date: 2022/7/3 17:27 **/@Componentpublic class TokenRequestOriginParser implements RequestOriginParser { @Override public String parseOrigin(HttpServletRequest httpServletRequest) { String authority = httpServletRequest.getHeader(\"auth\"); return authority; }}View Code
使用API的方式设置
package com.datang.api;import com.alibaba.csp.sentinel.slots.block.RuleConstant;import www.fransesoap.comityRule;import www.fransesoap.comityRuleManager;import com.alibaba.csp.sentinel.slots.block.degrade.DegradeRule;import com.alibaba.csp.sentinel.slots.block.degrade.DegradeRuleManager;import com.alibaba.csp.sentinel.slots.block.flow.FlowRule;import com.alibaba.csp.sentinel.slots.block.flow.FlowRuleManager;import org.checkerframework.checker.units.qual.A;import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;import org.springframework.cloud.openfeign.EnableFeignClients;import java.util.ArrayList;import java.util.List;@SpringBootApplication@EnableFeignClientspublic class ApiServer { public static void main(String[] args) { www.fransesoap.com(ApiServer.class, args); initRule(); } public static void initRule() { //熔断规则 List degradeRules = new ArrayList<>(); degradeRules.add(ApiServer.slowRequest()); degradeRules.add(ApiServer.errorRatio()); degradeRules.add(ApiServer.errorCount()); DegradeRuleManager.loadRules(degradeRules); List flowRules = new ArrayList<>(); flowRules.add(ApiServer.qpsDirectConnectionFailFast()); flowRules.add(ApiServer.qpsDirectConnectionWarmUp()); flowRules.add(ApiServer.qpsDirectConnectionQueueUp()); flowRules.add(ApiServer.qpsCorrelationFailFast()); flowRules.add(ApiServer.qpsLikeFailFast()); flowRules.add(ApiServer.threadDirectConnectionFailFast()); FlowRuleManager.loadRules(flowRules); List authorityRules = new ArrayList<>(); authorityRules.add(ApiServer.blackList()); authorityRules.add(ApiServer.whiteList()); AuthorityRuleManager.loadRules(authorityRules); } //慢调用比例 public static DegradeRule slowRequest() { DegradeRule rule = new DegradeRule(); rule.setResource(\"slowRequest\");//资源名，即规则的作用对象 rule.setGrade(RuleConstant.DEGRADE_GRADE_RT);//慢调用比例 rule.setCount(1000);//最大RT rule.setSlowRatioThreshold(0.5);//比例阈值 rule.setTimeWindow(5000);//熔断时长 rule.setMinRequestAmount(50);//最小请求数 rule.setStatIntervalMs(3000);//统计时长 return rule; } //异常比例 public static DegradeRule errorRatio() { DegradeRule rule = new DegradeRule(); rule.setResource(\"errorRatio\");//资源名，即规则的作用对象 rule.setGrade(RuleConstant.DEGRADE_GRADE_EXCEPTION_RATIO);//异常比例 rule.setCount(0.6);//比例阈值 rule.setTimeWindow(20);//熔断时长 rule.setMinRequestAmount(50);//最小请求数 rule.setStatIntervalMs(3000);//统计时长 return rule; } //异常数 public static DegradeRule errorCount() { DegradeRule rule = new DegradeRule(); rule.setResource(\"errorCount\");//资源名，即规则的作用对象 rule.setGrade(RuleConstant.DEGRADE_GRADE_EXCEPTION_COUNT);//异常数 rule.setCount(5);//异常数 rule.setTimeWindow(10);//熔断时长 rule.setMinRequestAmount(10);//最小请求数 rule.setStatIntervalMs(1000);//统计时长 return rule; } //QPS-直接-快速失败 public static FlowRule qpsDirectConnectionFailFast(){ FlowRule rule = new FlowRule(); rule.setResource(\"qpsDirectConnectionFailFast\");//资源名，即规则的作用对象 rule.setLimitApp(\"default\");//针对来源 rule.setGrade(RuleConstant.FLOW_GRADE_QPS);//阈值类型 rule.setCount(1);//单机阈值 rule.setStrategy(RuleConstant.STRATEGY_DIRECT);//流控模式 rule.setControlBehavior(RuleConstant.CONTROL_BEHAVIOR_DEFAULT);//流控效果 return rule; } //QPS-直接-Warm Up public static FlowRule qpsDirectConnectionWarmUp(){ FlowRule rule = new FlowRule(); rule.setResource(\"qpsDirectConnectionWarmUp\");//资源名，即规则的作用对象 rule.setLimitApp(\"default\");//针对来源 rule.setGrade(RuleConstant.FLOW_GRADE_QPS);//阈值类型 rule.setCount(1);//单机阈值 rule.setStrategy(RuleConstant.STRATEGY_DIRECT);//流控模式 rule.setControlBehavior(RuleConstant.CONTROL_BEHAVIOR_WARM_UP);//流控效果 rule.setWarmUpPeriodSec(10);//预热时长 return rule; } //QPS-直接-排队等待 public static FlowRule qpsDirectConnectionQueueUp(){ FlowRule rule = new FlowRule(); rule.setResource(\"qpsDirectConnectionQueueUp\");//资源名，即规则的作用对象 rule.setLimitApp(\"default\");//针对来源 rule.setGrade(RuleConstant.FLOW_GRADE_QPS);//阈值类型 rule.setCount(3);//单机阈值 rule.setStrategy(RuleConstant.STRATEGY_DIRECT);//流控模式 rule.setControlBehavior(RuleConstant.CONTROL_BEHAVIOR_RATE_LIMITER);//流控效果 rule.setMaxQueueingTimeMs(300);//超时时间 return rule; } //QPS-关联-快速失败 public static FlowRule qpsCorrelationFailFast(){ FlowRule rule = new FlowRule(); rule.setResource(\"qpsCorrelationFailFast\");//资源名，即规则的作用对象 rule.setLimitApp(\"default\");//针对来源 rule.setGrade(RuleConstant.FLOW_GRADE_QPS);//阈值类型 rule.setCount(5);//单机阈值 rule.setStrategy(RuleConstant.STRATEGY_RELATE);//流控模式 rule.setRefResource(\"qpsCorrelationFailFast2\");//关联资源 rule.setControlBehavior(RuleConstant.CONTROL_BEHAVIOR_DEFAULT);//流控效果 return rule; } //QPS-链路-快速失败 public static FlowRule qpsLikeFailFast(){ FlowRule rule = new FlowRule(); rule.setResource(\"qpsLikeFailFast\");//资源名，即规则的作用对象 rule.setLimitApp(\"default\");//针对来源 rule.setGrade(RuleConstant.FLOW_GRADE_QPS);//阈值类型 rule.setCount(1);//单机阈值 rule.setStrategy(RuleConstant.STRATEGY_CHAIN);//流控模式 rule.setRefResource(\"/demo2\");//入口资源 rule.setControlBehavior(RuleConstant.CONTROL_BEHAVIOR_DEFAULT);//流控效果 return rule; } //并发线程数-直接-快速失败 public static FlowRule threadDirectConnectionFailFast(){ FlowRule rule = new FlowRule(); rule.setResource(\"threadDirectConnectionFailFast\");//资源名，即规则的作用对象 rule.setLimitApp(\"default\");//针对来源 rule.setGrade(RuleConstant.FLOW_GRADE_THREAD);//阈值类型 rule.setCount(5);//单机阈值 rule.setStrategy(RuleConstant.STRATEGY_DIRECT);//流控模式 rule.setControlBehavior(RuleConstant.CONTROL_BEHAVIOR_DEFAULT);//流控效果 return rule; } //白名单 private static AuthorityRule whiteList(){ AuthorityRule rule = new AuthorityRule(); rule.setResource(\"whiteList\");//资源名，即规则的作用对象 rule.setLimitApp(\"a\");//流控应用 rule.setStrategy(www.fransesoap.comITY_WHITE);//授权类型 return rule; } //黑名单 private static AuthorityRule blackList(){ AuthorityRule rule = new AuthorityRule(); rule.setResource(\"blackList\");//资源名，即规则的作用对象 rule.setLimitApp(\"b\");//流控应用 rule.setStrategy(www.fransesoap.comITY_BLACK);//授权类型 return rule; }} View Code
对资源中的参数做限制，10秒内只允许1QPS，可以对参数的值做额外的限制，值为 zs 的QPS为2。
package com.datang.api.controller;import com.alibaba.csp.sentinel.annotation.SentinelResource;import com.alibaba.csp.sentinel.slots.block.BlockException;import com.datang.api.service.BusinessService;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.web.bind.annotation.GetMapping;import org.springframework.web.bind.annotation.RestController;/** * @author: 顶风少年 * @Description: * @date: 2022/7/1 15:48 **/@RestControllerpublic class DemoController { @Autowired private BusinessService businessService; @GetMapping(value = \"demo1\") @SentinelResource(value = \"param\", blockHandler = \"demoBlockHandler\", fallback = \"demoFallback\") public String demo1(String name) { return \"success\"; } public String demoFallback() { return \"方法降级~~~~~~~~~~~~\"; } public String demoBlockHandler(String name,BlockException e) { return \"方法限流~~~~~~~~~~~~\"; }}View Code
使用API的方式设置
package com.datang.api;import com.alibaba.csp.sentinel.slots.block.RuleConstant;import www.fransesoap.comityRule;import www.fransesoap.comityRuleManager;import com.alibaba.csp.sentinel.slots.block.degrade.DegradeRule;import com.alibaba.csp.sentinel.slots.block.degrade.DegradeRuleManager;import com.alibaba.csp.sentinel.slots.block.flow.FlowRule;import com.alibaba.csp.sentinel.slots.block.flow.FlowRuleManager;import com.alibaba.csp.sentinel.slots.block.flow.param.ParamFlowItem;import com.alibaba.csp.sentinel.slots.block.flow.param.ParamFlowRule;import com.alibaba.csp.sentinel.slots.block.flow.param.ParamFlowRuleManager;import org.checkerframework.checker.units.qual.A;import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;import org.springframework.cloud.openfeign.EnableFeignClients;import java.util.ArrayList;import java.util.List;@SpringBootApplication@EnableFeignClientspublic class ApiServer { public static void main(String[] args) { www.fransesoap.com(ApiServer.class, args); initRule(); } public static void initRule() { //熔断规则 List degradeRules = new ArrayList<>(); degradeRules.add(ApiServer.slowRequest()); degradeRules.add(ApiServer.errorRatio()); degradeRules.add(ApiServer.errorCount()); DegradeRuleManager.loadRules(degradeRules); //流控规则 List flowRules = new ArrayList<>(); flowRules.add(ApiServer.qpsDirectConnectionFailFast()); flowRules.add(ApiServer.qpsDirectConnectionWarmUp()); flowRules.add(ApiServer.qpsDirectConnectionQueueUp()); flowRules.add(ApiServer.qpsCorrelationFailFast()); flowRules.add(ApiServer.qpsLikeFailFast()); flowRules.add(ApiServer.threadDirectConnectionFailFast()); FlowRuleManager.loadRules(flowRules); //授权规则 List authorityRules = new ArrayList<>(); authorityRules.add(ApiServer.blackList()); authorityRules.add(ApiServer.whiteList()); AuthorityRuleManager.loadRules(authorityRules); //热点规则 List paramFlowRules = new ArrayList<>(); paramFlowRules.add(ApiServer.param()); ParamFlowRuleManager.loadRules(paramFlowRules); } //慢调用比例 public static DegradeRule slowRequest() { DegradeRule rule = new DegradeRule(); rule.setResource(\"slowRequest\");//资源名，即规则的作用对象 rule.setGrade(RuleConstant.DEGRADE_GRADE_RT);//慢调用比例 rule.setCount(1000);//最大RT rule.setSlowRatioThreshold(0.5);//比例阈值 rule.setTimeWindow(5000);//熔断时长 rule.setMinRequestAmount(50);//最小请求数 rule.setStatIntervalMs(3000);//统计时长 return rule; } //异常比例 public static DegradeRule errorRatio() { DegradeRule rule = new DegradeRule(); rule.setResource(\"errorRatio\");//资源名，即规则的作用对象 rule.setGrade(RuleConstant.DEGRADE_GRADE_EXCEPTION_RATIO);//异常比例 rule.setCount(0.6);//比例阈值 rule.setTimeWindow(20);//熔断时长 rule.setMinRequestAmount(50);//最小请求数 rule.setStatIntervalMs(3000);//统计时长 return rule; } //异常数 public static DegradeRule errorCount() { DegradeRule rule = new DegradeRule(); rule.setResource(\"errorCount\");//资源名，即规则的作用对象 rule.setGrade(RuleConstant.DEGRADE_GRADE_EXCEPTION_COUNT);//异常数 rule.setCount(5);//异常数 rule.setTimeWindow(10);//熔断时长 rule.setMinRequestAmount(10);//最小请求数 rule.setStatIntervalMs(1000);//统计时长 return rule; } //QPS-直接-快速失败 public static FlowRule qpsDirectConnectionFailFast(){ FlowRule rule = new FlowRule(); rule.setResource(\"qpsDirectConnectionFailFast\");//资源名，即规则的作用对象 rule.setLimitApp(\"default\");//针对来源 rule.setGrade(RuleConstant.FLOW_GRADE_QPS);//阈值类型 rule.setCount(1);//单机阈值 rule.setStrategy(RuleConstant.STRATEGY_DIRECT);//流控模式 rule.setControlBehavior(RuleConstant.CONTROL_BEHAVIOR_DEFAULT);//流控效果 return rule; } //QPS-直接-Warm Up public static FlowRule qpsDirectConnectionWarmUp(){ FlowRule rule = new FlowRule(); rule.setResource(\"qpsDirectConnectionWarmUp\");//资源名，即规则的作用对象 rule.setLimitApp(\"default\");//针对来源 rule.setGrade(RuleConstant.FLOW_GRADE_QPS);//阈值类型 rule.setCount(1);//单机阈值 rule.setStrategy(RuleConstant.STRATEGY_DIRECT);//流控模式 rule.setControlBehavior(RuleConstant.CONTROL_BEHAVIOR_WARM_UP);//流控效果 rule.setWarmUpPeriodSec(10);//预热时长 return rule; } //QPS-直接-排队等待 public static FlowRule qpsDirectConnectionQueueUp(){ FlowRule rule = new FlowRule(); rule.setResource(\"qpsDirectConnectionQueueUp\");//资源名，即规则的作用对象 rule.setLimitApp(\"default\");//针对来源 rule.setGrade(RuleConstant.FLOW_GRADE_QPS);//阈值类型 rule.setCount(3);//单机阈值 rule.setStrategy(RuleConstant.STRATEGY_DIRECT);//流控模式 rule.setControlBehavior(RuleConstant.CONTROL_BEHAVIOR_RATE_LIMITER);//流控效果 rule.setMaxQueueingTimeMs(300);//超时时间 return rule; } //QPS-关联-快速失败 public static FlowRule qpsCorrelationFailFast(){ FlowRule rule = new FlowRule(); rule.setResource(\"qpsCorrelationFailFast\");//资源名，即规则的作用对象 rule.setLimitApp(\"default\");//针对来源 rule.setGrade(RuleConstant.FLOW_GRADE_QPS);//阈值类型 rule.setCount(5);//单机阈值 rule.setStrategy(RuleConstant.STRATEGY_RELATE);//流控模式 rule.setRefResource(\"qpsCorrelationFailFast2\");//关联资源 rule.setControlBehavior(RuleConstant.CONTROL_BEHAVIOR_DEFAULT);//流控效果 return rule; } //QPS-链路-快速失败 public static FlowRule qpsLikeFailFast(){ FlowRule rule = new FlowRule(); rule.setResource(\"qpsLikeFailFast\");//资源名，即规则的作用对象 rule.setLimitApp(\"default\");//针对来源 rule.setGrade(RuleConstant.FLOW_GRADE_QPS);//阈值类型 rule.setCount(1);//单机阈值 rule.setStrategy(RuleConstant.STRATEGY_CHAIN);//流控模式 rule.setRefResource(\"/demo2\");//入口资源 rule.setControlBehavior(RuleConstant.CONTROL_BEHAVIOR_DEFAULT);//流控效果 return rule; } //并发线程数-直接-快速失败 public static FlowRule threadDirectConnectionFailFast(){ FlowRule rule = new FlowRule(); rule.setResource(\"threadDirectConnectionFailFast\");//资源名，即规则的作用对象 rule.setLimitApp(\"default\");//针对来源 rule.setGrade(RuleConstant.FLOW_GRADE_THREAD);//阈值类型 rule.setCount(5);//单机阈值 rule.setStrategy(RuleConstant.STRATEGY_DIRECT);//流控模式 rule.setControlBehavior(RuleConstant.CONTROL_BEHAVIOR_DEFAULT);//流控效果 return rule; } //白名单 private static AuthorityRule whiteList(){ AuthorityRule rule = new AuthorityRule(); rule.setResource(\"whiteList\");//资源名，即规则的作用对象 rule.setLimitApp(\"a\");//流控应用 rule.setStrategy(www.fransesoap.comITY_WHITE);//授权类型 return rule; } //黑名单 private static AuthorityRule blackList(){ AuthorityRule rule = new AuthorityRule(); rule.setResource(\"blackList\");//资源名，即规则的作用对象 rule.setLimitApp(\"b\");//流控应用 rule.setStrategy(www.fransesoap.comITY_BLACK);//授权类型 return rule; } //热点规则 public static ParamFlowRule param(){ ParamFlowRule rule = new ParamFlowRule(); rule.setResource(\"param\");//资源名 rule.setParamIdx(0);//参数索引 rule.setCount(1);//单机阈值 rule.setDurationInSec(10);//统计窗口时长 List items = new ArrayList<>(); ParamFlowItem item = new ParamFlowItem();//参数例外项 item.setClassType(String.class.getName());//参数类型 item.setObject(\"zs\");//参数值 item.setCount(3);//限流阈值 items.add(item); rule.setParamFlowItemList(items); return rule; }} View Code
Sentinel 系统自适应限流对应用级别入口流量进行整体控制，结合应用的 Load、CPU 使用率、平均 RT、入口 QPS 和入口并发线程数等几个维度的监控指标，通过自适应的流控策略，让系统的入口流量和系统的负载达到一个平衡，让系统尽可能跑在最大吞吐量的同时保证系统整体的稳定性。由于该限流方式中阈值的设置需要很多系统软硬件相关的数据，而与代码关系不大，所以这种限流方式一般是由运维来设置的。
package com.datang.api;import com.alibaba.csp.sentinel.slots.block.RuleConstant;import www.fransesoap.comityRule;import www.fransesoap.comityRuleManager;import com.alibaba.csp.sentinel.slots.block.degrade.DegradeRule;import com.alibaba.csp.sentinel.slots.block.degrade.DegradeRuleManager;import com.alibaba.csp.sentinel.slots.block.flow.FlowRule;import com.alibaba.csp.sentinel.slots.block.flow.FlowRuleManager;import com.alibaba.csp.sentinel.slots.block.flow.param.ParamFlowItem;import com.alibaba.csp.sentinel.slots.block.flow.param.ParamFlowRule;import com.alibaba.csp.sentinel.slots.block.flow.param.ParamFlowRuleManager;import com.alibaba.csp.sentinel.slots.system.SystemRule;import com.alibaba.csp.sentinel.slots.system.SystemRuleManager;import org.checkerframework.checker.units.qual.A;import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;import org.springframework.cloud.openfeign.EnableFeignClients;import java.util.ArrayList;import java.util.List;@SpringBootApplication@EnableFeignClientspublic class ApiServer { public static void main(String[] args) { www.fransesoap.com(ApiServer.class, args); initRule(); } public static void initRule() { //熔断规则 List degradeRules = new ArrayList<>(); degradeRules.add(ApiServer.slowRequest()); degradeRules.add(ApiServer.errorRatio()); degradeRules.add(ApiServer.errorCount()); DegradeRuleManager.loadRules(degradeRules); //流控规则 List flowRules = new ArrayList<>(); flowRules.add(ApiServer.qpsDirectConnectionFailFast()); flowRules.add(ApiServer.qpsDirectConnectionWarmUp()); flowRules.add(ApiServer.qpsDirectConnectionQueueUp()); flowRules.add(ApiServer.qpsCorrelationFailFast()); flowRules.add(ApiServer.qpsLikeFailFast()); flowRules.add(ApiServer.threadDirectConnectionFailFast()); FlowRuleManager.loadRules(flowRules); //授权规则 List authorityRules = new ArrayList<>(); authorityRules.add(ApiServer.blackList()); authorityRules.add(ApiServer.whiteList()); AuthorityRuleManager.loadRules(authorityRules); //热点规则 List paramFlowRules = new ArrayList<>(); paramFlowRules.add(ApiServer.param()); ParamFlowRuleManager.loadRules(paramFlowRules); //系统规则 List systemRules = new ArrayList<>(); systemRules.add(ApiServer.system()); SystemRuleManager.loadRules(systemRules); } //慢调用比例 public static DegradeRule slowRequest() { DegradeRule rule = new DegradeRule(); rule.setResource(\"slowRequest\");//资源名，即规则的作用对象 rule.setGrade(RuleConstant.DEGRADE_GRADE_RT);//慢调用比例 rule.setCount(1000);//最大RT rule.setSlowRatioThreshold(0.5);//比例阈值 rule.setTimeWindow(5000);//熔断时长 rule.setMinRequestAmount(50);//最小请求数 rule.setStatIntervalMs(3000);//统计时长 return rule; } //异常比例 public static DegradeRule errorRatio() { DegradeRule rule = new DegradeRule(); rule.setResource(\"errorRatio\");//资源名，即规则的作用对象 rule.setGrade(RuleConstant.DEGRADE_GRADE_EXCEPTION_RATIO);//异常比例 rule.setCount(0.6);//比例阈值 rule.setTimeWindow(20);//熔断时长 rule.setMinRequestAmount(50);//最小请求数 rule.setStatIntervalMs(3000);//统计时长 return rule; } //异常数 public static DegradeRule errorCount() { DegradeRule rule = new DegradeRule(); rule.setResource(\"errorCount\");//资源名，即规则的作用对象 rule.setGrade(RuleConstant.DEGRADE_GRADE_EXCEPTION_COUNT);//异常数 rule.setCount(5);//异常数 rule.setTimeWindow(10);//熔断时长 rule.setMinRequestAmount(10);//最小请求数 rule.setStatIntervalMs(1000);//统计时长 return rule; } //QPS-直接-快速失败 public static FlowRule qpsDirectConnectionFailFast(){ FlowRule rule = new FlowRule(); rule.setResource(\"qpsDirectConnectionFailFast\");//资源名，即规则的作用对象 rule.setLimitApp(\"default\");//针对来源 rule.setGrade(RuleConstant.FLOW_GRADE_QPS);//阈值类型 rule.setCount(1);//单机阈值 rule.setStrategy(RuleConstant.STRATEGY_DIRECT);//流控模式 rule.setControlBehavior(RuleConstant.CONTROL_BEHAVIOR_DEFAULT);//流控效果 return rule; } //QPS-直接-Warm Up public static FlowRule qpsDirectConnectionWarmUp(){ FlowRule rule = new FlowRule(); rule.setResource(\"qpsDirectConnectionWarmUp\");//资源名，即规则的作用对象 rule.setLimitApp(\"default\");//针对来源 rule.setGrade(RuleConstant.FLOW_GRADE_QPS);//阈值类型 rule.setCount(1);//单机阈值 rule.setStrategy(RuleConstant.STRATEGY_DIRECT);//流控模式 rule.setControlBehavior(RuleConstant.CONTROL_BEHAVIOR_WARM_UP);//流控效果 rule.setWarmUpPeriodSec(10);//预热时长 return rule; } //QPS-直接-排队等待 public static FlowRule qpsDirectConnectionQueueUp(){ FlowRule rule = new FlowRule(); rule.setResource(\"qpsDirectConnectionQueueUp\");//资源名，即规则的作用对象 rule.setLimitApp(\"default\");//针对来源 rule.setGrade(RuleConstant.FLOW_GRADE_QPS);//阈值类型 rule.setCount(3);//单机阈值 rule.setStrategy(RuleConstant.STRATEGY_DIRECT);//流控模式 rule.setControlBehavior(RuleConstant.CONTROL_BEHAVIOR_RATE_LIMITER);//流控效果 rule.setMaxQueueingTimeMs(300);//超时时间 return rule; } //QPS-关联-快速失败 public static FlowRule qpsCorrelationFailFast(){ FlowRule rule = new FlowRule(); rule.setResource(\"qpsCorrelationFailFast\");//资源名，即规则的作用对象 rule.setLimitApp(\"default\");//针对来源 rule.setGrade(RuleConstant.FLOW_GRADE_QPS);//阈值类型 rule.setCount(5);//单机阈值 rule.setStrategy(RuleConstant.STRATEGY_RELATE);//流控模式 rule.setRefResource(\"qpsCorrelationFailFast2\");//关联资源 rule.setControlBehavior(RuleConstant.CONTROL_BEHAVIOR_DEFAULT);//流控效果 return rule; } //QPS-链路-快速失败 public static FlowRule qpsLikeFailFast(){ FlowRule rule = new FlowRule(); rule.setResource(\"qpsLikeFailFast\");//资源名，即规则的作用对象 rule.setLimitApp(\"default\");//针对来源 rule.setGrade(RuleConstant.FLOW_GRADE_QPS);//阈值类型 rule.setCount(1);//单机阈值 rule.setStrategy(RuleConstant.STRATEGY_CHAIN);//流控模式 rule.setRefResource(\"/demo2\");//入口资源 rule.setControlBehavior(RuleConstant.CONTROL_BEHAVIOR_DEFAULT);//流控效果 return rule; } //并发线程数-直接-快速失败 public static FlowRule threadDirectConnectionFailFast(){ FlowRule rule = new FlowRule(); rule.setResource(\"threadDirectConnectionFailFast\");//资源名，即规则的作用对象 rule.setLimitApp(\"default\");//针对来源 rule.setGrade(RuleConstant.FLOW_GRADE_THREAD);//阈值类型 rule.setCount(5);//单机阈值 rule.setStrategy(RuleConstant.STRATEGY_DIRECT);//流控模式 rule.setControlBehavior(RuleConstant.CONTROL_BEHAVIOR_DEFAULT);//流控效果 return rule; } //白名单 private static AuthorityRule whiteList(){ AuthorityRule rule = new AuthorityRule(); rule.setResource(\"whiteList\");//资源名，即规则的作用对象 rule.setLimitApp(\"a\");//流控应用 rule.setStrategy(www.fransesoap.comITY_WHITE);//授权类型 return rule; } //黑名单 private static AuthorityRule blackList(){ AuthorityRule rule = new AuthorityRule(); rule.setResource(\"blackList\");//资源名，即规则的作用对象 rule.setLimitApp(\"b\");//流控应用 rule.setStrategy(www.fransesoap.comITY_BLACK);//授权类型 return rule; } //热点规则 public static ParamFlowRule param(){ ParamFlowRule rule = new ParamFlowRule(); rule.setResource(\"param\");//资源名 rule.setParamIdx(0);//参数索引 rule.setCount(1);//单机阈值 rule.setDurationInSec(10);//统计窗口时长 List items = new ArrayList<>(); ParamFlowItem item = new ParamFlowItem();//参数例外项 item.setClassType(String.class.getName());//参数类型 item.setObject(\"zs\");//参数值 item.setCount(3);//限流阈值 items.add(item); rule.setParamFlowItemList(items); return rule; } //系统规则 public static SystemRule system(){ SystemRule rule = new SystemRule(); rule.setHighestSystemLoad(100);//LOAD rule.setAvgRt(3);//RT rule.setMaxThread(2);//线程数 rule.setQps(5);//入口 QPS rule.setHighestCpuUsage(0.2);//CPU 使用率 return rule; }} View Code
该模式仅对 Linux/Unix-like 系统生效。当系统 CPU 最近一分钟的负载量 load1 超过了设置的阈值时会触发系统保护，即对再来的请求进行限流处理。这个阈值就是系统负载容量，系统容量可以由 maxQps * minRt 估算得出。不过，也可以通过 CPU cores * 2.5 计算出其参考数值。
当对当前应用上所有入口流量的平均 RT 达到阈值时触发系统保护，单位是毫秒。
当对当前应用的所有入口流量进行处理的所有线程数量达到阈值时触发系统保护。
当对当前应用的所有入口流量的总 QPS 达到阈值时触发系统保护。
当系统 CPU 使用率超过阈值即触发系统保护（取值范围 0.0-1.0），比较灵敏。
在代码中配置了规则以后，往往我们需要在控制台根据实际情况修改，但在控制台修改后，当项目重启，控制台没有保留我们的配置。所以我们需要可以持久化的配置，sentinel提供了本地文件持久化和nacos持久化，这里我用的nacos持久化。
新增csp包，然后再yml文件中连接nacos。
xmlns:xsi =\"http://www.fransesoap.com/2001/XMLSchema-instance\" xsi:schemaLocation=\"http://www.fransesoap.com/POM/4.0.0 http://www.fransesoap.com/xsd/maven-4.0.0.xsd\">4.0.0 com.datang parent 1.0-SNAPSHOT pom ../api ../business 8 8 www.fransesoap.com9 2.2.6.RELEASE org.springframework.boot spring-boot-starter-parent 2.3.2.RELEASE org.springframework.boot spring-boot-starter-web www.fransesoap.com spring-cloud-starter-alibaba-nacos-discovery www.fransesoap.com spring-cloud-starter-alibaba-nacos-config www.fransesoap.com spring-cloud-starter-openfeign www.fransesoap.com spring-cloud-starter-alibaba-sentinel com.alibaba.csp sentinel-datasource-nacos www.fransesoap.com spring-cloud-dependencies ${spring-cloud.version} pom import www.fransesoap.com spring-cloud-alibaba-dependencies ${spring-cloud-alibaba.version} pom import
View Code
server: port: 8080spring: application: name: api cloud: nacos: discovery: server-addr: 127.00.1:8848 sentinel: transport: dashboard: localhost:8888 port: 8720 eager: true web-context-unify: false datasource: ds-flow: #任意 nacos: server-addr: localhost:8848 #nacos地址 dataId: ${www.fransesoap.com}-flow-rules #配置文件Data ID data-type: json rule-type: flow #流控规则 #rule-type: degrade #熔断规则 #rule-type: authority #授权规则 #rule-type: param-flow #热点规则 #rule-type: system #系统规则ribbon: ReadTimeout: 5000 ConnectTimeout: 5000feign: client: config: default: connectTimeout: 5000 readTimeout: 5000eureka: client: register-with-eureka: true fetch-registry: true service-url: defaultZone: http://localhost:7001/eureka#java -Dserver.port=8888 -Dcsp.sentinel.dashboard.server=localhost:8888 -www.fransesoap.com=sentinel-dashboard -Dsentinel.dashboard.auth.username=sentinel -Dsentinel.dashboard.auth.password=sentinel -jar sentinel-dashboard-1.8.4.jarView Code
在nacos配置的规则，在sentinel是不显示的，如果需要返显，需要下载sentinel源码然后改造,目前官方只提供了流控规则的控制台改造案例。
修改1：sentinel-dashboard/pom.xml
修改2：D:\\office\\sentinel\\Sentinel-master\\sentinel-dashboard\\src\\test\\java\\com\\alibaba\\csp\\sentinel\\dashboard\\rule文件夹及其4个java文件复制到D:\\office\\sentinel\\Sentinel-master\\sentinel-dashboard\\src\\main\\java\\com\\alibaba\\csp\\sentinel\\dashboard\\rule下
修改3：D:\\office\\sentinel\\Sentinel-master\\sentinel-dashboard\\src\\main\\java\\com\\alibaba\\csp\\sentinel\\dashboard\\controller\\v2\\www.fransesoap.com
修改4：D:\\office\\sentinel\\Sentinel-master\\sentinel-dashboard\\src\\main\\java\\com\\alibaba\\csp\\sentinel\\dashboard\\rule\\nacos\\www.fransesoap.com
修改5：D:\\office\\sentinel\\Sentinel-master\\sentinel-dashboard\\src\\main\\resources\\application.properties
修改6：D:\\office\\sentinel\\Sentinel-master\\sentinel-dashboard\\src\\main\\webapp\\resources\\app\\scripts\\directives\\sidebar\\sidebar.html
mvn clean package -Dmaven.test.skip=true 重新打包，然后启动。
