1.启动sentinel:
下载jar sentinel-dashboard-1.8.0.jar
使用以下命令直接运行 jar 包(JDK 版本必须≥ 1.8):
java -Dserver.port=9999 -jar D:\sentinel-dashboard-1.8.0.jar
控制台访问地址:http://localhost:9999,默认账号密码都为 sentinel/sentinel
1.导入依赖:
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
</dependency>
2.在alibaba-user-consumer-8090项目的application.yml编写代码
spring:
cloud:
sentinel:
transport:
port: 8719 #sentinel控制台端口
dashboard: 127.0.0.1:9999 #sentinel控制台地址
enable: true #开启sentinel 默认true
eager: true #取消控制台懒加载 立即初始化
3.监控
这个是实时刷新的,所以点击网址之后等几秒就行
2.流量控制
普通流控:
资源名:请求路径
阈值类型: QPS: 即每秒查询率, 线程数:用
因为是用手测试,所以选QPS
效果:会显示429代表 “Too Many Requests”,即 “请求过多”
关联:(反向关联):
点击高级选项
当sout的阈值超过到1时,demo不可用。(吧demo的资源节省出来给sout)
流控效果:
快速失败:抛异常
方式是默认的流量控制方式,当QPS超过任意规则的阈值后,新的请求就会被立即拒绝,拒绝方
式为抛出 FlowException 。
WarmUp:慢慢增加到阈值
WarmUp 旨在避免因为流量突增或系统负载过高导致的拒绝服务问题。通过“热身”过程,系统逐步适应流量的增加,避免瞬间流量过载。
通过动态控制请求的通过率(例如,限制请求的通过比例),逐渐放开流量限制,避免系统立即面对过多请求的压力。
例如,可以设定初始通过率为 20%,然后逐步提升到 100%,这样系统就能平稳适应流量增长。
排队等待:匀速排队处理
排队等待 是 Sentinel 提供的另一种流量控制策略,用于限制并发请求的数量,并确保在系统负载较高时不会直接拒绝请求,而是让请求在队列中等待,直到系统能够处理它们。
注意:匀速排队模式暂时不支持 QPS > 1000 的场景
3.熔断降级:
这里还没写熔断降级的方法,
选项解析:
最大RT:默认毫秒,请求超出时长
比例阈值:: 当每秒请求量>=N(可配置),并且每秒异常总数占通过量的比值超过阈值之后,进入降级状
态。取值范围[0.0,1.0] 代表0%-100%(如:设置为0.2,如果请求异常数超过20%则进入降级)
最小请求数:请求数小于该值时即使异常比率超出阈值也不会熔断
熔断策略:
1.慢调用比例:
当单位统计时长
( statIntervalMs )内请求数目大于设置的最小请求数目,并且慢调用的比例大于阈值,则接
下来的熔断时长内请求会自动被熔断降级。
2.异常比例:
请求异常数超过0.2(20%)就降级
3.异常数:
当单位统计时长内的异常数目超过阈值之后会自动进行熔断。经过熔断
时长后熔断器会进入探测恢复状态(HALF-OPEN 状态),若接下来的一个请求成功完成(没有错
误)则结束熔断,否则会再次被熔断。
4.热点参数限流:
热点参数限流例子:比如说id为3的商品特别火爆,需要进行限流,但是其他id的商品一般不需要限流
资源名:需要在consumer中的方法上设置@SentinelResource注解
参数索引:就是第几个参数,从0开始
单机阈值:就是正常情况下允许的点击量
限流阈值:就是限流情况下允许的点击量
5.@SentinelResource
@SentinelResource 用于定义资源,并提供可选的异常处理和 fallback 配置项。 @SentinelResource
注解包含以下属性:
value:资源名称,必需项(不能为空)
entryType:entry 类型,可选项(默认为 EntryType.OUT)
blockHandler / blockHandlerClass: blockHandler 对应处理 BlockException 的函数名称,可
选项。blockHandler 函数访问范围需要是 public,返回类型需要与原方法相匹配,参数类型需要
和原方法相匹配并且最后加一个额外的参数,类型为 BlockException。blockHandler 函数默认需
要和原方法在同一个类中。若希望使用其他类的函数,则可以指定 blockHandlerClass 为对应的
类的 Class 对象,注意对应的函数必需为 static 函数,否则无法解析。
fallback:fallback 函数名称,可选项,用于在抛出异常的时候提供 fallback 处理逻辑。fallback
函数可以针对所有类型的异常(除了 exceptionsToIgnore 里面排除掉的异常类型)进行处理。
fallback 函数签名和位置要求:
返回值类型必须与原函数返回值类型一致;
方法参数列表需要和原函数一致,或者可以额外多一个 Throwable 类型的参数用于接收对应的异
常。
fallback 函数默认需要和原方法在同一个类中。若希望使用其他类的函数,则可以指定
fallbackClass 为对应的类的 Class 对象,注意对应的函数必需为 static 函数,否则无法解析。
defaultFallback(since 1.6.0):默认的 fallback 函数名称,可选项,通常用于通用的 fallback
逻辑(即可以用于很多服务或方法)。默认 fallback 函数可以针对所以类型的异常(除了
exceptionsToIgnore 里面排除掉的异常类型)进行处理。若同时配置了 fallback 和
defaultFallback,则只有 fallback 会生效。defaultFallback 函数签名要求:
返回值类型必须与原函数返回值类型一致;
方法参数列表需要为空,或者可以额外多一个 Throwable 类型的参数用于接收对应的异常。
defaultFallback 函数默认需要和原方法在同一个类中。若希望使用其他类的函数,则可以指定
fallbackClass 为对应的类的 Class 对象,注意对应的函数必需为 static 函数,否则无法解析。
exceptionsToIgnore(since 1.6.0):用于指定哪些异常被排除掉,不会计入异常统计中,也不会
进入 fallback 逻辑中,而是会原样抛出
fallback属性:
因为使用热点参数限流以后如果超了阈值就会报500,ParamFlowException异常,所以我们要处理这个异常
注意:
- fallback 方法可以在同一个类中定义,也可以在其他类中定义。如果在其他类中定义,则需要通过 fallbackClass 属性指定该类
- 返回类型:fallback 方法的返回类型必须与被保护的方法相同
- fallback 方法应该为 public,以便 Sentinel 框架能够调用它
- 参数列表:fallback 方法可以有以下几种参数组合:不带参数。只有一个 Throwable 类型的参数,用于接收捕获到的异常。包含原始方法的所有参数和一个 Throwable 类型的参数。
@SentinelResource(value = "demo",fallback = "fallback")
@GetMapping("/demo")
public ResultAJAX demo(Integer id) {
System.out.println("这是方法demo——————————————————————————————"+id);
return ResultAJAX.success();
}
public ResultAJAX fallback(Integer id) {
return ResultAJAX.error("这是方法fallback,用来解决ParamFlowException异常");
}
这样就不会直接报500,而是报我们自定义设置的message
blockHandler属性:
blockHandler 对应处理 BlockException 的函数名称,可选项。blockHandler 函数访问范围需要是 public,返回类型需要与原方法相匹配,参数类型需要 和原方法相匹配并且最后加一个额外的参数,类型为 BlockException。blockHandler 函数默认需要和原方法在同一个类中。若希望使用其他类的函数,则可以指定 blockHandlerClass 为对应的 类的 Class 对象,注意对应的函数必需为 static 函数,否则无法解析。
ParamFlowException 热点参数异常
DegradeException熔断降级异常
FlowException流控异常处理
@SentinelResource(value = "demo",blockHandler = "blockHandler")//
@GetMapping("/demo")
public ResultAJAX demo(Integer id) {
System.out.println("这是方法demo——————————————————————————————"+id);
return ResultAJAX.success();
}
public ResultAJAX blockHandler(Integer id, BlockException e) {
//异常类型判断
//流控异常
if (e instanceof FlowException) {
return ResultAJAX.error("ParamFlowException异常流控异常处理");
}
//熔断降级异常处理
if (e instanceof DegradeException) {
return ResultAJAX.error("熔断降级处理");
}
//热点参数异常
if (e instanceof ParamFlowException) {
return ResultAJAX.error("ParamFlowException异常流控异常处理");
}
return ResultAJAX.error("系统异常"+id);
}
6.基于nacos配置中心进行规则持久化:
sentinel利用nacos做持久化,然后nacos再做持久化
<!--sentinel利用nacos做持久化-->
<dependency>
<groupId>com.alibaba.csp</groupId>
<artifactId>sentinel-datasource-nacos</artifactId>
</dependency>
流量控制配置:
spring:
cloud:
sentinel:
datasource:
ds1:
nacos:
server-addr: 127.0.0.1:8848 #nacos地址
data-id: ${spring.application.name}-flow
#naocs中配置文件名称,对应服务名,可随意填写(和配置中文文件一致即可)
group-id: DEFAULT_GROUP #文件分组
data-type: json #使用json格式
rule-type: flow #使用flow限流
在配置中心配置:
流量控制,热点参数,熔断降级配置:
resource:资源名称
limitApp:来源应用
grade:阈值类型,0表示线程数,1表示QPS
count:单机阈值
strategy:流控模式,0表示直接,1表示关联,2表示链路
controlBehavior:流控效果,0表示快速失败,1表示Warm Up,2表示排队等待
clusterMode:是否集群
nacos-consume-flow配置:限流配置
[
{
"resource": "demo",
"limitApp": "default",
"grade": 1,
"count": 2,
"strategy": 0,
"controlBehavior": 0,
"clusterMode": false
}
]
bill-consumer-degrade配置:熔断降级
[
{
"resource": "abc",
"grade": 0,
"count": 2,
"timeWindow": 1,
"minRequestAmount": 1,
"statIntervalMs": 5
}
]
bill-consumer-7790-param-flow 配置:热点参数限流配置
[
{
"resource": "abc",
"paramIdx": 0,
"count": 10,
"burst": 5,
"duration": 1,
"controlBehavior": 0,
"maxQueueingTimeMs": 500
}
]
yml配置:
spring:
application:
name: nacos-consume
cloud:
sentinel:
transport:
port: 8719 #sentinel控制台端口
dashboard: 127.0.0.1:9999 #sentinel控制台地址
enable: true #开启sentinel 默认true
eager: true #取消控制台懒加载 立即初始化
datasource:
ds1: #限流配置
nacos:
server-addr: 127.0.0.1:8848 #nacos地址
data-id: "${spring.application.name}-flow" #naocs中配置文件名称,对应服务名,可随意填写(和配置中文文件一致即可)
group-id: DEFAULT_GROUP #文件分组
data-type: json #使用json格式
rule-type: flow #使用flow限流
ds2: #熔断降级配置
nacos:
server-addr: 127.0.0.1:8848
data-id: "${spring.application.name}-degrade"
group-id: DEFAULT_GROUP
data-type: json
rule-type: degrade #指定为熔断降级规则
ds3: #热点参数限流配置
nacos:
server-addr: 127.0.0.1:8848
data-id: "${spring.application.name}-param-flow"
group-id: DEFAULT_GROUP
data-type: json
rule-type: param-flow
能够在sentinel里面看到持久化的