SpringBoot2.0+阿里巴巴Sentinel动态限流实战(附源码)

程序员文章站 2022-07-06 21:36:19

sentinel 是什么？随着微服务的流行，服务和服务之间的稳定性变得越来越重要。sentinel 以流量为切入点，从流量控制、熔断降级、系统负载保护等多个维度保护服务的稳定性。sentinel 具有...

sentinel 是什么？

随着微服务的流行，服务和服务之间的稳定性变得越来越重要。sentinel 以流量为切入点，从流量控制、熔断降级、系统负载保护等多个维度保护服务的稳定性。

sentinel 具有以下特征:

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

sentinel 的主要特性：

SpringBoot2.0+阿里巴巴Sentinel动态限流实战(附源码)

sentinel 的开源生态：

SpringBoot2.0+阿里巴巴Sentinel动态限流实战(附源码)

sentinel 分为两个部分:

核心库（java 客户端）不依赖任何框架/库，能够运行于所有 java 运行时环境，同时对 dubbo / spring cloud 等框架也有较好的支持。
控制台（dashboard）基于 spring boot 开发，打包后可以直接运行，不需要额外的 tomcat 等应用容器。

控制台配置

sentinel 控制台最少应该包含如下功能:

查看机器列表以及健康情况：收集 sentinel 客户端发送的心跳包，用于判断机器是否在线。
监控 (单机和集群聚合)：通过 sentinel 客户端暴露的监控 api，定期拉取并且聚合应用监控信息，最终可以实现秒级的实时监控。
规则管理和推送：统一管理推送规则。
鉴权：生产环境中鉴权非常重要。这里每个开发者需要根据自己的实际情况进行定制。

可以直接从[ release 页面](https://github.com/alibaba/sentinel/releases " release 页面") 下载最新版本的控制台 jar 包，启动 sentinel 控制台需要 jdk 版本为 1.8 及以上版本。。

启动脚本 sentinel.sh：

#!/bin/bash
java -dsentinel.dashboard.auth.username=admin \
-dsentinel.dashboard.auth.password=admin \
-dserver.port=8084 -dcsp.sentinel.dashboard.server=localhost:8084 \
-dproject.name=sentinel-dashboard \
-jar sentinel-dashboard-1.6.3.jar &

用户可以通过如下参数进行配置：

-dsentinel.dashboard.auth.username=admin 用于指定控制台的登录用户名为 admin；
-dsentinel.dashboard.auth.password=admin 用于指定控制台的登录密码为 admin；如果省略这两个参数，默认用户和密码均为 sentinel；
-dserver.servlet.session.timeout=7200 用于指定 spring boot 服务端 session 的过期时间，如 7200 表示 7200 秒；60m 表示 60 分钟，默认为 30 分钟；

SpringBoot2.0+阿里巴巴Sentinel动态限流实战(附源码)

客户端配置

pom.xml 引入以下依赖：

 <!-- https://blog.52itstyle.vip -->
<parent>
 <groupid>org.springframework.boot</groupid>
 <artifactid>spring-boot-starter-parent</artifactid>
 <version>2.1.5.release</version>
 <relativepath/>
</parent>
<dependencies>
 <dependency>
 <groupid>org.springframework.boot</groupid>
 <artifactid>spring-boot-starter-web</artifactid>
 </dependency>
 <dependency>
 <groupid>com.alibaba.cloud</groupid>
 <artifactid>spring-cloud-starter-alibaba-sentinel</artifactid>
 </dependency>
</dependencies>
<dependencymanagement>
 <!--注意跟 springboot 保持一致 2.1.x for spring boot 2.1.x-->
 <dependencies>
 <dependency>
 <groupid>com.alibaba.cloud</groupid>
 <artifactid>spring-cloud-alibaba-dependencies</artifactid>
 <version>2.1.0.release</version>
 <type>pom</type>
 <scope>import</scope>
 </dependency>
 </dependencies>
</dependencymanagement>

配置文件：

# 应用名称 https://blog.52itstyle.vip
spring.application.name=blog
spring.cloud.sentinel.transport.port=8720
# 测试请替换为自己的地址
spring.cloud.sentinel.transport.dashboard=116.190.247.112:8084

这里的 spring.cloud.sentinel.transport.port端口配置会在应用对应的机器上启动一个 http server，该 server 会与 sentinel 控制台做交互。比如 sentinel 控制台添加了1个限流规则，会把规则数据 push 给这个 http server 接收，http server 再将规则注册到 sentinel 中。

代码配置：

/**
 * 博文 https://blog.52itstyle.vip
 */
@requestmapping("{id}.shtml")
@sentinelresource("blogview")
public string page(@pathvariable("id") long id, modelmap model) {
 try{
 blog blog = blogservice.getbyid(id);
 string key = "blog_"+id;
 long views = redisutil.size(key);
 blog.setviews(views+blog.getviews());
 model.addattribute("blog",blog);
 } catch (throwable e) {
 return "error/404";
 }
 return "article";
}

@sentinelresource 注解用来标识资源是否被限流、降级。上述例子上该注解的属性 'blogview' 表示资源名。

默认情况，sentinel 会拦截所有的 controller 请求，这里标识资源名，是因为所有的文章都会走这个请求，为了方便统计和流控，这里自定义资源标识。

更多注解支持，请参考：sentinel/wiki/注解支持。

访问客户端项目，随便点击几个页面，然后登录 sentinel 控制台，如果看到以下界面，说明配置成功。

SpringBoot2.0+阿里巴巴Sentinel动态限流实战(附源码)