前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >Sentinel与OpenFeign整合实现熔断降级源码分析

Sentinel与OpenFeign整合实现熔断降级源码分析

作者头像
吴就业
发布2020-07-16 17:03:46
1.3K0
发布2020-07-16 17:03:46
举报
文章被收录于专栏:Java艺术Java艺术

Sentinel无论是实现限流还是熔断降级,其实都是通过适配模块去实现拦截方法的执行,在方法执行之前调用所有ProcessorSlot的entry方法,在方法执行之后所有ProcessorSlot的exit方法,使用责任链模式调用。由StatisticSlot这个ProcessorSlot统计请求信息,由DegradeSlot检查当前请求是否需要熔断,由FlowSlot检查当前请求是否需要限流。

StatisticSlot的entry方法将资源当前时间窗口的Bucket的请求数自增1,如果需要限流或熔断,则将Bucket的限流总数自增1;exit方法负责更新Bucket的成功总数或者异常总数、总耗时、最大耗时,以及将并发使用的线程总数减1。

Sentinel提供各种适配模块让我们更方便的使用Sentinel,这些适配模块只不过是帮我们完成调用ProcessorSlot的entry方法以及调用ProcessorSlot的exit方法。在前面学习使用Sentinel与OpenFeign整合实现熔断降级时,我们使用spring-cloud-start-alibaba-sentinel,由它实现Sentinel与OpenFeign整合。

Sentinel与OpenFeign整合源码分析

当Sentinel与OpenFeign、Ribbon整合时,客户端向服务端发起一次请求的过程如下图所示。

1、当调用@FeignClient注解注释的接口的方法时,由Sentinel提供的SentinelInvocationHandler方法调用拦截器拦截方法的执行,根据调用的方法的url生成资源名称,然后调用Sentinel的SphU的entry方法(完成所有ProcessorSlot的entry方法的调用),判断当前发起的请求是否需要限流或者熔断降级;

2、非限流、熔断降级情况下,继续将请求交给OpenFeign的MethodHandler处理;

3、OpenFeign从Ribbon那里获取一个服务提供者节点;

4、OpenFeign使用HttpClient发起http请求;

5、OpenFeign请求成功或者异常(已经经过重试)时,调用Sentinel的Entry的exit方法(完成所有ProcessorSlot的exit方法的调用)更新当前时间窗口的请求成功总数、异常总数等;

可见,Sentinel处在接口调用的最前端,因此Sentinel的统计数据即不会受Ribbon的重试影响也不会受OpenFeign的重试影响。

Sentinel通过自己提供InvocationHandler替换OpenFeign的InvocationHandler实现请求拦截。SentinelInvocationHandler源码如下。

SentinelInvocationHandler源码调试如下图所示:

InvocationHandler是OpenFeign为接口生成的JDK动态代理类时所需要的,是接口的方法拦截处理器,Sentinel通过替换OpenFeign的InvocationHandler拦截方法的执行,在OpenFeign处理接口调用之前实现限流、熔断降级的逻辑,以及之后的接口调用成功或异常时的数据统计。那么,Sentinel是如何将原本的FeignInvocationHandler替换为SentinelInvocationHandler的呢?

OpenFeign是通过Feign.Builder类创建接口的代理类的,所以Sentinel直接将Feign.Builder也替换成了SentinelFeign.Builder,由SentinelFeignAutoConfiguration自动配置类向Spring的Bean容器注入SentinelFeign.Builder,代码如下。

SentinelFeign.Builder继承Feign.Builder并重写build方法,只是替换了InvocationHandlerFactory,所以OpenFeign调用InvocationHandlerFactory的create方法创建的InvocationHandler就变成了SentinelInvocationHandler。SentinelFeign.Builder的build方法源码如下。

build方法中的匿名内部类InvocationHandlerFactory的create方法代码很长,所以去掉了。

create方法负责创建SentinelInvocationHandler,通过反射从FeignClientFactoryBean拿到@FeignClient注解上配置的fallback,当触发限流或熔断时,Sentinel就能根据fallback配置的类型从Bean工厂取得Fallback并调用。

本文参与 腾讯云自媒体分享计划,分享自微信公众号。
原始发表:2020-07-14,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 Java艺术 微信公众号,前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体分享计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
相关产品与服务
容器服务
腾讯云容器服务(Tencent Kubernetes Engine, TKE)基于原生 kubernetes 提供以容器为核心的、高度可扩展的高性能容器管理服务,覆盖 Serverless、边缘计算、分布式云等多种业务部署场景,业内首创单个集群兼容多种计算节点的容器资源管理模式。同时产品作为云原生 Finops 领先布道者,主导开源项目Crane,全面助力客户实现资源优化、成本控制。
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档