本文详细介绍了如何在项目中实战应用Sentinel监控流量，涵盖Sentinel的安装、配置及流量控制规则的设置。通过具体步骤和示例代码，展示了如何在Spring Boot项目中集成并使用Sentinel进行流量监控和保护，确保系统的稳定性和可靠性。文章涵盖了从环境搭建到规则配置的全过程。

Sentinel是什么

Sentinel 是阿里开源的一款针对微服务架构的流量控制组件。它的核心功能包括流量控制、授权控制、系统保护等功能，可以对微服务的流量进行实时监控和控制，保证系统的稳定性和可靠性。Sentinel 是用 Java 语言开发的，可以方便地集成到现有的 Java 项目中。

Sentinel的主要功能

1. 流量控制：通过规则控制流量，可以设置请求的并发数、QPS（每秒查询率）等，防止系统因大量请求而崩溃。
2. 授权控制：提供灵活的授权规则，可以限制只有特定用户或角色才能访问某些资源。
3. 系统保护：当系统 CPU 使用率、系统负载等达到阈值时，自动减少流量，防止系统过载。
4. 降级保护：在某些服务不可用时，可以设置熔断降级策略，确保其他服务不受影响。
5. 监控和告警：提供实时的监控和告警功能，可以实时获取系统的运行状态，及时处理异常。

Sentinel的安装步骤

1. 添加 Maven 依赖
   在项目的 pom.xml 文件中添加 Sentinel 的依赖。

   <dependencies>
      <dependency>
          <groupId>com.alibaba.csp</groupId>
          <artifactId>sentinel-core</artifactId>
          <version>1.8.3</version>
      </dependency>
      <dependency>
          <groupId>com.alibaba.csp</groupId>
          <artifactId>sentinel-transport-netty</artifactId>
          <version>1.8.3</version>
      </dependency>
      <dependency>
          <groupId>com.alibaba.csp</groupId>
          <artifactId>sentinel-datasource-nacos</artifactId>
          <version>1.8.3</version>
      </dependency>
   </dependencies>

2. 创建一个 Sentinel 的配置文件 sentinel.properties。

   # 流控规则存储配置
   sentinel.flow.saveMode=1
   # 系统规则存储配置
   sentinel.system.saveMode=1
   # 授权规则存储配置
   sentinel.authority.saveMode=1
   # 日志级别
   sentinel.log.level=INFO

3. 初始化 Sentinel。
   在项目的入口类中初始化 Sentinel。

   import com.alibaba.csp.sentinel.init.SentinelInitializer;
   
   public class MyApplication {
      public static void main(String[] args) {
          SentinelInitializer.init();
          SpringApplication.run(MyApplication.class, args);
      }
   }

准备开发环境

1. 安装 JDK 8 或更高版本。
2. 安装并配置 Maven。
3. 安装并配置 IDE，如 Intellij IDEA 或 Eclipse。

创建基础项目结构

创建一个 Spring Boot 项目。

1. 使用 Spring Initializr 创建一个新的 Spring Boot 项目，选择以下依赖：

   • Spring Web
   • Spring Actuator
   • Sentinel Core
   • Sentinel Transport Netty

2. 创建项目的目录结构：

   src/main/java
   ├── com/example
   │   ├── MyApplication.java
   │   └── controller
   │       └── MyController.java
   └── MyApplication.properties

3. 创建一个简单的 Controller。

   package com.example.controller;
   
   import org.springframework.web.bind.annotation.GetMapping;
   import org.springframework.web.bind.annotation.RestController;
   
   @RestController
   public class MyController {
      @GetMapping("/hello")
      public String hello() {
          return "Hello, Sentinel!";
      }
   }

4. 在 MyApplication 类中启动应用。

   import org.springframework.boot.SpringApplication;
   import org.springframework.boot.autoconfigure.SpringBootApplication;
   import com.alibaba.csp.sentinel.init.SentinelInitializer;
   
   @SpringBootApplication
   public class MyApplication {
      public static void main(String[] args) {
          SentinelInitializer.init();
          SpringApplication.run(MyApplication.class, args);
      }
   }

导入Sentinel依赖

