上一篇
我们介绍了如何通过Nacos的配置功能来存储限流规则。Apollo是国内用户非常多的配置中心,所以,今天我们继续说说Spring Cloud Alibaba Sentinel中如何将流控规则存储在Apollo中。
使用Apollo存储限流规则
Sentinel自身就支持了多种不同的数据源来持久化规则配置,目前包括以下几种方式:
Nacos配置
ZooKeeper配置
Apollo配置
本文我们就来一起动手尝试一下,如何使用Apollo来存储限流规则。
下面我们将同时使用到
Apollo
和
Sentinel Dashboard
,所以可以先把
Apollo
和
Sentinel Dashboard
启动起来。
如果还没入门
Sentinel Dashboard
可以通过文末的系列目录先学习之前的内容。Apollo的话相对复杂一些,这里不做详细介绍了,如果还没有接触过Apollo的读者可以查看其
官方文档
进一步学习。
第一步
:在Spring Cloud应用的
pom.xml
中引入Spring Cloud Alibaba的Sentinel模块和Apollo存储扩展:
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
</dependency>
<dependency>
<groupId>com.alibaba.csp</groupId>
<artifactId>sentinel-datasource-apollo</artifactId>
<version>1.4.0</version>
</dependency>
</dependencies>
第二步
:在Spring Cloud应用中配置的服务信息,在
resource
目录下,创建
apollo-env.properties
文件,内容样例:
local.meta=http://192.168.0.201:8080
dev.meta=http://192.168.0.202:8080
这里需要了解Apollo对多环境的配置,这里设置的是每个环境不同的配置服务地址,读者需要根据自己的实际情况修改。
第三步
:在Spring Cloud应用中添加配置信息:
spring.application.name=sentinel-datasource-apollo
server.port=8002
# apollo config
app.id=${spring.application.name}
# sentinel dashboard
spring.cloud.sentinel.transport.dashboard=localhost:8080
# sentinel datasource apollo
spring.cloud.sentinel.datasource.ds.apollo.namespaceName=application
spring.cloud.sentinel.datasource.ds.apollo.flowRulesKey=sentinel.flowRules
app.id
:Apollo中的创建的项目名称,这里采用
spring.application.name
参数的引用,从而达到服务名与配置项目名一致的效果
spring.cloud.sentinel.transport.dashboard
:sentinel dashboard的访问地址,根据上面准备工作中启动的实例配置
spring.cloud.sentinel.datasource.ds.apollo.namespaceName
:Apollo的空间名
spring.cloud.sentinel.datasource.ds.apollo.flowRulesKey
:配置规则的key名称
关于Apollo相关配置的对应关系可见下图所示:
第四步
:创建应用主类,并提供一个rest接口,比如:
@EnableApolloConfig
@SpringBootApplication
public class TestApplication {
public static void main(String[] args) {
SpringApplication.run(TestApplication.class, args);
@Slf4j
@RestController
static class TestController {
@GetMapping("/hello")
public String hello() {
return "didispace.com";
其中@EnableApolloConfig
注解是开启Apollo的配置加载功能。
第五步:Apollo中配置限流规则,具体可见第三步的截图中的样子。其中,key值的内容是下面的json
"resource": "/hello",
"limitApp": "default",
"grade": 1,
"count": 5,
"strategy": 0,
"controlBehavior": 0,
"clusterMode": false
可以看到上面配置规则是一个数组类型,数组中的每个对象是针对每一个保护资源的配置对象,每个对象中的属性解释如下:
resource:资源名,即限流规则的作用对象
limitApp:流控针对的调用来源,若为 default 则不区分调用来源
grade:限流阈值类型(QPS 或并发线程数);0
代表根据并发数量来限流,1
代表根据QPS来进行流量控制
count:限流阈值
strategy:调用关系限流策略
controlBehavior:流量控制效果(直接拒绝、Warm Up、匀速排队)
clusterMode:是否为集群模式
这里我们只做简单的配置解释,以便于理解这里的配置作用。实际上这里还有非常多可配置选项和规则,更复杂的配置后面我们单独开一篇来深入学习。
第六步:启动应用。如果一些顺利,可以看到类似下面的日志,代表已经成功从Nacos加载了一条限流规则:
2019-04-18 23:56:11.278 INFO 29149 --- [ main] o.s.c.a.s.c.SentinelDataSourceHandler : [Sentinel Starter] DataSource ds-sentinel-apollo-datasource start to loadConfig
2019-04-18 23:56:11.279 INFO 29149 --- [ main] o.s.c.a.s.c.SentinelDataSourceHandler : [Sentinel Starter] DataSource ds-sentinel-apollo-datasource load 1 FlowRule
通过postman或者curl访问几下localhost:8002/hello
接口:
$ curl localhost:8002/hello
didispace.com
此时,在Sentinel Dashboard中就可以看到当前我们启动的sentinel-datasource-apollo
服务。点击左侧菜单中的流控规则,可以看到已经存在一条记录了,这条记录就是上面我们在Apollo中配置的限流规则。
在使用Apollo存储规则配置的时候与Nacos存储一样,对于Sentinel控制台这些数据是只读的,也就是说:
Sentinel控制台中修改规则:仅存在于服务的内存中,不会修改Apollo中的配置值,重启后恢复原来的值。
Nacos控制台中修改规则:服务的内存中规则会更新,Apollo中持久化规则也会更新,重启后依然保持。
本文介绍内容的客户端代码,示例读者可以通过查看下面仓库中的alibaba-sentinel-datasource-apollo
项目:
Github:https://github.com/dyc87112/SpringCloud-Learning/
Gitee:https://gitee.com/didispace/SpringCloud-Learning/
如果您对这些感兴趣,欢迎star、follow、收藏、转发给予支持!
下面是Sentinel的仓库地址与官方文档,读者也可以自己查阅文档学习:
Github
Sentinel官方文档:动态规则
Spring Cloud Alibaba Sentinel文档
Spring Boot基础教程
Spring Cloud基础教程
SpringCloud Alibaba学习(十一):Sentinel的规则持久化
在前面学习Sentinel时我们发现:一旦重启应用,sentinel规则将消失,生产环境需要将配置规则进行持久化 ,非常不方便。这就需要本文介绍的sentinel的规则持久化。
SpringCloud Alibaba学习(八):Sentinel的热点规则
热点即经常访问的数据,很多时候我们希望统计或者限制某个热点数据中访问频次最高的TopN数据,并对其访问进行限流或者其它操作 。
SpringCloud Alibaba学习(七):Sentinel的降级规则
Sentinel 熔断降级会在调用链路中某个资源出现不稳定状态时(例如调用超时或异常比例升高),对这个资源的调用进行限制,让请求快速失败,避免影响到其它的资源而导致级联错误。
从0到1 手把手搭建spring cloud alibaba 微服务大型应用框架(十)sentinel篇(3): sentinel 熔断规则及使用详解
从0到1 手把手搭建spring cloud alibaba 微服务大型应用框架(十)sentinel篇(3): sentinel 熔断规则及使用详解
从0到1 手把手搭建spring cloud alibaba 微服务大型应用框架(十)sentinel篇(2): sentinel 流控规则及使用详解
从0到1 手把手搭建spring cloud alibaba 微服务大型应用框架(十)sentinel篇(2): sentinel 流控规则及使用详解
(2) 调整点之新增NacosConfigProperties类
(3) 调整点之修改NacosConfigUtil类
(4) DynamicRuleProvider和DynamicRulePublisher实现优化
1) AbstractNacosProvider类
2) AbstractNacosPublisher类
3) FlowRuleNacosProvider类
4) FlowRuleNacosPublisher