Sentinel: 分布式系统的流量防卫兵

prtyaa 2024-01-02 15:34:11  65306 赞同 0 反对 0

分类：资源

Sentinel 是什么？ Sentinel 具有以下特征: 丰富的应用场景：Sentinel 承接了阿里巴巴近 10 年的双十一大促流量的核心场景，例如秒杀（即突发流量控制在系统容量可以承受的范围）、消息削峰填谷、集群流量控制、实时熔断下游不可用应用等。完备的实时监控：Sentinel 同时提供实时的监控功能。您可以在控制台中看到接入应用的单台机器秒级数据，甚至 500 台以下规模的集群的汇总运行情况。广泛的开源生态：Sentinel 提供开箱即用的与其它开源框架/库的整合模块，例如与 Spring Cloud、Dubbo、gRPC 的整合。您只需要引入相应的依赖并进行简单的配置即可快速地接入 Sentinel。完善的 SPI 扩展点：Sentinel 提供简单易用、完善的 SPI 扩展接口。您可以通过实现扩展接口来快速地定制逻辑。例如定制规则管理、适配动态数据源等。

Sentinel 的主要特性：

Sentinel 的开源生态：

我们大概叙述后开始整合我们的分布式项目，我这里里为一个简单分布式项目，注册中心为Nacos，一个服务提供者(user-center)和一个服务消费者(content-center)

可以看到我的content-center调用user-center/users服务

我们现在只启动content-center不启动user服务，可想而知肯定报错，我们来看

没错500，找不到user-center服务，我们现在整合Sentinel,首先加入两个依赖

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-alibaba-sentinel</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-actuator</artifactId>
</dependency>

和actuator配合使用，可通过http://localhost:8010/actuator/sentinel端点进行查看

{
    "blockPage":null,
    "appName":"content-center",
    "consoleServer":"localhost:8333",
    "coldFactor":"3",
    "rules":{
        "systemRules":[

        ],
        "authorityRule":[

        ],
        "paramFlowRule":[

        ],
        "flowRules":[

        ],
        "degradeRules":[

        ]
    },
    "metricsFileCharset":"UTF-8",
    "filter":{
        "order":-2147483648,
        "urlPatterns":[
            "/*"
        ],
        "enabled":true
    },
    "totalMetricsFileCount":6,
    "datasource":{

    },
    "clientIp":"192.168.2.29",
    "clientPort":"8719",
    "logUsePid":false,
    "metricsFileSize":52428800,
    "logDir":"/Users/zhangguowei/logs/csp/",
    "heartbeatIntervalMs":10000
}

我们暂时先不要管这些是什么我们后面再详细阐述,从JSON的形式看不太方便，Sentinel为我们整合有UI界面

整合Sentinel可视化界面

下载 sentinel的jar包然后直接启动

https://github.com/alibaba/Sentinel/releases

启动的时候可以自定义端口号

账号密码默认为sentinel

在项目的yml中加入

spring:
  datasource:
    url: jdbc:mysql://localhost:3306/content_center
    hikari:
      username: ***
      password: ******
      driver-class-name: com.mysql.cj.jdbc.Driver
  cloud:
    sentinel:
      transport:
        # 指向sentinel UI界面
        dashboard: localhost:8333
    nacos:
      discovery:
        # 指定nacos server的地址
        server-addr: localhost:8848
  application:
    # 服务名称尽量用-，不要用_，不要用特殊字符
    name: content-center
server:
  port: 8010
management:
  endpoints:
    web:
      exposure:
        include: "*"

这个时候我们继续刚刚的500再执行几次会看到

相对于原来的Hystrix 的UI界面 Sentinel更人性化，

他支持QPS的查看，请求时间等等

那么我们首先来探讨流控规则，我们现在把user服务也启动，我们点击簇点链路

可以看到content曾经访问过的路径，我们点击流控按钮，就可以为这路径设置流控规则

我们可以看到资源名默认为我们请求的路径，其实也不一定是路径，他只是做唯一标识。

针对来源：Sentinel可以针对调用者进行限流控制，比如两个服务调用content服务，我可以把针对来源写为A然后设置QPS的阈值为200，B为300QPS，也就是我当前访问的API接口对不同的服务有不同的限流规则，那么就可以用针对来源来设置，我们暂时用default，标识不区分来源，后面详细说如何区分来源。

阈值类型有两个选项，分别是QPS和线程数，如果选择QPS然后设置阈值，就是当这个API达到这个QPS阈值时会进行限流，同理也可以使用线程数限流，当达到一定的线程数的时候进行限流，是否集群我们在后面会详细探讨。

流控模式，sentinel提供了三种流控模式,我们先来看直接我们设置直接并保存

可以看到访问一次直接再次访问就直接限流了。那关联是什么意思，也就是说当关联的资源达到阈值，就限流自己，我们来尝试，刚刚上面所说我们可以用http://localhost:8010/actuator/sentinel 来查看信息，我们用/shares/1关

它表示actuator/sentinel这个端点达到这个阈值那么就限流/shares/1这个路径，
我们来写段测试代码

理论上这样调用的话QPS肯定大于1，那么此时/shares/1会被限流

此时/shares/1会一直处于限流状态，他适用于什么场景：比如一个请求查询shares一个来修改shares处于高并发状态，查询过快的话会影响修改的性能，修改快的话会影响查询性能，所以这个时候可以根据业务场景，是希望优先读还是优先改，如果我们希望优先改，我们可以把关联的资源写成修改的API，资源名设置为查询API，这样修改超过阈值的话查询就会被限流。总的来说关联就是保护关联资源的设计。

我们继续来说第三个模式