在项目的 pom.xml 文件中添加 Sentinel 的依赖。

<dependencies>
    <dependency>
        <groupId>com.alibaba.csp</groupId>
        <artifactId>sentinel-core</artifactId>
        <version>1.8.3</version>
    </dependency>
    <dependency>
        <groupId>com.alibaba.csp</groupId>
        <artifactId>sentinel-transport-netty</artifactId>
        <version>1.8.3</version>
    </dependency>
    <dependency>
        <groupId>com.alibaba.csp</groupId>
        <artifactId>sentinel-datasource-nacos</artifactId>
        <version>1.8.3</version>
    </dependency>
</dependencies>

配置Sentinel

创建一个 Sentinel 配置文件 sentinel.properties。

# 流控规则存储配置
sentinel.flow.saveMode=1
# 系统规则存储配置
sentinel.system.saveMode=1
# 授权规则存储配置
sentinel.authority.saveMode=1
# 日志级别
sentinel.log.level=INFO

初始化Sentinel

在项目的入口类中初始化 Sentinel，并配置 Spring Boot。

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import com.alibaba.csp.sentinel.init.SentinelInitializer;

@SpringBootApplication
public class MyApplication {
    public static void main(String[] args) {
        SentinelInitializer.init();
        SpringApplication.run(MyApplication.class, args);
    }
}

设置流量控制规则

在 MyController 中设置流量控制规则。

import com.alibaba.csp.sentinel.annotation.SentinelResource;
import com.alibaba.csp.sentinel.slots.block.BlockException;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class MyController {
    @GetMapping("/hello")
    @SentinelResource(value = "hello", blockHandler = "helloBlockHandler")
    public String hello() {
        return "Hello, Sentinel!";
    }

    public String helloBlockHandler(BlockException ex) {
        return "Blocked by Sentinel!";
    }
}

实现流量监控

启动监控中心。

1. 下载并启动 Sentinel 监控中心，并设置监控中心端口和 IP。

   # 监控中心端口
   dashboard.port=8080
   # 监控中心地址
   dashboard.ip=localhost

2. 访问监控中心地址： http://localhost:8080。

查看监控数据

在监控中心页面中，可以查看实时的监控数据，包括 QPS、请求成功率、并发数等。

流量控制规则配置

流量控制规则可以限制接口的 QPS 和并发线程数。

1. 打开监控中心，进入“流量控制”页面。
2. 选择需要设置流量控制规则的 API。
3. 设置流控的阈值类型、阈值以及流控模式。
   • 阈值类型：QPS 或并发线程数。
   • 阈值：具体数值。
   • 流控模式：直接、关联。
4. 保存规则。

系统保护规则配置

系统保护规则可以基于系统的负载情况自动进行流量控制。

1. 在“系统规则”页面中设置系统保护规则。
2. 设置系统规则的阈值类型和阈值。
   • 阈值类型： CPU 使用率、系统负载。
   • 阈值：具体数值。
3. 保存规则。

授权规则配置

授权规则可以控制哪些用户或角色可以访问特定的资源。

1. 在“授权规则”页面中设置授权规则。
2. 设置资源名、操作类型以及授权类型。
   • 资源名：需要保护的具体资源。
   • 操作类型：GET、POST 等。
   • 授权类型：黑名单、白名单。
3. 保存规则。

配置日志记录

1. 在 sentinel.properties 文件中配置日志记录。

   # 日志文件路径
   sentinel.log.file.path=/logs/sentinel.log

2. 在项目中配置日志文件。

   # 日志配置
   logging.file.path=/logs/sentinel.log

设置报警规则

在监控中心中设置报警规则。

1. 打开监控中心，进入“报警规则”页面。
2. 设置报警的规则和阈值。
   • 规则：流量控制规则、系统保护规则、授权规则。
   • 阈值：具体数值。
3. 保存规则。

测试报警功能

1. 手动触发报警规则。
2. 观察报警是否正常发送到指定的目标，如邮件、短信等。

通过以上步骤，我们可以顺利地在项目中集成和使用 Sentinel，实现流量控制、监控以及告警等功能。这将有助于提高系统的稳定性和可靠性。