2021-06-08

Sentinel全局Feign默认熔断设计实现

前言

上篇文章中介绍了Sentinel全局默认熔断，留下了一个思考：

图片

Sentinel的降级熔断的配置，生产环境使用的时候，一般会在控制台管理，持久化到Nacos；微服务监听Nacos的配置变化，从而实现服务调用的降级熔断策略。

现在就会遇到这样的问题，如果有很多Feign接口，如上图服务A、服务B都有一些Feign接口的远程调用，都需要我们进行一一配置。而且配置的一些参数绝大多数都一样的。如：

1、对Feign远程调用的慢响应策略的配置降级策略

2、对Feign远程调用的异常数的配置降级策略

3、对Feign远程调用的异常比例数的配置降级策略

针对上面的配置1-2个服务方法还好；但是现在公司的生产环境都有100～200个微服务，服务之间的调用方法就更多了；那针对普通标准的降级熔断的配置都需要人工一个个配置，那是不是太麻烦了。

虽然之前的文章中，我们已经解决了Feign的全局默认降级fallback配置，但是他没法实现熔断（即没有熔断功能，每次都要去调用异常服务方法，然后再降级）。

本文就来解决这个问题，跟着继续往下看。

源码分析

我们先来看看Sentinel是怎么设置熔断策略的，在上图中我们知道是通过Sentinel控制台进行配置，然后微服务都可以订阅这些配置；我们看一下源码。

图片

这个是监听nacos配置的相关的代码

图片

上图代码核心就是发现配置有变化，就updateValue规则；我们继续跟踪代码发现一个DegradeRuleManager降级规则的管理类，里面有2个核心的变量ruleMap、circuitBreakers；我们可以猜出就是降级规则集合以及熔断规则集合。

图片

在继续往下看，我们发现有个RulePropertyListener中reloadFrom方法****，即重新加载规则；方法里面有个buildCircuitBreakers方法，一看方法名就知道是构建熔断策略。

图片

在看一下buildCircuitBreakers方法，我们看到本质就是遍历DegradeRule集合，然后在初始化熔断对象CircuitBreaker。

图片

这里我们知道熔断是怎么产生的了；本质就是通过DegradeRule产生的。

解决方案

上面我们知道了一些熔断对象产生的原理，我们只要可以自定义DegradeRule对象就可以产生。我们在学习Sentinel的时候，他有个Api方式去定义降级规则，大家可以去看一下之前的文章，详细介绍了Api定义规则的方式。我们看一下案例

图片

我们可以看到DegradeRule对象的定义，以及DegradeRuleManager对象；上面的代码就能给资源名api定义了慢响应的降级策略了。

讲到这里聪明的小伙伴们有没有想到一些思路呢？往下看。

方案思路

先给出整体的解决思路

图片

上图中介绍的流程

