服务流控(Sentinel)

引入依赖

<!-- 必须的 -->
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId>
</dependency><!-- sentinel 核心库 -->
<dependency><groupId>com.alibaba.csp</groupId><artifactId>sentinel-core</artifactId><version>1.8.0</version>
</dependency>

实现流控

编码实现

  • 限流实现
    private static final Logger logger = LoggerFactory.getLogger(HelloController.class);private static final String RESOURCE_NAME = "hello";@RequestMapping("/hello")public String hello() {Entry entry = null;// 务必保证finally会被执行try {// 资源名可使用任意有业务语义的字符串entry = SphU.entry(RESOURCE_NAME);// 被保护的业务逻辑// do something...String str = "hello world";logger.info("++++++++++++" + str);return str;} catch (BlockException e1) {// 资源访问阻止,被限流或被降级// 进行相应的处理操作logger.info("block!!!!!");return "被流控了!!!!";} catch (Exception e) {// 若需要配置降级规则。则需要通过这种方式记录业务异常Tracer.traceEntry(e, entry);} finally {if (entry != null) {entry.exit();}}return null;}
  • 注册流控规则
    @PostConstructprivate static void initFlowControlRules() { // 通常设置在服务提供方// 流控规则列表List<FlowRule> flowRuleList = new ArrayList<>();// 流控规则FlowRule helloFlowRule = new FlowRule();// 设置流控的资源名称helloFlowRule.setResource(RESOURCE_NAME);// 设置流控规则 QPShelloFlowRule.setGrade(RuleConstant.FLOW_GRADE_QPS);// 设置流控的阈值// Set limit QPS to 20helloFlowRule.setCount(1);flowRuleList.add(helloFlowRule);FlowRuleManager.loadRules(flowRuleList);}
  • 效果呈现

注解实现

  • 引入依赖
<!--  @SentinelResource  -->
<dependency><groupId>com.alibaba.csp</groupId><artifactId>sentinel-annotation-aspectj</artifactId><version>1.8.0</version>
</dependency>
  • 增加切面
    • 启动类
    @Beanpublic SentinelResourceAspect sentinelResourceAspect() {return new SentinelResourceAspect();}
    • 配置类
/*** 1. 使用注解@SentinelResource* 2. 使用了 Spring AOP* 3. 通过配置的方式将 SentinelResourceAspect 注册为一个 Spring Bean*/
@Configuration
public class AopConfiguration {@Beanpublic SentinelResourceAspect sentinelResourceAspect() {return new SentinelResourceAspect();}
}
  • 注解使用
    /*** 使用注解 使用Sentinel** @SentinelResource: 依赖:* <dependency>*      <groupId>com.alibaba.csp</groupId>*      <artifactId>sentinel-annotation-aspectj</artifactId>*      <version>1.8.0</version>* </dependency>* 1. value: 资源名称* 2. blockHandler 流控降低处理器 (默认和接口实现方法在同一个类中)* 3. blockHandlerClass 指定处理器类* 4. fallback  业务异常处理* 5. fallbackClass 指定异常处理器类* 6. blockHandler 和 fallback 同时配置, blockHandler 优先级高* 7. exceptionsToIgnore 排除不需要处理的异常 -> exceptionsToIgnore = {}*/@RequestMapping("/user")@SentinelResource(value = USER_RESOURCE_NAME, blockHandler = "blockHandlerForGetUser",
//            fallback = "fallBackForGetUser",exceptionsToIgnore = {})public User getUser(String id) {// int i = 1 / 0;return new User(id, "Quentin");}/*** 注意:* 1. 必须是public, 若放在其他类中 blockHandlerClass 则必须为 public static* 2. 返回值 需和原接口方法的返回值保持一致 且 参数包含原方法的参数* 3. 额外增加  异常参数 BlockException** @param id* @param be* @return*/public User blockHandlerForGetUser(String id, BlockException be) {logger.info("++++++++注解流控");return new User(id, "被流控了!!!");}
  • 增加流控规则
    @PostConstructprivate static void initFlowControlRules() { // 通常设置在服务提供方// 流控规则列表List<FlowRule> flowRuleList = new ArrayList<>();// 流控规则FlowRule userFlowRule = new FlowRule();// 设置流控的资源名称userFlowRule.setResource(USER_RESOURCE_NAME);// 设置流控规则 QPSuserFlowRule.setGrade(RuleConstant.FLOW_GRADE_QPS);// 设置流控的阈值// Set limit QPS to 20userFlowRule.setCount(1);flowRuleList.add(userFlowRule);FlowRuleManager.loadRules(flowRuleList);}
  • 效果

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

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

相关文章

权限系统设计

权限系统设计 RBAC 基于角色的访问控制 ABAC 基于属性的访问控制 普通的系统无非 CRUD&#xff0c;那系统如何控制一个用户该看到哪些数据、能操作哪些功能&#xff1f;日常开发中最常用到 RBAC 和 OAuth2 这两种访问控制和授权方案 RBAC 基于角色的访问控制 所有的访问控制模…

GoZero 微服务个人探究之路(十一)编写sql语句所用到的sqlx包

前言 使用go-zero的脚手架工具goctl生成数据库代码时候&#xff0c;我们发现goctl引入了sqlx这个包来进行sql操作&#xff0c;本文旨在对sqlx包进行整理&#xff0c;来方便我们使用go-zero&#xff0c;sqlx进行sql操作 Why sqlx 为什么要额外引入sqlx包&#xff0c;增加复杂…

力扣精选算法100道——【模板】前缀和 (二维)

目录 &#x1f388;题目解析 &#x1f388;算法原理 &#x1f388;实现代码 二维前缀和【模板】 &#x1f388;题目解析 上一题我们讲述了一维的前缀和求法。 第一行三个参数&#xff0c;n是行数3&#xff0c;m是列数4&#xff0c;q3代表查询次数 接下来就是n行m列的矩阵…

基于python混沌系统敏感文本信息加密算法的研究与实现,附源码

博主介绍&#xff1a;✌程序员徐师兄、7年大厂程序员经历。全网粉丝30W、csdn博客专家、掘金/华为云/阿里云/InfoQ等平台优质作者、专注于Java技术领域和毕业项目实战✌ &#x1f345;文末获取源码联系&#x1f345; &#x1f447;&#x1f3fb; 精彩专栏推荐订阅&#x1f447;…

【Python】洛谷P7614 [COCI2011-2012#2] NAJBOLJIH 5

P7614 [COCI2011-2012#2] NAJBOLJIH 5 题目描述 给定 8 8 8 个数字 X 1 , X 2 , . . . , X 8 X_1,X_2,...,X_8 X1​,X2​,...,X8​&#xff0c;从中选出 5 5 5 个数字&#xff0c;使得这 5 5 5 个数字的总和最大。输出这 5 5 5 个数字的和以及它们的编号。 X i X_i Xi​…

微服务OAuth 2.1认证授权Demo方案(Spring Security 6)

文章目录 一、介绍二、auth微服务代码1. SecurityConfig2. UserDetailsService3. 总结 三、gateway微服务代码1. 统一处理CORS问题 四、content微服务代码1. controller2. SecurityConfig3. 解析JWT Utils4. 总结 五、一些坑 书接上文 微服务OAuth 2.1认证授权可行性方案(Sprin…

【51单片机】串口(江科大)

8.1串口通信 1.串口介绍 2.硬件电路 3.电平标准 电平标准是数据1和数据0的表达方式,是传输线缆中人为规定的电压与数据的对应关系,串口常用的电平标准有如下三种: 电平标准是数据1和数据O的表达方式,是传输线缆中人为规定的电 压与数据的对应关系,串口常用的电平标准有如下…

【QT+QGIS跨平台编译】之三十六:【RasterLite2+Qt跨平台编译】(一套代码、一套框架,跨平台编译)

文章目录 一、RasterLite2介绍二、文件下载三、文件分析四、pro文件五、编译实践一、RasterLite2介绍 RasterLite2是一个开源的轻量级栅格数据库,可以用于存储和管理各种类型的栅格数据,包括卫星遥感图像、数字高程模型等。 与传统的GIS数据存储方式不同,RasterLite2采用基…

React18原理: 时间分片技术选择

渲染1w个节点的不同方式 1 &#xff09;案例1&#xff1a;一次渲染1w个节点 <div idroot><div><script type"text/javascript">function randomHexColor() {return "#" ("0000" (Math.random() * 0x1000000 << 0).toS…

「计算机网络」物理层

物理层的基本概念 物理层的作用&#xff1a;尽可能屏蔽掉不同传输媒体和通信手段的差异物理层规程&#xff1a;用于物理层的协议主要任务&#xff1a;确定与传输媒体的接口有关的一些特性 机械特性电器特性功能特性过程特性 数据通信的基础知识 数据通信系统的模型 划分为…

【深蓝学院】移动机器人运动规划--第4章 动力学约束下的运动规划--作业

文章目录 1. T11.1 题目1.2 求解1.3 Pontryagin Minimum Principle 的拓展 2. T22.1 题目2.2 求解 3. Reference 1. T1 1.1 题目 1.2 求解 1.3 Pontryagin Minimum Principle 的拓展 2. T2 2.1 题目 2.2 求解 Listing1&#xff1a; demo_node.cpp/trajectoryLibrary() for(i…

蓝桥杯-X图形

问题描述 给定一个字母矩阵。一个 X 图形由中心点和由中心点向四个 45度斜线方向引出的直线段组成&#xff0c;四条线段的长度相同&#xff0c;而且四条线段上的字母和中心点的字母相同。 一个 X 图形可以使用三个整数 r,c,L 来描述&#xff0c;其中 r,c 表示中心点位于第 r 行…

LOL全英文界面

文章目录 前言.bat 前言 对于需要学英文的同学们来说, 玩起lol来 ,有全部界面文字都是英文. 那真是很酷对于那些改配置还不起作用的玩家来说, 我只告诉你们, 只需要写一个.bat文件, 当然我的lol是日服版. 抗日起来是非常 cool .bat 只有两行 pushd "K:\Program Files (…

Spring Security 弃用 WebSecurityConfigurerAdapter 重写登录接口 前后端分离 返回json数据格式

springboot 版本高于 2.7 之后 弃用了 WebSecurityConfigurerAdapter 推荐使用组件化配置安全组件。 原版本的2.7版本的登录接口 功能&#xff1a; 通过/api/doLogin 进行登录 package cn.devops.config;import cn.devops.model.User; import cn.devops.response.RespBe…

nginx命名location跳转的模块上下文继承

目录 1. 缘起2. 解决方案2.1 保留指定模块的上下文信息2.2 获取指定模块的上下文信息2.3 设置指定模块的上下文信息2.4 设置模块上下文是否需要继承标记2.5 对openrety lua代码的支持 1. 缘起 nginx提供了非常棒的功能&#xff0c;命名location&#xff0c;如文章nginx的locati…

理解JAVA EE设计模式

理解JAVA EE设计模式 在Web应用程序的设计和开发阶段,开发人员在开发类似的项目时可能会遇到相似的问题。每名开发人员可能会遇到的问题找出不同或相似的解决方案。但是,这导致一些时间和精力浪费在为相似的问题寻找解决方案上。因此,要啊节省时间和精力,需要记录常见问题…

Vulnhub靶场 DC-9

目录 一、环境搭建 二、信息收集 1、主机发现 2、指纹识别 三、漏洞复现 1、dirsearch目录探测 2、sqlmap注入测试 3、文件包含漏洞 4、Knockd敲门服务 5、ssh爆破 ​​​​​​​6、提权 四、提取flag 一、环境搭建 Vulnhub靶机下载&#xff1a; 官网地址&#xff1a;https://…

红队打靶练习:Alfa:1

下载连接点击此处即可&#xff01; 目录 信息收集 1、arp 2、nmap 3、gobuster WEB web信息收集 FTP登录 smaba服务 crunch密码生成 提权 系统信息收集 权限提升 信息收集 1、arp ┌──(root㉿ru)-[~/kali] └─# arp-scan -l Interface: eth0, type: EN10MB, …

消息中间件面试篇

消息中间件 RabbitMQ 消息不丢失 可能导致消息丢失的情况&#xff1a; 生产者发送消息丢失消息队列宕机消费者服务宕机&#xff0c;未接收到消息 生产者确认机制 该机制解决了生产者发送消息有可能丢失的问题。 RabbitMQ提供了publisher confirm机制来避免消息发送到MQ过程…

Unity下使用Sqlite

sqlite和access类似是文件形式的数据库&#xff0c;不需要安装任何服务&#xff0c;可以存储数据&#xff0c;使用起来还是挺方便的。 首先需要安装DLL 需要的DLL 我们找到下面两个文件放入Plugins目录 Mono.Data.Sqlite.dll System.Data.dll DLL文件位于Unity的安装目录下的…