Sentinel的另外三种流控模式(附代码详细介绍)

news2024/11/19 7:33:58

前言:大家好,我是小威,24届毕业生,在一家满意的公司实习。本篇文章将详细介绍Sentinel的其他三种流控模式,后续文章将详细介绍Sentinel的其他知识。
如果文章有什么需要改进的地方还请大佬不吝赐教👏👏。
小威在此先感谢各位大佬啦~~🤞🤞
在这里插入图片描述

🏠个人主页:小威要向诸佬学习呀
🧑个人简介:大家好,我是小威,一个想要与大家共同进步的男人😉😉
目前状况🎉:24届毕业生,在一家满意的公司实习👏👏

💕欢迎大家:这里是CSDN,我总结知识的地方,欢迎来到我的博客,我亲爱的大佬😘

在这里插入图片描述

以下正文开始

文章目录

  • 预热模式
  • 排队等待模式
  • 热点规则

在这里插入图片描述

预热模式

Sentinel的warm up模式是一种流量控制模式,它可以在系统刚启动的时候,通过预热的方式逐步放开限流的限制,让系统逐步达到稳定状态,避免系统启动时因为限流过于严格而导致的性能问题。

具体来说,Sentinel的warm up模式会在系统启动时,先限制一定的流量,然后逐步放开限制,直到系统达到一个稳定的状态。在逐步放开限制的过程中,Sentinel会根据系统的实际情况,动态调整限制的值,以确保系统的稳定性和性能

在实际应用中,可以通过以下代码来使用Sentinel的warm up模式:

public class WarmUpDemo {
    public static void main(String[] args) {
        // 创建一个规则实例
        FlowRule rule = new FlowRule();
        rule.setResource("test");
        rule.setGrade(RuleConstant.FLOW_GRADE_QPS);
        rule.setCount(10);
        rule.setControlBehavior(RuleConstant.CONTROL_BEHAVIOR_WARM_UP);
        rule.setWarmUpPeriodSec(10);
        rule.setMaxQueueingTimeMs(500);

        // 加载规则
        List<FlowRule> rules = new ArrayList<>();
        rules.add(rule);
        FlowRuleManager.loadRules(rules);

        // 定义资源
        Entry entry = null;
        try {
            entry = SphU.entry("test");
            // 执行业务逻辑
            // ...
        } catch (BlockException e) {
            // 处理限流
            // ...
        } finally {
            if (entry != null) {
                entry.exit();
            }
        }
    }
}

在上述代码中,我们创建了一个FlowRule实例,将其控制行为设置为CONTROL_BEHAVIOR_WARM_UP,表示使用Sentinel的warm up模式。同时,我们还设置了warmUpPeriodSec参数,表示预热的时间为10秒。在执行业务逻辑时,我们使用SphU.entry方法来获取资源的Entry实例,并在try-catch-finally语句块中处理限流和资源释放的逻辑。

需要注意的是,使用Sentinel的warm up模式需要根据实际情况调整预热时间和限制的值,以确保系统的稳定性和性能

在这里插入图片描述

排队等待模式

Sentinel的排队等待模式是一种流量控制模式,它可以在流量超出阈值时,将请求放入队列中进行等待,直到系统处理完之前的请求后再进行处理。这种模式可以避免系统因瞬间流量过大而崩溃的情况。

在Sentinel中,排队等待模式需要配置一个等待队列的大小,当流量超过阈值时,请求就会被放入等待队列中。同时,还需要配置一个等待时间,如果请求在等待队列中等待的时间超过了设定的等待时间,那么请求将会被直接拒绝

下面是一个使用Sentinel的排队等待模式的代码示例:

@SentinelResource(value = "test", blockHandler = "handleBlock")
public String test() {
    // 方法实现
}

public String handleBlock(BlockException ex) {
    // 处理被拒绝的请求
    return "请求被拒绝,请稍后再试";
}

在上面的代码中,@SentinelResource注解用于标识该方法需要进行流量控制。blockHandler参数指定了当请求被拒绝时的处理方法。如果使用排队等待模式,那么可以在@SentinelResource注解中添加waitQueuemaxQueueingTimeMs参数来配置等待队列的大小和等待时间:

@SentinelResource(value = "test", blockHandler = "handleBlock", waitQueue = true, maxQueueingTimeMs = 5000)
public String test() {
    // 方法实现
}

在上面的代码中,waitQueue参数设置为true表示开启排队等待模式,maxQueueingTimeMs参数设置为5000表示等待时间为5秒。这样,当请求被拒绝时,它就会被放入等待队列中等待处理。如果等待时间超过了5秒,请求将会被直接拒绝。

热点规则

Sentinel的热点规则是一种特殊的限流规则,用于对系统中的热点资源进行限流。热点资源是指在系统中访问频率较高或者访问量较大的资源,例如某个接口、某个方法等。如果这些热点资源没有得到有效的限流控制,就容易导致系统崩溃或者性能下降

