什么是Sentinel

Sentinel 是阿里巴巴出品的面向分布式服务架构的高可用防护组件，主要以流量为切入点，从流量控制、熔断降级、系统自适应保护等多个维度来帮助用户保障微服务的稳定性。

安装Sentinel

Sentinel与Nacos类似，需要安装一个控制台程序，安装方法很简单，可以参考官方文档提供的安装教程：传送门，也可以使用我的Docker安装教程

整合Sentinel

第一步：创建SpringBoot模块alibaba-sentinel-rate-limiting
第二步：编辑pom.xml

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0"
  3.     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4.     xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  5.     <parent>
  6.         <artifactId>spring-cloud-learn</artifactId>
  7.         <groupId>com.example</groupId>
  8.         <version>0.0.1-SNAPSHOT</version>
  9.     </parent>
  10.     <modelVersion>4.0.0</modelVersion>
  12.     <artifactId>alibaba-sentinel-rate-limiting</artifactId>
  14.     <properties>
  15.         <java.version>11</java.version>
  16.         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  17.         <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
  18.         <spring-boot.version>2.3.7.RELEASE</spring-boot.version>
  19.         <spring-cloud-alibaba.version>2.2.2.RELEASE</spring-cloud-alibaba.version>
  20.         <spring-cloud.version>Hoxton.SR9</spring-cloud.version>
  21.     </properties>
  23.     <dependencyManagement>
  24.         <dependencies>
  25.             <dependency>
  26.                 <groupId>org.springframework.cloud</groupId>
  27.                 <artifactId>spring-cloud-dependencies</artifactId>
  28.                 <version>${spring-cloud.version}</version>
  29.                 <type>pom</type>
  30.                 <scope>import</scope>
  31.             </dependency>
  32.             <dependency>
  33.                 <groupId>org.springframework.boot</groupId>
  34.                 <artifactId>spring-boot-dependencies</artifactId>
  35.                 <version>${spring-boot.version}</version>
  36.                 <type>pom</type>
  37.                 <scope>import</scope>
  38.             </dependency>
  39.             <dependency>
  40.                 <groupId>com.alibaba.cloud</groupId>
  41.                 <artifactId>spring-cloud-alibaba-dependencies</artifactId>
  42.                 <version>${spring-cloud-alibaba.version}</version>
  43.                 <type>pom</type>
  44.                 <scope>import</scope>
  45.             </dependency>
  46.         </dependencies>
  47.     </dependencyManagement>
  49.     <dependencies>
  50.         <dependency>
  51.             <groupId>org.springframework.boot</groupId>
  52.             <artifactId>spring-boot-starter-web</artifactId>
  53.         </dependency>
  54.         <dependency>
  55.             <groupId>com.alibaba.cloud</groupId>
  56.             <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
  57.         </dependency>
  58.         <dependency>
  59.             <groupId>org.projectlombok</groupId>
  60.             <artifactId>lombok</artifactId>
  61.             <optional>true</optional>
  62.         </dependency>
  63.         <dependency>
  64.             <groupId>org.springframework.boot</groupId>
  65.             <artifactId>spring-boot-starter-test</artifactId>
  66.             <scope>test</scope>
  67.             <exclusions>
  68.                 <exclusion>
  69.                     <groupId>org.junit.vintage</groupId>
  70.                     <artifactId>junit-vintage-engine</artifactId>
  71.                 </exclusion>
  72.             </exclusions>
  73.         </dependency>
  74.     </dependencies>
  76. </project>

第三步：编辑配置文件application.properties

  1. spring.application.name=alibaba-sentinel-rate-limiting
  2. server.port=8003
  4. spring.cloud.sentinel.transport.dashboard=localhost:9260

第四步：创建一个Controller

  1. package com.demo;
  3. import lombok.extern.slf4j.Slf4j;
  4. import org.springframework.boot.SpringApplication;
  5. import org.springframework.boot.autoconfigure.SpringBootApplication;
  6. import org.springframework.web.bind.annotation.GetMapping;
  7. import org.springframework.web.bind.annotation.RestController;
  9. /**
  10.  * @author wujiawei
  11.  * @see
  12.  * @since 2021/4/14 下午1:32
  13.  */
  14. @SpringBootApplication
  15. public class AlibabaSentinelRateLimitingApplication {
  17.     public static void main(String[] args) {
  18.         SpringApplication.run(AlibabaSentinelRateLimitingApplication.class, args);
  19.     }
  21.     @Slf4j
  22.     @RestController
  23.     static class EchoController {
  25.         @GetMapping("echo")
  26.         public String echo() {
  27.             return "echo";
  28.         }
  30.     }
  32. }

第五步：启动程序，通过curl反复请求/echo接口

  1. wujiawei@wujiaweideMacBook-Pro sentinel % curl http://localhost:8003/echo
  2. echo

此时在Sentinel控制台出现了我们当前的应用，并且在实时监控菜单中可以看到刚才的请求，如图：
image.png

配置限流规则

Sentinel整合完成后，我们尝试使用它的限流功能。
打开控制台，在alibaba-sentinel-rate-limiting服务下，点击簇点链路菜单，可以看到我们调用过的/echo接口。点击流控按钮，为该接口设置流量控制规则。
image.png
这里用一个最简单的设置，修改单机阈值为2，其他属性保持不动。这个设置的意思就是每秒最多允许2个请求，超过两个后就会被拒绝。
image.png
新增完成后，可以看到流控规则中出现了我们创建的规则。
image.png
这时回到curl，再次尝试反复请求/echo接口，注意这里要快快快！可以看到一秒内连续调用两次之后，第三次直接被拦截了。

  1. wujiawei@wujiaweideMacBook-Pro sentinel % curl http://localhost:8003/echo
  2. echo
  3. wujiawei@wujiaweideMacBook-Pro sentinel % curl http://localhost:8003/echo
  4. echo
  5. wujiawei@wujiaweideMacBook-Pro sentinel % curl http://localhost:8003/echo
  6. Blocked by Sentinel (flow limiting)

代码示例

  • Github:
  • Gitee: