使用Sentinel实现流控和服务降级的代码示例

使用Sentinel实现流控和服务降级需要遵循以下几个步骤：

1. 引入Sentinel依赖

在Maven项目中，可以在pom.xml中引入以下Sentinel依赖：

<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
</dependency>

1. 配置Sentinel

在Spring Boot项目中，可以在application.yml或者application.properties中配置Sentinel的基本属性，例如：

spring:
  cloud:
    sentinel:
      transport:
        dashboard: localhost:8080

其中，dashboard属性表示Sentinel控制台的地址。

1. 设置资源

在Sentinel中，资源是需要被限流或者降级的代码块。可以使用Sentinel注解来标识资源，例如：

@SentinelResource(value = "helloWorld", blockHandler = "handleBlock")
public String helloWorld() {
    return "Hello, World!";
}

其中，value属性表示资源名称，blockHandler属性表示阻塞处理函数的名称。

1. 设置规则

在Sentinel中，可以设置不同的限流和降级规则来保护资源。可以通过代码动态设置规则，也可以通过Sentinel控制台设置规则。例如，可以通过以下代码设置QPS限流规则：

FlowRule rule = new FlowRule();
rule.setResource("helloWorld");
rule.setGrade(RuleConstant.FLOW_GRADE_QPS);
rule.setCount(10);
FlowRuleManager.loadRules(Collections.singletonList(rule));

其中，resource属性表示资源名称，grade属性表示限流阈值类型，count属性表示限流阈值。

另外，还可以通过以下代码设置异常比例降级规则：

DegradeRule rule = new DegradeRule();
rule.setResource("helloWorld");
rule.setGrade(RuleConstant.DEGRADE_GRADE_EXCEPTION_RATIO);
rule.setCount(0.5);
rule.setTimeWindow(10);
DegradeRuleManager.loadRules(Collections.singletonList(rule));

其中，resource属性表示资源名称，grade属性表示降级阈值类型，count属性表示阈值，timeWindow属性表示统计时间窗口。

1. 编写阻塞处理函数

在资源被限流或者降级时，需要编写阻塞处理函数来处理这种情况。例如：

public String handleBlock(BlockException ex) {
    return "Blocked!";
}

这个函数的作用是在资源被限流或者降级时返回Blocked字符串。

1. 启动Sentinel控制台

Sentinel控制台用于查看和管理Sentinel的规则和统计信息。可以通过以下命令启动Sentinel控制台：

java -jar sentinel-dashboard.jar

其中，sentinel-dashboard.jar表示Sentinel控制台的jar包。

1. 启动项目

最后，可以启动Spring Boot项目，并在控制台或者Sentinel控制台中查看统计信息和规则。

示例1：限流示例

以下代码是一个简单的限流示例：

@RestController
public class DemoController {
    @GetMapping("/hello")
    @SentinelResource(value = "helloWorld", blockHandler = "handleBlock")
    public String helloWorld() {
        return "Hello, World!";
    }
}

其中，@GetMapping注解表示处理GET请求，SentinelResource注解表示资源名称和阻塞处理函数。

以下代码是一个动态设置限流规则的示例：

@GetMapping("/setRule")
public String setRule() {
    FlowRule rule = new FlowRule();
    rule.setResource("helloWorld");
    rule.setGrade(RuleConstant.FLOW_GRADE_QPS);
    rule.setCount(10);
    FlowRuleManager.loadRules(Collections.singletonList(rule));
    return "OK";
}

其中，FlowRuleManager.loadRules()函数用于动态设置流控规则。

示例2：降级示例

以下代码是一个简单的降级示例：

@RestController
public class DemoController {
    @GetMapping("/hello")
    @SentinelResource(value = "helloWorld", fallback = "fallback")
    public String helloWorld() throws Exception {
        throw new Exception("Oops");
    }

    public String fallback() {
        return "Fallback!";
    }
}

其中，@SentinelResource注解的fallback属性表示降级处理函数。

以下代码是一个动态设置异常比例降级规则的示例：

@GetMapping("/setRule")
public String setRule() {
    DegradeRule rule = new DegradeRule();
    rule.setResource("helloWorld");
    rule.setGrade(RuleConstant.DEGRADE_GRADE_EXCEPTION_RATIO);
    rule.setCount(0.5);
    rule.setTimeWindow(10);
    DegradeRuleManager.loadRules(Collections.singletonList(rule));
    return "OK";
}

其中，DegradeRuleManager.loadRules()函数用于动态设置降级规则。