Sentinel的热点规则可以通过以下几个方面来进行限流控制:

  1. 参数限流:根据指定的参数进行限流,例如根据某个接口的请求参数进行限流。

  2. URL限流:根据URL进行限流,例如对某个接口的请求URL进行限流。

  3. IP限流:根据IP地址进行限流,例如对某个IP地址的请求进行限流。

  4. 关联流控:根据某个关联的资源进行限流,例如对某个接口的关联接口进行限流。

Sentinel的热点规则可以通过以下几个参数进行配置:

  1. resource:热点资源的名称,可以是接口名称、方法名称、URL等。

  2. count:限流阈值,表示在一个时间窗口内允许通过的请求次数。

  3. paramIndex:参数索引,表示要进行参数限流的参数在请求中的索引位置。

  4. grade:限流模式,可以是QPS模式或线程数模式。

  5. durationSeconds:时间窗口大小,表示限流的时间窗口大小,单位为秒。

  6. controlBehavior:流控模式,可以是快速失败模式、排队等待模式等。

  7. burstCount:预热时的突发流量,表示在预热阶段允许通过的最大请求次数。

总的来说,Sentinel的热点规则可以根据业务需求进行灵活配置,有效地对系统中的热点资源进行限流控制,保证系统的稳定性和性能。

好了,本篇文章就先分享到这里了,后续将会继续介绍sentinel详细的其他方面的知识,感谢大佬认真读完支持咯~
在这里插入图片描述

文章到这里就结束了,如果有什么疑问的地方请指出,诸佬们一起讨论😁
希望能和诸佬们一起努力,今后我们顶峰相见🍻
再次感谢各位小伙伴儿们的支持🤞

在这里插入图片描述

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

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

相关文章

轻量应用服务器如何选择之阿里云和腾讯云PK哪个好?

阿里云和腾讯云都有轻量应用服务器&#xff0c;轻量服务器是一种轻量级开箱即用的云服务器&#xff0c;适合小型网站、博客或测试等单机应用&#xff0c;那么问题来了&#xff0c;轻量应用服务器到底是阿里云好还是腾讯云好&#xff1f;阿腾云来详细对比下阿里云轻量应用服务器…

find命令的结果顺序

文章目录 1. 目的2. 准备&#xff1a; 克隆 doxygen 源码3. ubuntu22.04 结果4. ubuntu16.04 结果5. git bash 结果6. 三路比较7. 保持一样的结果&#xff1a; 用自然排序8. References 1. 目的 在研读 doxygen 源码时&#xff0c; 在不同电脑、不同操作系统上使用了 find 命令…

vue2中provide/inject的使用

一般来说&#xff0c;组件之间有以下几种关系&#xff1a; A-B、A-C、B-D、B-E、C-F都是父子关系&#xff0c;B-C、D-E-F是兄弟关系&#xff0c;A-D、A-E、A-F是祖先与孙子关系。 vue2中provide/inject这对选项需要一起使用&#xff0c;以允许一个祖先组件向其所有子孙后代注…

私有化部署即时通讯工具能为企业提升工作沟通效率吗?

在疫情的影响下&#xff0c;越来越多的企业开始采用私有化部署的方式部署即时通讯工具&#xff0c;以提升工作沟通效率。私有化部署的即时通讯工具&#xff0c;能够为企业提供完善的人员管理、安全保障、灵活便捷等优势&#xff0c;帮助企业更好地管理人员、团队协作以及工作沟…

CAMx-Python融合技术与大气污染来源解析方法

详情点击链接&#xff1a;CAMx-Python融合技术应用与大气污染来源解析方法 CAMx模型是一个基于大气化学&#xff0c;针对臭氧、颗粒物和雾霾天气过程的大气污染物计算模型。 1、CAMx模式的区域空气质量模拟配置技术&#xff1b; 2、SMOKE模型的CAMx模式大气排放清单输入准备&…

Kubernetes 二进制部署高可用集群 失败 看报错

概述 openssl证书有问题导致失败&#xff0c;未能解决openssl如何创建私钥&#xff0c;可参考ansible 在私有局域网内完成Kubernetes二进制高可用集群的部署 ETCD Openssl > ca 证书 Haproxy Keepalived Kubernetes 主机规划 序号名字功能VMNET 1备注 1备注 2备注 3 备注…

拉线位移传感器可以用来做的工作

拉线位移传感器可以用来做的工作 拉线位移传感器&#xff0c;是做什么的呢&#xff1f;是测位移的一种传感器&#xff0c;它的使用方式是用拉线测量&#xff0c;所以我们又叫它拉线位移传感器或者拉绳位移传感器。 拉绳位移传感器的应用非常广泛&#xff0c;一般只要精度要求不…

Docker issue failed to solve: rpc error: code = unknown desc

完整错误&#xff1a;failed to solve: rpc error: code Unknown desc failed to solve with frontend dockerfile.v0: failed to create LLB definition: unexpected status code [manifests 8.0-alpine-v3.14-swoole]: 403 Forbidden 解决方案一 重启DockerDesktop或重新启…

JavaScript全解析-继承

