微服务组件详解——sentinel

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 默认trueeager: 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:资源名称,必需项(不能为空)

entryTypeentry 类型,可选项(默认为 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异常,所以我们要处理这个异常

注意:
  1. fallback 方法可以在同一个类中定义,也可以在其他类中定义。如果在其他类中定义,则需要通过 fallbackClass 属性指定该类
  2. 返回类型:fallback 方法的返回类型必须与被保护的方法相同
  3. fallback 方法应该为 public,以便 Sentinel 框架能够调用它
  4. 参数列表: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-consumecloud:sentinel:transport:port: 8719 #sentinel控制台端口dashboard: 127.0.0.1:9999 #sentinel控制台地址enable: true #开启sentinel 默认trueeager: 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:8848data-id: "${spring.application.name}-degrade"group-id: DEFAULT_GROUPdata-type: jsonrule-type: degrade #指定为熔断降级规则ds3: #热点参数限流配置nacos:server-addr: 127.0.0.1:8848data-id: "${spring.application.name}-param-flow"group-id: DEFAULT_GROUPdata-type: jsonrule-type: param-flow

能够在sentinel里面看到持久化的

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/bicheng/72531.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

AI数据分析:deepseek生成SQL

在当今数据驱动的时代&#xff0c;数据分析已成为企业和个人决策的重要工具。随着人工智能技术的快速发展&#xff0c;AI 驱动的数据分析工具正在改变我们处理和分析数据的方式。本文将着重介绍如何使用 DeepSeek 进行自动补全SQL 查询语句。 我们都知道&#xff0c;SQL 查询语…

动态规划01背包问题系列一>目标和

目录 题目分析及优化&#xff1a;状态表示&#xff1a;状态转移方程&#xff1a;初始化&#xff1a;填表顺序&#xff1a;返回值&#xff1a;代码呈现&#xff1a;优化&#xff1a;代码呈现&#xff1a; 题目分析及优化&#xff1a; 状态表示&#xff1a; 状态转移方程&#xf…

Linux 基础---sudo权限 修改文件所属人、用户所属组

sudo 概念&#xff1a;让普通用户使用管理员权限执行一些操作&#xff08;root&#xff09; 在命令前加上sudo 即可 修改文件所属人、所属组

HMC7043和HMC7044芯片配置使用

一,HMC7043芯片 MC7043独特的特性是对14个通道分别进行独立灵活的相位管理。所有14个通道均支持频率和相位调整。这些输出还可针对50 Ω或100 Ω内部和外部端接选项进行编程。HMC7043器件具有RF SYNC功能,支持确定性同步多个HMC7043器件,即确保所有时钟输出从同一时钟沿开始…

【动手实验】TCP半连接队列、全连接队列实战分析

本文是对 从一次线上问题说起&#xff0c;详解 TCP 半连接队列、全连接队列 这篇文章的实验复现和总结&#xff0c;借此加深对 TCP 半连接队列、全连接队列的理解。 实验环境 两台腾讯云服务器 node2&#xff08;172.19.0.12&#xff09; 和 node3&#xff08;172.19.0.15&am…

Springboot整合WebSocket+Redis以及微信小程序如何调用

一、 Springboot整合WebSocket 1. 引入socket依赖 <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-websocket</artifactId> </dependency>引入依赖后需要刷新maven,Websocket的版本默认跟随S…

影刀RPA开发拓展--SQL常用语句全攻略

前言 SQL&#xff08;结构化查询语言&#xff09;是数据库管理和操作的核心工具&#xff0c;无论是初学者还是经验丰富的数据库管理员&#xff0c;掌握常用的 SQL 语句对于高效管理和查询数据都至关重要。本文将系统性地介绍最常用的 SQL 语句&#xff0c;并为每个语句提供详细…

大模型训练微调技术介绍

大模型训练微调技术是人工智能领域中的一项重要技术&#xff0c;旨在通过少量特定领域的数据对预训练模型进行进一步训练&#xff0c;使其更好地适应具体任务或应用场景。以下是关于大模型训练微调技术的详细介绍&#xff1a; 1. 微调技术的定义与意义 微调&#xff08;Fine-…

生态安全相关

概念&#xff1a;生态安全指一个国家具有支撑国家生存发展的较为完整、不受威胁的生态系统&#xff0c;以及应对内外重大生态问题的能力。 &#xff08;1&#xff09;国外生态安全的研究进展 国际上对生态安全的研究是从“环境”与“安全”之间的关系展开的。开始的阶段&#x…

2024年第十五届蓝桥杯大赛软件赛省赛Python大学A组真题解析《更新中》

文章目录 试题A: 拼正方形(本题总分:5 分)解析答案试题B: 召唤数学精灵(本题总分:5 分)解析答案试题C: 数字诗意解析答案试题D:回文数组试题A: 拼正方形(本题总分:5 分) 【问题描述】 小蓝正在玩拼图游戏,他有7385137888721 个2 2 的方块和10470245 个1 1 的方块,他需…

《张一鸣,创业心路与算法思维》

张一鸣&#xff0c;多年如一日的阅读习惯。 爱读人物传记&#xff0c;称教科书式人类知识最浓缩的书&#xff0c;也爱看心理学&#xff0c;创业以及商业管理类的书。 冯仑&#xff0c;王石&#xff0c;联想&#xff0c;杰克韦尔奇&#xff0c;思科。 《乔布斯传》《埃隆马斯…

策略模式处理

首先&#xff0c;定义接口或抽象父类。例如&#xff0c;定义一个Strategy接口&#xff0c;里面有execute方法。然后不同的策略类实现这个接口&#xff0c;比如ConcreteStrategyA、ConcreteStrategyB等&#xff0c;每个类用Component注解&#xff0c;可能指定Bean的名字&#xf…

go程序中使用pprof增加程序监控功能

1.什么是 pprof&#xff1f; pprof 是 Go 内置的性能分析工具&#xff0c;用于生成程序运行时的性能分析数据。它可以帮助开发者分析&#xff1a; CPU 使用情况 内存分配情况 Goroutine 状况 系统调用分析等 2. 如何使用 pprof&#xff1f; 要使用 pprof&#xff0c;首先需要在…

javaweb自用笔记:Vue

Vue 什么是vue vue案例 1、引入vue.js文件 2、定义vue对象 3、定义vue接管的区域el 4、定义数据模型data 5、定义视图div 6、通过标签v-model来绑定数据模型 7、{{message}}直接将数据模型message展示出来 8、由于vue的双向数据绑定&#xff0c;当视图层标签input里的…

376_C++_云透传,板端负责处理透传数据的API函数,用于实现客户端对设备内部接口的访问(VMS把数据直接传给板端内部)

RsApi_PassThrough 云透传,板端负责处理透传数据的API函数,用于实现客户端对设备内部接口的访问(VMS把数据直接传给板端内部) 我来分析一下 RsApi_PassThrough 函数的作用和实现逻辑: 1. 功能概述 RsApi_PassThrough 是一个透传接口,用于处理 /API/Http/PassThrough 的…

基于eRDMA实测DeepSeek开源的3FS

DeepSeek昨天开源了3FS分布式文件系统, 通过180个存储节点提供了 6.6TiB/s的存储性能, 全面支持大模型的训练和推理的KVCache转存以及向量数据库等能力, 每个客户端节点支持40GB/s峰值吞吐用于KVCache查找. 发布后, 我们在阿里云ECS上进行了快速的复现, 并进行了性能测试, ECS…

计算机毕业设计SpringBoot+Vue.js医院挂号就诊系统(源码+文档+PPT+讲解)

温馨提示&#xff1a;文末有 CSDN 平台官方提供的学长联系方式的名片&#xff01; 温馨提示&#xff1a;文末有 CSDN 平台官方提供的学长联系方式的名片&#xff01; 温馨提示&#xff1a;文末有 CSDN 平台官方提供的学长联系方式的名片&#xff01; 作者简介&#xff1a;Java领…

Linux的用户与权限--第二天

认知root用户&#xff08;超级管理员&#xff09; root用户用于最大的系统操作权限 普通用户的权限&#xff0c;一般在HOME目录内部不受限制 su与exit命令 su命令&#xff1a; su [-] 用户名 -符号是可选的&#xff0c;表示切换用户后加载环境变量 参数为用户名&#xff0c…

计算机网络软考

1.物理层 1.两个主机之间发送数据的过程 自上而下的封装数据&#xff0c;自下而上的解封装数据&#xff0c;实现数据的传输 2.数据、信号、码元 码元就是数字通信里用来表示信息的基本信号单元。比如在二进制中&#xff0c;用高电平代表 “1”、低电平代表 “0”&#xff0c…

第四十一:Axios 模型的 get ,post请求

Axios 的 get 请求方式 9.双向数据绑定 v-model - 邓瑞编程 Axios 的 post 请求方式&#xff1a;