微服务组件详解——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.rhkb.cn/news/28093.html

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

相关文章

AJAX介绍

XMLHttpRequest get请求使用 const xhr new XMLHttpRequest(); xhr.open("GET", "/data/test.json", true); xhr.onreadystatechange function () {if (xhr.readyState 4) {if (xhr.status 200) {alert(xhr.responseText);} else {console.log("…

Windows下使用docker安装rocketmq

最近准备把rocketmq重新学下&#xff0c;先把环境搭建好 Windows下安装docker拉取最新的rocketmq启动nameserver启动broker 首先在Windows下安装docker&#xff0c;之前不知道为什么&#xff0c;docker desktop启动一直报错&#xff0c;今天把Windows更新了一下&#xff0c;do…

Oracle 11g的部署配置

1、进入官网下载所需版本的Oracle 2、安装 ①&#xff1a;选择setup.exe开始安装 ②&#xff1a;安装提示如下&#xff0c;直接忽略&#xff0c;选是 ③&#xff1a;配置安全更新 填写邮箱&#xff0c;并取消勾选 ④&#xff1a;如果点击下一步&#xff0c;提示什么代理啥的…

【RabbitMQ】RabbitMQ的核心概念与七大工作模式

&#x1f525;个人主页&#xff1a; 中草药 &#x1f525;专栏&#xff1a;【中间件】企业级中间件剖析 在现代分布式系统和微服务架构中&#xff0c;消息队列&#xff08;Message Queue&#xff09; 是解决服务间通信、系统解耦和流量削峰的关键技术之一。而 RabbitMQ 作为一…

springboot宠物服务系统-计算机毕业设计源码29146

目 录 摘要 1 绪论 1.1 研究背景 1.2 研究意义 1.3 论文结构与章节安排 2 系统分析 2.1 可行性分析 2.2 系统流程分析 2.2.1 数据新增流程 2.2.2 数据删除流程 2.3 系统功能分析 2.3.1 功能性分析 2.3.2 非功能性分析 2.4 系统用例分析 2.5本章小结 3 系统总体…

使用 CLion 代替 BeyondStudio for NXP 开发 JN 5169

使用 CLion 代替 BeyondStudio for NXP 开发 JN 5169 一、安装 CLion二、搭建 NXP JN5169 ZigBee 3.0 开发环境和下载示例工程三、配置 CLion1、使用 CLion 打开 JN-AN-12192、创建自定义构建目标3、添加构建配置4、在构建前添加外部工具5、添加 6 个运行配置对于 6 个构建选项…

《鸢尾花数学大系:从加减乘除到机器学习》开源资源

《鸢尾花数学大系&#xff1a;从加减乘除到机器学习》开源资源 Gitee&#xff1a;https://gitee.com/higkoo/ bilibili&#xff1a;https://space.bilibili.com/513194466 GitHub&#xff1a;https://github.com/Visualize-ML

操作系统启动——前置知识预备

文章目录 1. 理解冯诺依曼体系结构1.1 简单见一见冯诺依曼1.2 进一步认识1.3 为什么一定要有内存的存在&#xff1f; 2. 操作系统2.1 概念2.2 设计OS的目的2.3 OS的核心功能2.4 如何理解“管理”二字&#xff1f;(小故事版)2.5 系统调用和库函数概念 3. 进程简述3.1 基本概念3.…

PMP项目管理—资源管理篇—5.管理团队

文章目录 基本信息4W1HITTO输入工具与技术输出 冲突管理解决方案八字方针冲突管理策略 基本信息 4W1H what: 跟踪团队成员工作表现&#xff0c;提供反馈&#xff0c;解决问题并管理团队变更&#xff0c;以优化项目绩效的过程。why: 影响团队行为、管理团队冲突&#xff0c;解…

数据结构与算法:选择排序

介绍 选择排序是一种简单直观的排序算法&#xff0c;其基本思想是&#xff1a;从待排序的数据元素中&#xff0c;每次选择最小&#xff08;或最大&#xff09;的元素&#xff0c;将其与序列的起始位置交换&#xff0c;然后继续对剩余的元素进行排序&#xff0c;知道整个序列排…

大模型提示词推理架构对比:ReAct/CoT/ToT

人工智能&#xff08;AI&#xff09;已不再只是一个流行词——它是驱动现代问题解决的引擎。但AI究竟是如何“思考”的呢&#xff1f;这就涉及到了推理框架。在本文中&#xff0c;我们将探讨三种关键框架&#xff1a;ReAct&#xff08;推理与行动&#xff09;、思维链&#xff…

【Linux】冯诺依曼体系结构-操作系统

一.冯诺依曼体系结构 我们所使用的计算机&#xff0c;如笔记本等都是按照冯诺依曼来设计的&#xff1a; 截止目前&#xff0c;我们所知道的计算机都是由一个一个的硬件组装起来的&#xff0c;这些硬件又由于功能的不同被分为了输入设备&#xff0c;输出设备&#xff0c;存储器…

【云原生】Spring Cloud是什么?Spring Cloud版本介绍

什么是SpringCloud 上一章节介绍了总体的SpringCloud的总体学习章节&#xff0c;因为最近项目刚好需要用到SpringCloud来搭建微服务项目、所以就跟着大家一起来再学习巩固下SpringCloud的相关知识 SpringCloud是基于SpringBoot提供了一套微服务解决方案&#xff0c;包括服务注…

人机交互革命:从触屏到脑波的13维战争

人机交互革命&#xff1a;从触屏到脑波的13维战争 一、交互维度大爆炸&#xff1a;重新定义人机沟通边界 当ChatGPT开始解析你的微表情&#xff0c;当Neuralink芯片能读取皮层信号&#xff0c;人机交互已突破【键鼠】的次元壁。我们正经历人类史上最大规模的感官革命&#xff…

高考數學。。。

2024上 具体来说&#xff0c;直线的参数方程可以写为&#xff1a; x1t y−t z1t 二、简答题(本大题共5小题&#xff0c;每小题7分&#xff0c;共35分。) 12.数学学习评价不仅要关注结果评价&#xff0c;也要关注过程评价。简要说明过程评价应关注哪几个方面。…

低空监视-无人机专用ADS-B应答机

产品简介 ping200XR是经过TSO适航认证的无人机专用ADS-B应答机&#xff0c;用于中大型无人机的低空监视。将经过认证的航空级航电设备引入无人机系统。该应答机支持航管二次雷达A&#xff0c;C/S模式和ADS-B OUT。重量仅52克满足无人机所面临的尺寸、重量、功耗的挑战&#xf…

Compose Multiplatform+Kotlin Multiplatfrom 第四弹跨平台

文章目录 引言功能效果开发准备依赖使用gradle依赖库MVIFlow设计富文本显示 总结 引言 Compose Multiplatformkotlin Multiplatfrom 今天已经到compose v1.7.3&#xff0c;从界面UI框架上实战开发看&#xff0c;很多api都去掉实验性注解&#xff0c;表示稳定使用了&#xff01;…

VLM-E2E:通过多模态驾驶员注意融合增强端到端自动驾驶

25年2月来自香港科大广州分校、理想汽车和厦门大学的论文“VLM-E2E: Enhancing End-to-End Autonomous Driving with Multimodal Driver Attention Fusion”。 人类驾驶员能够利用丰富的注意语义&#xff0c;熟练地应对复杂场景&#xff0c;但当前的自动驾驶系统难以复制这种能…

Linux的进程观:简单性如何成就强大性(三)

1. 环境变量 1.1. 基本概念 环境变量(environment variables)⼀般是指在操作系统中⽤来指定操作系统运⾏环境的⼀些参数。 如&#xff1a;我们在编写C/C代码的时候&#xff0c;在链接的时候&#xff0c;从来不知道我们的所链接的动态静态库在哪⾥&#xff0c;但是照样可以链接…

广域互联网关键技术详解(GRE/LSTP/IPsec/NAT/SAC/SPR)

《广域互联网关键技术详解》属于博主的“广域网”专栏&#xff0c;若想成为HCIE&#xff0c;对于广域网相关的知识需要非常了解&#xff0c;更多关于广域网的内容博主会更新在“广域网”专栏里&#xff0c;请持续关注&#xff01; 一.前言 广域互联技术纷杂多样&#xff0c;不…