添加URL
相关文章推荐
lichail  ·  linux-CentOS6.5安装后,loc ...·  3 年前    · 
lzx198301  ·  Java发送http的get、post、pu ...·  3 年前    · 
9976254  ·  logback新认识(二):logback之 ...·  3 年前    · 
9976254  ·  Database locked, ...·  2 年前    · 
天涯  ·  解决FastJson ...·  1 年前    · 

二、原理简述

•FileRefreshableDataSource 定时 从指定文件中读取规则JSON文件图中的本地文件,如果发现文件发生变化,就更新规则缓存。 •FileWritableDataSource 接收控制台规则推送,并根据配置,修改规则JSON文件图中的本地文件。

修改Spring Cloud Alibaba微服务。

3.1 加依赖

<dependency>	
  <groupId>com.alibaba.csp</groupId>	
  <artifactId>sentinel-datasource-extension</artifactId>	
</dependency>

3.2 写代码

* 拉模式规则持久化 * @author itmuch.com public class FileDataSourceInit implements InitFunc { @Override public void init() throws Exception { // TIPS: 如果你对这个路径不喜欢,可修改为你喜欢的路径 String ruleDir = System.getProperty("user.home") + "/sentinel/rules"; String flowRulePath = ruleDir + "/flow-rule.json"; String degradeRulePath = ruleDir + "/degrade-rule.json"; String systemRulePath = ruleDir + "/system-rule.json"; String authorityRulePath = ruleDir + "/authority-rule.json"; String paramFlowRulePath = ruleDir + "/param-flow-rule.json"; this.mkdirIfNotExits(ruleDir); this.createFileIfNotExits(flowRulePath); this.createFileIfNotExits(degradeRulePath); this.createFileIfNotExits(systemRulePath); this.createFileIfNotExits(authorityRulePath); this.createFileIfNotExits(paramFlowRulePath); // 流控规则 ReadableDataSource<String, List<FlowRule>> flowRuleRDS = new FileRefreshableDataSource<>( flowRulePath, flowRuleListParser // 将可读数据源注册至FlowRuleManager // 这样当规则文件发生变化时,就会更新规则到内存 FlowRuleManager.register2Property(flowRuleRDS.getProperty()); WritableDataSource<List<FlowRule>> flowRuleWDS = new FileWritableDataSource<>( flowRulePath, this::encodeJson // 将可写数据源注册至transport模块的WritableDataSourceRegistry中 // 这样收到控制台推送的规则时,Sentinel会先更新到内存,然后将规则写入到文件中 WritableDataSourceRegistry.registerFlowDataSource(flowRuleWDS); // 降级规则 ReadableDataSource<String, List<DegradeRule>> degradeRuleRDS = new FileRefreshableDataSource<>( degradeRulePath, degradeRuleListParser DegradeRuleManager.register2Property(degradeRuleRDS.getProperty()); WritableDataSource<List<DegradeRule>> degradeRuleWDS = new FileWritableDataSource<>( degradeRulePath, this::encodeJson WritableDataSourceRegistry.registerDegradeDataSource(degradeRuleWDS); // 系统规则 ReadableDataSource<String, List<SystemRule>> systemRuleRDS = new FileRefreshableDataSource<>( systemRulePath, systemRuleListParser SystemRuleManager.register2Property(systemRuleRDS.getProperty()); WritableDataSource<List<SystemRule>> systemRuleWDS = new FileWritableDataSource<>( systemRulePath, this::encodeJson WritableDataSourceRegistry.registerSystemDataSource(systemRuleWDS); // 授权规则 ReadableDataSource<String, List<AuthorityRule>> authorityRuleRDS = new FileRefreshableDataSource<>( flowRulePath, authorityRuleListParser AuthorityRuleManager.register2Property(authorityRuleRDS.getProperty()); WritableDataSource<List<AuthorityRule>> authorityRuleWDS = new FileWritableDataSource<>( authorityRulePath, this::encodeJson WritableDataSourceRegistry.registerAuthorityDataSource(authorityRuleWDS); // 热点参数规则 ReadableDataSource<String, List<ParamFlowRule>> paramFlowRuleRDS = new FileRefreshableDataSource<>( paramFlowRulePath, paramFlowRuleListParser ParamFlowRuleManager.register2Property(paramFlowRuleRDS.getProperty()); WritableDataSource<List<ParamFlowRule>> paramFlowRuleWDS = new FileWritableDataSource<>( paramFlowRulePath, this::encodeJson ModifyParamFlowRulesCommandHandler.setWritableDataSource(paramFlowRuleWDS); private Converter<String, List<FlowRule>> flowRuleListParser = source -> JSON.parseObject( source, new TypeReference<List<FlowRule>>() { private Converter<String, List<DegradeRule>> degradeRuleListParser = source -> JSON.parseObject( source, new TypeReference<List<DegradeRule>>() { private Converter<String, List<SystemRule>> systemRuleListParser = source -> JSON.parseObject( source, new TypeReference<List<SystemRule>>() { private Converter<String, List<AuthorityRule>> authorityRuleListParser = source -> JSON.parseObject( source, new TypeReference<List<AuthorityRule>>() { private Converter<String, List<ParamFlowRule>> paramFlowRuleListParser = source -> JSON.parseObject( source, new TypeReference<List<ParamFlowRule>>() { private void mkdirIfNotExits(String filePath) throws IOException { File file = new File(filePath); if (!file.exists()) { file.mkdirs(); private void createFileIfNotExits(String filePath) throws IOException { File file = new File(filePath); if (!file.exists()) { file.createNewFile(); private <T> String encodeJson(T t) { return JSON.toJSONString(t);

3.3 配置

在项目的 resources/META-INF/services 目录下创建文件,名为 com.alibaba.csp.sentinel.init.InitFunc ,内容为:

# 改成上面FileDataSourceInit的包名类名全路径即可。	
com.itmuch.contentcenter.FileDataSourceInit

四、优缺点分析

4.1 优点

•简单易懂 •没有多余依赖(比如配置中心、缓存等)

4.2 缺点

•由于规则是用 FileRefreshableDataSource 定时更新的,所以规则更新会有延迟。如果FileRefreshableDataSource定时时间过大,可能长时间延迟;如果FileRefreshableDataSource过小,又会影响性能; •规则存储在本地文件,如果有一天需要迁移微服务,那么需要把规则文件一起迁移,否则规则会丢失。

五、你可能会有的疑问

Spring Cloud Alibaba不是提供了如下配置了吗?为什么要全部自己写呢?

spring.cloud.sentinel.datasource.ds1.file.file=classpath: degraderule.json	
spring.cloud.sentinel.datasource.ds1.file.rule-type=flow	
#spring.cloud.sentinel.datasource.ds1.file.file=classpath: flowrule.json	
#spring.cloud.sentinel.datasource.ds1.file.data-type=custom	
#spring.cloud.sentinel.datasource.ds1.file.converter-class=com.alibaba.cloud.examples.JsonFlowRuleListConverter	
#spring.cloud.sentinel.datasource.ds1.file.rule-type=flow

关于这个问题,可以看我提的Issue: https://github.com/alibaba/spring-cloud-alibaba/issues/756

六、参考文档

https://github.com/alibaba/Sentinel/wiki/在生产环境中使用-Sentinel#pull模式

最近将个人学习笔记整理成册,使用PDF分享。关注我,回复如下代码,即可获得百度盘地址,无套路领取!

•001:《Java并发与高并发解决方案》学习笔记; •002:《深入JVM内核——原理、诊断与优化》学习笔记; •003:《Java面试宝典》 •004:《Docker开源书》 •005:《Kubernetes开源书》 •006:《DDD速成(领域驱动设计速成)》 •007: 全部 •008: 加技术讨论群

你真的了解 lambda 吗(纠错篇)? 如何在 IDEA 使用Debug 图文教程 除了负载均衡,Nginx还可以做限流、缓存、黑白名单…… 漫漫优化路,总会错几步!记一次接口优化! 秒杀系统 架构分析 与 实战 优化你的Spring Boot

想知道更多?长按/扫码关注我吧↓↓↓ 640?wx_fmt=jpeg >>>技术讨论群<<< 喜欢就点个 "在看" 呗^_^

1 (pull) 模式 1.1 架构设计 该 模式 的数据源(如本地 文件 、RDBMS 等)一般可写入。使用时需在客户端注册数据源:将对应读数据源注册至对应的 RuleManager,将写数据源注册至 transport 的 WritableDataSourceRegistry 中。 以本地 文件 数据源为例: public class FileDataSourceInit implements InitFunc { @Override public void init() throws
Sentinel 基本概念在此文章就不进行介绍了,没有了解过的,可以参考我的其他文章有介绍 Sentinel 是解决什么问题的 首先去 Sentinel 官网上,将它的源码进行下载,因为在它源码上进行修改,当然如果觉得源码不方便,也可以直接下载它官网上的jar包 Sentinel 官方地址 https://github.com/ alibaba / Sentinel /wiki/%E4%BB%8B%E7%BB%8...
从上面的一篇文章中 – 03、 Sentinel 源码分析 之 Hello World 我们知道了如何简单的使用 Sentinel 进行限流工作。如果你想知道更加详细的使用方式可以查询 Sentinel 的官方文档。我们首先来回顾一下之前的简单操作,然后就来从源码级别来分析一下这个框架是如何实现的。 1、 Sentinel 简单操作 下面就是使用 Sentinel 框架进行资源限流的简单步骤。 public static void main(String[] args) { // 配置 规则 . 每天多学一点点~ 话不多说,这就开始吧… 文章目录 Sentinel 规则 持久化 改造(pull+push+Ahas)1.前言2. 官网参考3. 原生 模式 4. PULL 模式 5. push 推 模式 6. 阿里云Ahas7.结语 之前学习过阿里的 sentinel 组件,但是重启之后,配置的 规则 都消失了。于是乎上网找了点资料,自己也来对 sentinel 持久化 改造一下,这里记录一下过程。 以 sentinel 1.7.0 版本 为例 sentine
<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring - cloud - alibaba - sentinel </artifactId> <version>0.9.0.RELEASE</version> </dependency&gt 每次微服务重新启动,在 Sentinel 设置的各种 规则 都会消失,所以需要进行 持久化 ,本文介绍两种方法一种是 持久化 到本地,另外一种是 持久化 的nacos。 持久化 到本地 这个很简单总共只有两步 添加依赖,创建 Sentinel PerFile 在resource 文件 下创建META_INF/services 文件 夹,然后创建文档com. alibaba .csp. sentinel .init.InitFunc,在上面写上 Sentinel PerFile 的绝对路径 <! - - 添加 sentinel 持久化 到本地
在一些情况下,不需要使用nacos等其他组件保存限流 规则 ,且限流 规则 一般不改变。就可以使用配置 文件 的方式配置限流 规则 了。 限流参数解释: 对应的值可以在com. alibaba .csp. sentinel .slots.block.RuleConstant.java中查到 Field resource 资源名,资源名是限流 规则 的作用对象 count
本篇博客主要包括:限流方式、微服务容灾技术选型、 Sentinel 的使用、 Sentinel 动态 规则 持久化 Zookeeper 等。 Sentinel 动态 规则 持久化 到Zookeeper的代码实现我已经共享到本人的github,有需要的可以下载使用。 github地址:https://github.com/Force - King/ sentinel - dashboard - zk 持久化 zk的 sentinel ...