自定义资源点

第一步：在应用主类中增加注解支持的配置：

  1. @SpringBootApplication
  2. public class SentinelAnnotationApplication {
  4.     public static void main(String[] args) {
  5.         SpringApplication.run(SentinelAnnotationApplication.class, args);
  6.     }
  8.     @Bean
  9.     public SentinelResourceAspect sentinelResourceAspect() {
  10.         return new SentinelResourceAspect();
  11.     }
  12. }

第二步：在需要通过Sentinel来控制流量的地方使用@SentinelResource注解，比如下面以控制Service逻辑层的某个方法为例：


    @SentinelResource(value = "doSomeThing", blockHandler = "exceptionHandler")
    public String doSomeThing(String str) {
        log.info(str);
        return str;
    }

    // 限流与阻塞处理
    public String exceptionHandler(String str, BlockException ex) {
        log.error("exceptionHandler:" + str);
        ex.printStackTrace();
        return str;
    }

如何实现限流与熔断降级

在定义了资源点之后，我们就可以通过Dashboard来设置限流和降级策略来对资源点进行保护了。同时，也可以通过@SentinelResource来指定出现限流和降级时候的异常处理策略。下面，就来一起分别看看限流和降级都是如何实现的。

实现限流控制

第一步：在Web层调用这个被保护的方法：

@RestController
public class TestController {

    @Autowired
    private TestService testService;

    @GetMapping("/server")
    public String hello() {
        return testService.doSomeThing("hello" + new Date());
    }

第二步：启动测试应用，启动Sentinel-Dashboard。发一个请求到/hello接口上，使得Sentinel-Dashboard上可以看到如下图所示的几个控制点：
image.png
可以通过界面为这个资源点设置限流规则，比如将其QPS设置为2

  • 通过@SentinelResource注解的blockHandler属性制定具体的处理函数
  • 实现处理函数，该函数的传参必须与资源点的传参一样，并且最后加上BlockException异常参数；同时，返回类型也必须一样。

完成上面的改动之后，再尝试访问接口（注意限流规则需要配置好），此时前端就不会返回异常信息了，后端会打印exceptionHandler中定义的日志输出。而在实际应用的时候，只要根据业务需要对限流请求做缓存或者前端提示等都可以基于此方法来实现。
image.png

熔断的降级处理

在Sentinel中定义熔断的降级处理方法非常简单，与Hystrix非常相似。只需要使用@SentinelResource注解的fallback属性来指定具体的方法名即可。这里也需要注意传参与返回必须一致。比如：

 // 降级处理
    public String fallBackHandler(String str) {
        log.error("fallBackHandler:" + str);
        return str + "熔断降级";
    }
    @SentinelResource(value = "doSomeThingError", fallback = "fallBackHandler")
    public String doSomeThingError(String str) {
        log.info(str);
        int r = (int) (Math.random() * 10);
        if (r > 3) {
            throw new RuntimeException("throw exception");
        }
        return str;
    }

image.pngimage.png

更多注解属性说明

关于@SentinelResource注解最主要的两个用法：限流控制和熔断降级的具体使用案例介绍完了。另外，该注解还有一些其他更精细化的配置，比如忽略某些异常的配置、默认降级函数等等，具体可见如下说明：

  • value：资源名称，必需项（不能为空）
  • entryType：entry 类型，可选项（默认为 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 逻辑中，而是会原样抛出。

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

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