1、启动服务时扫描jar，获取@FeignClient注解的接口（技术难点一：扫描哪些jar包）2、获得Feign接口中的调用方法3、服务本地创建DegradeRule对象。(技术难点二：Sentinel的资源名支持动态配置）4、把设置的默认的降级熔断规则同步到Nacos

根据上面的流程，我们就可以看到，一旦微服务启动了，就会自动把Feign接口配置默认的降级熔断规则，以及同步到Nacos中；再结合之前文章中介绍的Sentinel控制台改造，就立刻在控制台显示这些降级规则了，而不需要认为配置了。

注意：上面只是介绍了整体流程，在编写代码的时候，我们需要考虑到很多场景，如：

一）服务第二次启动的时候，nacos中已经有了相关的配置，是否还要修改nacos的配置。

二）以及有些特殊业务在Sentinel控制台进行了降级配置，那默认的全局配置如何兼容人工的配置。

这些就不在这里讲了，本文只介绍核心方案思路，核心代码

其他的有兴趣的小伙伴们，可以跟要源码

技术难点

难点一

我们扫码jar包，而且是要扫码包含@FeignClient注解接口的jar。我们知道在使用Feign功能的时候，需要在SpringBootApplication启动类中加上@EnableFeignClients；

@SpringBootApplication@EnableDiscoveryClient@EnableFeignClientspublic class ApplicationA { public static void main(String[] args) { SpringApplication.run(ApplicationA.class, args); }}

有的时候Feign包会用第三方jar的形式存在，那代码就有会变成

@SpringBootApplication@EnableDiscoveryClient@EnableFeignClients(basePackages = {"com.rainbow.demo1.feign","com.rainbow.demo2.feign"})public class ApplicationA { public static void main(String[] args) { SpringApplication.run(ApplicationA.class, args); }}

里面的@EnableFeignClients注解的属性basePackages中显式的指向了Feign包的位置了，这个比较好弄，直接用用ClassScan工具类扫就行了。

ClassScan工具类是支持子包扫描的

那没有显式的定义basePackages，那怎么获取到jar包路径呢？

我们可以参考SpringCloud的源码实现的方法，看代码。

图片

上面是根据启动服务时，堆栈信息获取main方法的启动类对象。

图片

根据启动类对象，获取到EnableFeignClients对象，如果没有basePackages，那就是以启动类的包为扫描的入口。

这样我们就解决了扫描jar入口的问题。

难点二

常规方式

资源名的获取，举个例子

@FeignClient(name = "service-provider")public interface ProviderServiceFeign { @GetMapping("/transferHeaders") public BaseRestResponse<String> transferHeaders();}

根据微服务的Sentinel资源名定义，@FeignClient(name = "service-provider")，微服务名是service-provider；那针对transferHeaders()方法的降级策略资源名即为

lb://service-provider/transferHeaders

这个实现比较简单就是获取@FeignClient的name的值，以及方法@GetMapping里面的值就可以拼接出资源名。

指定Url地址

@FeignClient(name = "service-provider",url = "http://xxxxx")public interface ProviderServiceFeign { @GetMapping("/transferHeaders") public BaseRestResponse<String> transferHeaders();}

指定url的目的其实就是指定请求的方式，这种情况的Sentinel的资源名即为

动态配置Url
还有一种情况即对接第三方平台时，我们一般不会写死Url，而是通过配置的方式，如
@FeignClient(name = "service-provider",url = "${reqUrl}")public interface ProviderServiceFeign { @GetMapping("/transferHeaders") public BaseRestResponse<String> transferHeaders();}
上面的${reqUrl}是通过配置的，那Sentinel的资源名是什么样的呢？本质上面资源名也是Url+具体的请求地址，即
Environment environment ;//环境变量对象this.environment.resolvePlaceholders(url);//获取变量的值
图片
核心代码
上面的技术难点解决掉之后，我们就放开双手撸代码了，这里贴上核心的代码；小伙伴们。
public class DegradeRuleInitializer implements ApplicationRunner, EnvironmentAware
实现ApplicationRunner, EnvironmentAware就能够实现启动时，去扫描了，入口就在ApplicationRunner中的run方法。
图片
扫描类
图片
扫描FeignClient
图片
初始化默认规则
图片
设置了默认降级规则，把配置信息发布到nacos
图片
效果
一旦微服务启动了，nacos配置就有了
图片
我们会把默认的值发布到nacos里面，小伙伴们可以具体看一些资源名，里面就会有很多降级规则。
图片
我们再来看看Sentinel控制台，里面就显示了降级规则列表；设计的是针对同一个资源名做异常数、异常比例、慢响应三种类型的降级熔断策略。
图片
全局默认的值，到底是多少阀值，是可以通过配置的方式的，这些就不介绍了。比较简单。
到这里就全部实现了微服务中Feign接口的降级熔断策略的默认化配置，不需要人工去添加了；当然是支持人工去修改的，如果需要修改阀值，可以人工修改。
总结
本文介绍了Sentinel的全局Feign默认熔断的技术实现方案，整体思路原理不是太复杂，就是利用其本身的功能，做了一些扩展；这样更方便用户的使用。小伙伴如果需要源代码可以联系哦。谢谢！！！
java高级开发系统进阶笔记、最新面试复习笔记PDF，我的GitHub



 
 
 

   
原文转载：http://www.shaoqun.com/a/790358.html
跨境电商：https://www.ikjzd.com/
邓白氏集团：https://www.ikjzd.com/w/582
 
环球易购：https://www.ikjzd.com/w/1034
 
夸克：https://www.ikjzd.com/w/1237
 
四海商舟：https://www.ikjzd.com/w/1516
 
前言上篇文章中介绍了Sentinel全局默认熔断，留下了一个思考：Sentinel的降级熔断的配置，生产环境使用的时候，一般会在控制台管理，持久化到Nacos；微服务监听Nacos的配置变化，从而实现服务调用的降级熔断策略。现在就会遇到这样的问题，如果有很多Feign接口，如上图服务A、服务B都有一些Feign接口的远程调用，都需要我们进行一一配置。而且配置的一些参数绝大多数都一样的。如：1、对F
focalprice：https://www.ikjzd.com/w/1094.html
雨果网：https://www.ikjzd.com/w/1307
易速：https://www.ikjzd.com/w/2389
声网：https://www.ikjzd.com/w/2176
母婴团购网：https://www.ikjzd.com/w/716
忍不了 妖艳化妆师当面摸我男友：http://lady.shaoqun.com/m/a/271760.html
边走边律动 嗯好大挺入 小姨子的贴身保镖：http://lady.shaoqun.com/m/a/274607.html
撞见弟妹裸身趴我老公身上：http://lady.shaoqun.com/a/271234.html
女友向闺蜜抱怨我床技不行：http://www.30bags.com/m/a/251304.html
桂林融创欢乐部落在哪里，怎么走？：http://www.30bags.com/a/370380.html
离亚马逊Prime Day只剩半个月，卖家应该如何应对？：https://www.ikjzd.com/articles/145612
eBay授权监管机构对被禁止的物品进行移除：https://www.ikjzd.com/articles/145611
阿里巴巴国际站运营怎么做？：https://www.ikjzd.com/articles/145602
Posted by at

No comments:

Post a Comment

Subscribe to: Post Comments (Atom)