• SentinelResource注解之blockHander和fallback


    前言

    我们访问接口进行限流或者降级后,直接返回500错误,或者提示 flow limit 之类的东西:

    这样显得很不优雅,透漏着不专业,那么进行限流或者降级后该如何进行优雅的返回呢?

    Sentinel 的 热点参数限流 着手,使用注解 @SentinelResource 的 blockHandler 和 fallback 来实现限流后优雅的返回。

    Sentinel的热点参数限流

    看到限流名字 热点参数 ,顾名思义,就能想到是针对请求资源的参数进行限流的。如果参数是 热点参数 ,并且符合设置的热点参数限流规则,那么 Sentinel 也对其进行限流。

    何为 热点参数 呢?联想一下娱乐圈的那些明星,粉丝越多的明星,他的热度就越高。同理,一个系统,访问的数据越频繁,这个数据的热度就越高。这种经常访问的数据就是 热点 。

    有些时候,需要采取一些措施对 热点数据 进行限制,比如:

    • 统计一段时间内最常访问的某个商品 ID (参数为商品 ID ),那么对该商品 ID 进行限制;
    • 请求资源参数用户 ID ,针对一段时间内频繁访问的用户 ID 进行限制;
    • 等等

    热点参数限流 会统计传入参数中的热点参数,并根据配置的限流阈值与模式,对包含热点参数的资源调用进行限流。

    热点参数限流可以看做是一种特殊的流量控制,仅对包含热点参数的资源调用生效。

    下面我们就开始创建包含热点参数的接口资源,并配置热点参数限流规则进行验证 Sentinel 的热点参数限流功能。

    还是用之前的微服务项目 sentinel-service ,新增一个接口资源如下:

    1. @RestController
    2. @Slf4j
    3. public class UserController {
    4. @GetMapping("/getProduct")
    5. @SentinelResource("getProduct")
    6. public String getProduct(@RequestParam(value = "userId", required = false) Long userId,
    7. @RequestParam(value = "productId", required = false) Long productId,
    8. @RequestParam(value = "categoryId", required = false) Integer categoryId) {
    9. log.info("getProduct param userId={},productId={},categoryId={}", userId, productId, categoryId);
    10. return "getProduct success";
    11. }
    12. }

    下面开始通过 Sentinel 控制台和 Nacos 配置中心两种方式进行规则配置。

    通过 Sentinel 控制台进行热点参数限流规则配置

    在控制台,在簇点链路上找到对应的资源,进行 热点 规则配置:

    打开 热点 操作:

    如图所示的就是对资源 getProduct 的第一个参数 userId 进行限流,如果配置单机阈值为1,窗口统计时长1秒,那么其含义就是: 在1秒内访问 getProduct 资源超过1次,如果传入了热点参数 userId,那么将对该资源进行限流,如果没有传入 userId,那么该资源不被限流。

    现在我们来访问接口验证一下,先传入不是热点的参数 categoryId :

    可以看到,无论QPS是多少,接口都正常返回,没有进行限流,现在我们加上热点参数 userId 试一下:

    1秒内快速刷新几下,QPS只要大于1了,接口访问就芭比Q了,说明 Sentinel 的热点参数限流生效了。

    Sentinel 热点参数限流规则持久化到 Nacos

    在 Nacos 设置 Data ID 及规则内容

    在 Sentinel 控制台配置的规则,当服务重启后,规则将消失,这并不是我们想要的结果,上一篇文章中,我们已经完成了 Sentinel 的规则持久化到 Nacos 中,本小节我们配置一下热点参数的限流规则。

    热点参数的限流规则主要有以下几个字段:

    • resource :资源名,必填项;
    • count :限流阈值,必填项;
    • grade :限流模式,只能是 QPS ;
    • paramIdx :热点参数的索引,必填项&
  • 相关阅读:
    最简单的java工具(JDK+IDEA)安装教程
    【论文复现】QuestEval:《QuestEval: Summarization Asks for Fact-based Evaluation》
    音视频专题--opengl (3)
    案例4-1.4 堆中的路径 + 基础实验4-2.5 关于堆的判断
    华为路由器多WAN口设置负载均衡
    指针---C语言
    消息队列-Kafka-基础架构
    PYTHON第二次
    【数据结构】队列
    入门JavaWeb之 Session 篇
  • 原文地址:https://blog.csdn.net/weixin_62421895/article/details/126436225