@SentinelResource注解的使用

@SentinelResource注解的使用

1、按资源名称限流+后续处理

前置条件：

1. 启动Nacos
2. 启动Sentinel

1.1、修改cloudalibaba-sentinel-service8401

引入自己的API通用包

<dependency>
    <groupId>com.zcl.springcloudgroupId>
    <artifactId>cloud-api-commonsartifactId>
    <version>1.0-SNAPSHOTversion>
dependency>
1
2
3
4
5
6

1.2、新建控制器RateLimitController

按资源名称以及兜底方法 @SentinelResource(value = "byResource",blockHandler = "handleException")

package com.zcl.springcloud.controller;

import com.alibaba.csp.sentinel.annotation.SentinelResource;
import com.alibaba.csp.sentinel.slots.block.BlockException;
import com.zcl.springcloud.entities.CommonResult;
import com.zcl.springcloud.entities.Payment;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

/**
 * 描述：@SentinelResource注解使用
 *
 * @author zhong
 * @date 2022-10-02 11:23
 */
@RestController
public class RateLimitController
{
    /**
     * 按value = "byResource"资源名称限流测试
     * @return
     */
    @GetMapping("/byResource")
    @SentinelResource(value = "byResource",blockHandler = "handleException")
    public CommonResult byResource()
    {
        return new CommonResult(200,"按资源名称限流测试OK",new Payment(2020L,"serial001"));
    }

