Spring Cloud Alibaba整合Sentinel流控

ytwman 发布于2019-08-16 16:51 / 2943人阅读

摘要：前面我们都是直接通过集成的依赖，通过编码的方式配置规则等。对于集成到中阿里已经有了一套开源框架，就是用于将一系列的框架成功的整合到中。但这也是在学习过程中遇到的一个问题，还是得通过调试源码的方式去发现问题的原因。

前面我们都是直接通过集成sentinel的依赖，通过编码的方式配置规则等。对于集成到Spring Cloud中阿里已经有了一套开源框架spring-cloud-alibaba，就是用于将一系列的框架成功的整合到Spring Cloud中。

我这边Spring Cloud的版本是Finchley.SR2，Spring Boot的版本是2.0.6.RELEASE，下面开始集成步骤。

1. 整合步骤 1.1添加Maven依赖


    org.springframework.cloud
    spring-cloud-starter-alibaba-sentinel
    0.2.1.RELEASE

1.2 增加限流的配置

application.properties

# 文件规则数据源
spring.cloud.sentinel.datasource.ds1.file.file=classpath: flowrule.json
# JSON格式的数据
spring.cloud.sentinel.datasource.ds1.file.data-type=json
# 规则类型
spring.cloud.sentinel.datasource.ds1.file.rule-type=flow

flowrule.json

[
  {
    "resource": "hello",
    "controlBehavior": 0,
    "count": 1,
    "grade": 1,
    "limitApp": "default",
    "strategy": 0
  }
]

1.3 @SentinelResource使用

@GetMapping("/test")
@SentinelResource(value="hello",blockHandler="handleException",blockHandlerClass=ExceptionUtil.class)
public String test() {
    String result = restTemplate.getForObject("http://localhost:8087/user/name", String.class);
    return result;
}

1.4 回退内容定义

public class ExceptionUtil {
    public static String handleException(BlockException ex) {
        return "扛不住了啊....";
    }
}

前面我们使用注解的话都是手动配置SentinelResourceAspect类，为什么今天不需要配置SentinelResourceAspect呢？

那是因为在spring-cloud-alibaba中已经默认配置好了，代码在org.springframework.cloud.alibaba.sentinel.custom.SentinelAutoConfiguration中，代码如下：

@Bean
@ConditionalOnMissingBean
public SentinelResourceAspect sentinelResourceAspect() {
    return new SentinelResourceAspect();
}

2. 整合Apollo持久化规则

利用spring-cloud-alibaba整合Apollo就比较简单了，直接通过配置就可以，不需要通过编码的方式手动注册动态数据源。

2.1 增加Apollo的Maven依赖


    com.alibaba.csp
    sentinel-datasource-apollo
    1.4.1

2.2 数据源配置

# Apollo命名空间
spring.cloud.sentinel.datasource.ds4.apollo.namespace-name = application
# 规则配置Key
spring.cloud.sentinel.datasource.ds4.apollo.flow-rules-key = flowRules
# 规则配置默认值
spring.cloud.sentinel.datasource.ds4.apollo.default-flow-rule-value = []
# 规则类型
spring.cloud.sentinel.datasource.ds4.apollo.rule-type = flow

2.3 Apollo相关的配置

关于Apollo的地址，appid等信息可以在配置文件中添加，我们为了演示方便就还是使用代码指定的方式。

@SpringBootApplication
public class SentinelApp {
    public static void main(String[] args) {
        // Apollo 中的应用名称，自己定义的
        String appId = "SampleApp";
        // Apollo 的地址
        String apolloMetaServerAddress = "http://localhost:8080";
        System.setProperty("app.id", appId);
        System.setProperty("apollo.meta", apolloMetaServerAddress);
        // 指定环境
        System.setProperty("env", "DEV");
        SpringApplication.run(SentinelApp.class, args);
    }
}

2.4 测试

在Apollo中添加限流的规则即可，比如：

flowRules = [{"grade":1,"count":1,"resource":"hello","controlBehavior":0}]

在org.springframework.cloud.alibaba.sentinel.datasource.converter.JsonConverter中打个端点调试下，启动时或者配置更新时都会在里面进行规则的转换。

在这边遇到了一个坑跟大家分享一下，最开始我配置了最简单的规则，就下面三个Key

flowRules = [{"grade":1,"count":1,"resource":"hello"}]

如果配置成上面的三个Key，限流将不会触发，后面自己调试JsonConverter中的代码才发现了原因。

有这么一段代码，是根据配置中心的json字符串转换成对应的规则类：

List rules = Arrays.asList(convertFlowRule(itemJson),
                        convertDegradeRule(itemJson), convertSystemRule(itemJson),
                        convertAuthorityRule(itemJson), convertParamFlowRule(itemJson));