继承 ●要知道什么是继承 ●要知道继承的方式有哪些 ●每种的继承方式是如何实现的 什么是继承 ●继承关系出现在构造函数和构造函数之间 ●当构造函数A 的实例使用了 构造函数B 的属性和方法 ●我们就说 构造函数A 继承自 构造函数B ○管 构造函数A 叫做子类 ○管 构造函数B 叫…

MATLAB算法实战应用案例精讲-【数模应用】生存曲线(补充篇)

目录 前言 几个相关概念 生存概率与死亡概率 生存率 生存曲线 事件、生存时间 中位生存时间 生存率的比较 生存数据 风险集 如何读懂KM曲线 应用案例 新药对患者总生存时间的影响-KM曲线 软件操作及结果解读 应用GraphPad Prism制作生存曲线 SPSS绘制生存曲线图 …

gRPC-go参数功能介绍1->WithBlock参数介绍

在gRPC-go框架中&#xff0c;当客户端使用 Dial() 方法连接到gRPC服务器时&#xff0c;可以使用 WithBlock() 选项来阻塞客户端&#xff0c;直到与服务器建立连接成功。 通常情况下&#xff0c;当客户端调用 Dial() 方法时&#xff0c;该方法会立即返回&#xff0c;并在后台异…

使用MinIO文件存储系统【完成图片上传保存】业务逻辑

目录 1&#xff1a;业务流程 2&#xff1a;接口实现 controller层 service层 1&#xff1a;业务流程 步骤一&#xff1a;前端进入上传图片的界面 步骤二&#xff1a;上传图片&#xff0c;请求到后端的媒资管理服务模块 步骤三&#xff1a;媒资管理服务将图片文件存储到m…

STM32---编写呼吸灯串口发送ON开LED,发送OFF关LED或者0X550X440XFF表示开灯,0X550X660XFF表示关灯

编写呼吸灯串口发送ON开LED&#xff0c;发送OFF关LED或者&#xff08;0X550X440XFF表示开灯&#xff0c;0X550X660XFF表示关灯&#xff09;注&#xff1a;包头 0X55 包尾&#xff1a;0XFF 数据&#xff1a;0X44表示开灯 0X66表示关灯 用到了重定向 //printf的重定向 int fpu…

使用SSD会提高游戏性能或FPS吗?

​“我在考虑要不要给电脑换个SSD&#xff0c;现在旧电脑上的HDD快满了&#xff0c;正好我也喜欢打游戏&#xff0c;听说换SSD可以提高电脑性能以及游戏FPS&#xff0c;这是真的吗&#xff1f;如果是真的&#xff0c;那我怎么样可以把旧硬盘上的数据迁移到新硬盘呢&#xff1f;…

【Web3.0大势所趋】下一代互联网的未来

前言 Web3.0 是一个越来越受到关注的话题&#xff0c;它被认为将会带来天翻地覆的变化。本文我们一起来谈谈 Web3.0 的概念、特点和优势&#xff0c;并探讨它为什么如此重要和具有革命性的。 文章目录 前言Web3.0是什么区块链技术智能合约总结 Web3.0是什么 Web3.0: 是下一代互…

达梦数据库的安装DM8

文章目录 一、达梦数据库的安装1、环境需求2、达梦的官方安装文档3、达梦数据库的安装包下载3.1、DM8的下载3.2、DM7的下载 4、开始操作4.1、使用xftp传dm8到虚拟机里4.2、下载依赖包4.3、拷贝dm8的iso文件到指定目录&#xff0c;并挂载4.4、创建DM安装用户和安装用户组并初始化…

提前熟知领英被限制被封因素,避免踩坑

领英在什么情况下容易被封 01.同一个人注册使用多个领英帐号。 02.多个人共同使用同一个领英帐号。 03.虚假资料注册领英账号&#xff0c;常见于注册领英账号的时候初始姓名随便填写或胡编乱造&#xff0c;注册时使用了网络虚拟的手机号码或邮箱等。 04.领英帐号的个人档案资料…

unity多线程Burst+Job System

Unity自己本身UnityEngine所使用的API是不能被多线程调用的&#xff0c;它没有向用户开放线程接口&#xff0c;所以Unity是不能使用多线程的&#xff0c;但是C#中可以使用多线程&#xff0c;Unity使用C#进行脚本编辑&#xff0c;故而Unity也可以通过C#来调用多线程。 JobSyste…

如何在新能源行业运用IPD?

新能源又称非常规能源&#xff0c;一般指在新技术基础上&#xff0c;可系统地开发利用的可再生能源。是指传统能源之外的各种能源形式&#xff0c;也是指刚开始开发利用或正在积极研究、有待推广的能源&#xff0c;如太阳能、地热能、风能、海洋能、生物质能和核聚变能等。目前…

HTTP与HTTPS的区别

1 HTTP与HTTPS有哪些区别 HTTP 是超文本传输协议&#xff0c;信息是明文传输&#xff0c;存在安全风险的问题。HTTPS 则解决 HTTP 不安全的缺陷&#xff0c;在 TCP 和 HTTP 网络层之间加入了 SSL/TLS 安全协议&#xff0c;使得报文能够加密传输。HTTP 连接建立相对简单&#x…