    /**
     * 兜底方法
     * @param exception
     * @return
     */
    public CommonResult handleException(BlockException exception)
    {
        return new CommonResult(444,exception.getClass().getCanonicalName()+"\t 服务不可用");
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39

1.3、配置限流规则

需要先访问http://localhost:8401/byResource

一秒钟访问正常显示，如果超过一秒钟就会执行自定义的兜底方法handleException

2、按照Url地址限流+后续处理

通过访问的URL来限流，会返回Sentinel自带默认的限流处理信息

2.1、测试控制器

@RestController
public class RateLimitController
{
    /**
     * 按URL来进行限流：/rateLimit/byUrl
     * @return
     */
    @GetMapping("/rateLimit/byUrl")
    @SentinelResource(value = "byUrl")
    public CommonResult byUrl()
    {
        return new CommonResult(200,"按url限流测试OK",new Payment(2020L,"serial002"));
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14

2.2、添加流控规则

流控规则既可以使用@GetMapping("/rateLimit/byUrl")访问的URL进行，也可以使用 @SentinelResource(value = "byUrl")指定的资源名称进行

2.3、测试

当请求的url资源1秒钟超过一个QPS的话就会使用系统的报错提示Blocked by Sentinel (flow limiting),因为没有通过blockHandler = "handleException"指定兜底方法

3、上面兜底方案面临的问题

1. 系统默认的，没有体现我们自己的业务要求。
2. 依照现有条件，我们自定义的处理方法又和业务代码耦合在一块，不直观。
3. 每个业务方法都添加一个兜底的，那代码膨胀加剧。
4. 全局统一的处理方法没有体现。

4、客户自定义限流处理逻辑

4.1、创建CustomerBlockHandler类用于自定义限流处理逻辑

package com.zcl.springcloud.myhandler;

import com.alibaba.csp.sentinel.slots.block.BlockException;
import com.zcl.springcloud.entities.CommonResult;

/**
 * 描述：自定义异常处理类，必须是静态的并且返回值与控制器的一样
 *
 * @author zhong
 * @date 2022-10-03 8:12
 */
public class CustomerBlockHandler {
    public static CommonResult handleException(BlockException exception) {
        return new CommonResult(2022,"使用了自定义的异常处理类------1");
    }

    public static CommonResult handleException2(BlockException exception) {
        return new CommonResult(2022,"使用了自定义的异常处理类------2");
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

4.2、创建控制器接口测试

blockHandlerClass = CustomerBlockHandler.class, blockHandler = "handleException2"指定自定义资源处理类是哪一个并且通过blockHandler指定类里面的具体某个方法

注意：注解方式埋点不支持private方法

@RestController
public class RateLimitController
{
    /**
     * 测试自定义异常处理类
     * @return
     */
    @GetMapping("/rateLimit/customerBlockHandler")
    @SentinelResource(value = "customerBlockHandler",
            blockHandlerClass = CustomerBlockHandler.class, blockHandler = "handleException2")
    public CommonResult customerBlockHandler()
    {
        return new CommonResult(200,"按客户自定义限流处理逻辑");
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

4.3、流控规则配置

4.3、请求测试

1. 正常请求1秒一个QPS：http://localhost:8401/rateLimit/customerBlockHandler

   {
     "code": 200,
     "message": "按客户自定义限流处理逻辑",
     "data": null
   }
   1
   2
   3
   4
   5

2. 异常请求1秒两个QPS：http://localhost:8401/rateLimit/customerBlockHandler

   {
     "code": 2022,
     "message": "使用了自定义的异常处理类------2",
     "data": null
   }
   1
   2
   3
   4
   5

5、更多注解属性说明

注解官网地址：https://sentinelguard.io/zh-cn/docs/annotation-support.html

@SentinelResource 注解

注意：注解方式埋点不支持 private 方法。

@SentinelResource 用于定义资源，并提供可选的异常处理和 fallback 配置项。 @SentinelResource 注解包含以下属性：

• value：资源名称，必需项（不能为空）

• entryType：entry 类型，可选项（默认为 EntryType.OUT）

• blockHandler / blockHandlerClass: blockHandler 对应处理 BlockException 的函数名称，可选项。blockHandler 函数访问范围需要是 public，返回类型需要与原方法相匹配，参数类型需要和原方法相匹配并且最后加一个额外的参数，类型为 BlockException。blockHandler 函数默认需要和原方法在同一个类中。若希望使用其他类的函数，则可以指定 blockHandlerClass 为对应的类的 Class 对象，注意对应的函数必需为 static 函数，否则无法解析。

• fallback
  1

  ：fallback 函数名称，可选项，用于在抛出异常的时候提供 fallback 处理逻辑。fallback 函数可以针对所有类型的异常（除了

  exceptionsToIgnore
  1

  里面排除掉的异常类型）进行处理。fallback 函数签名和位置要求：

  • 返回值类型必须与原函数返回值类型一致；
  • 方法参数列表需要和原函数一致，或者可以额外多一个 Throwable 类型的参数用于接收对应的异常。
  • fallback 函数默认需要和原方法在同一个类中。若希望使用其他类的函数，则可以指定 fallbackClass 为对应的类的 Class 对象，注意对应的函数必需为 static 函数，否则无法解析。

• defaultFallback
  1

  （since 1.6.0）：默认的 fallback 函数名称，可选项，通常用于通用的 fallback 逻辑（即可以用于很多服务或方法）。默认 fallback 函数可以针对所以类型的异常（除了

  exceptionsToIgnore
  1

  里面排除掉的异常类型）进行处理。若同时配置了 fallback 和 defaultFallback，则只有 fallback 会生效。defaultFallback 函数签名要求：

  • 返回值类型必须与原函数返回值类型一致；
  • 方法参数列表需要为空，或者可以额外多一个 Throwable 类型的参数用于接收对应的异常。
  • defaultFallback 函数默认需要和原方法在同一个类中。若希望使用其他类的函数，则可以指定 fallbackClass 为对应的类的 Class 对象，注意对应的函数必需为 static 函数，否则无法解析。

• exceptionsToIgnore（since 1.6.0）：用于指定哪些异常被排除掉，不会计入异常统计中，也不会进入 fallback 逻辑中，而是会原样抛出。

注：1.6.0 之前的版本 fallback 函数只针对降级异常（DegradeException）进行处理，不能针对业务异常进行处理。

特别地，若 blockHandler 和 fallback 都进行了配置，则被限流降级而抛出 BlockException 时只会进入 blockHandler 处理逻辑。若未配置 blockHandler、fallback 和 defaultFallback，则被限流降级时会将 BlockException 直接抛出。

5.1、代码自定义流控规则API

1. SphU定义资源
2. Tracer定义统计
3. ContextUtil定义了上下文