转换完了后会进行过滤，得到一个最终的List，然后判断数量，只有为1的时候才是正确的，由于我配置上面的规则，然后得出来的convertRuleList里面数量为2，这样就没法返回正确的规则。

List convertRuleList = rules.stream()
                        .filter(rule -> !ObjectUtils.isEmpty(rule))
                        .collect(Collectors.toList());

if (convertRuleList.size() == 0) {
    logger.warn(
            "Sentinel JsonConverter can not convert {} to any rules, ignore", itemJson);
}
else if (convertRuleList.size() > 1) {
    logger.warn(
            "Sentinel JsonConverter convert {} and match multi rules, ignore", itemJson);
}
else {
    ruleList.add(convertRuleList.get(0));
}

之所有数量为2是因为上面转换代码的convertFlowRule(itemJson)和convertParamFlowRule(itemJson)，这两个转换的问题，由于我的配置只有三个key，而这三个Key又是这两个规则共同的，所以都转换成功了才导致数量为2。解决办法就是加一些独有的Key，比如controlBehavior。

当然这个问题如果我们对接了控制台的话，通过控制台去修改配置中心的值就不会出现这个问题了。但这也是在学习过程中遇到的一个问题，还是得通过调试源码的方式去发现问题的原因。

欢迎加入我的知识星球，一起交流技术，免费学习猿天地的课程（http://cxytiandi.com/course） PS：目前星球中正在星主的带领下组队学习Sentinel，等你哦！

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/74221.html

Spring Cloud Alibaba基础教程：Sentinel使用Nacos存储规则

摘要：所以，在整合了做规则存储之后，需要知道在下面两个地方修改存在不同的效果控制台中修改规则仅存在于服务的内存中，不会修改中的配置值，重启后恢复原来的值。控制台中修改规则服务的内存中规则会更新，中持久化规则也会更新，重启后依然保持。通过上一篇《使用Sentinel实现接口限流》的介绍，相信大家对Sentinel已经有了初步的认识。在Spring Cloud Alibaba的整合封装之下，接...

xingqiba 2019-08-16 16:43 评论0 收藏0
Spring Cloud Alibaba基础教程：使用Sentinel实现接口限流

摘要：但是比较可惜的是已经宣布对停止更新。客户端整合每个微服务客户端都需要整合的客户端封装与配置，才能将监控信息上报给展示以及实时的更改限流或熔断规则等。下面我们就分两部分来看看，如何使用来实现接口限流。最近管点闲事浪费了不少时间，感谢网友libinwalan的留言提醒。及时纠正路线，继续跟大家一起学习Spring Cloud Alibaba。 Nacos作为注册中心和配置中心的基础教程，...

stefanieliang 2019-08-19 11:37 评论0 收藏0
Sentinel Dashboard中修改规则同步到Apollo存储

摘要：在之前的两篇教程中我们分别介绍了如何将的限流规则存储到和中。本文以存储为例，下一篇介绍的改在示例。但是由于考虑到与的结合使用，略作修改。在之前的两篇教程中我们分别介绍了如何将Sentinel的限流规则存储到Nacos和Apollo中。同时，在文末的思考中，我都指出了这两套整合方案都存在一个不足之处：不论采用什么配置中心，限流规则都只能通过Nacos界面或Apollo界面来完成修改才能...

psychola 2019-08-16 17:12 评论0 收藏0
[Spring-Cloud-Alibaba] Sentinel 整合RestTemplate &am

摘要：开发阶段很有意义。源码整合配置文件中添加来开启编写类，实现默认用户远程调用被限流降级，默认用户应用定义可以拿到异常信息无法拿到异常信息若初启动应用，设置流控规则，结果展示如下默认用户源码 Sentinel API Github : WIKI Sphu （指明要保护的资源名称） Tracer （指明调用来源,异常统计接口） ContextUtil（标示进入调用链入口）流控规则(针...

libin19890520 2019-08-16 18:38 评论0 收藏0
Spring Cloud Alibaba基础教程：Sentinel使用Apollo存储规则

摘要：上一篇我们介绍了如何通过的配置功能来存储限流规则。第六步启动应用。深入思考在使用存储规则配置的时候与存储一样，对于控制台这些数据是只读的，也就是说控制台中修改规则仅存在于服务的内存中，不会修改中的配置值，重启后恢复原来的值。上一篇我们介绍了如何通过Nacos的配置功能来存储限流规则。Apollo是国内用户非常多的配置中心，所以，今天我们继续说说Spring Cloud Alibaba...

Airmusic 2019-08-16 16:51 评论0 收藏0