Sentinel之sentinel-dubbo-adapter适配器源码分析

一、简介

sentinel-dubbo-adapter模块是sentinel与dubbo的一个适配模块,dubbo项目可以引入以下依赖:

<dependency>
    <groupId>com.alibaba.csp</groupId>
    <artifactId>sentinel-dubbo-adapter</artifactId>
    <version>1.3.0-GA</version>
</dependency>

注意:项目若需要接入dashboard只引入这个依赖是不够的,还需要引入一个transport依赖,这里以simple-http为例:

  <dependency>
        <groupId>com.alibaba.csp</groupId>
        <artifactId>sentinel-transport-simple-http</artifactId>
        <version>1.3.0-GA</version>
  </dependency>

原理

通过扩展dubbo的Filter,在自定义Filter中实现对资源的保护。

二、源码分析

包结构

如图所示

sentinel-dubbo-adaper

分析

1、DubboFallback是个回调接口,在发送BlockException异常时会调用。

2、DefaultDubboFallback是DubboFallback接口的实现类,可以发现调用该接口时会抛出SentinelRpcException异常。dubbo应用若捕获到这个异常说明资源是被保护了。
3、DubboFallbackRegistry是一个DubboFallback接口的注册器,其中注册了consumerFallback和providerFallback;

DubboFallbackRegistry

4、AbstractDubboFilter
AbstractDubboFilter是一个抽象类。

image.png

只提供了一个受保护的方法,用来获取资源的名称。
资源名称=interfaceName:methodName(clazzName,clazzName)

5、DubboAppContextFilter
源码如图:

image.png
可以发现:
  • 该filter是默认激活的且针对消费者的
  • 注释的解释可以发现,该Filter的作用是把当前消费者应用名称设置到每一个调用上下文中
  • 应用名称设置到invocation的attachment的dubboApplication中。
那么为什么要需要这个呢?
  • 在RPC调用时,dubbo消费者并没有提供应用程序名称给提供方
  • 如果消费者不使用该适配器但是又需要基于调用者进行流量控制,开发者可以手动把应用程序的attachment的应用名称设置为“dubboApplication”
  • 有了消费者的应用名称后,可以对某一个调用者进行流程控制,如果这里没有配置的话,默认就是全部调用者。

6、DubboUtils
这个类就是获取DubboAppContextFilter类设置消费者名称了。

7、dubbo/com.alibaba.dubbo.rpc.Filter

image.png

这里把自定义的Filter添加到指定的文件中,通过dubbo的SPI扩展机制可以加载这些扩展的Filter,想了解dubbo的SPI扩展机制可以网上找下资料。

8、SentinelDubboConsumerFilter
直接看源码:

image.png

这里需要注意Tracer.trace方法:

image.png

后续回调用ClusterNode的trace方法,方法中会调用父类的increaseExceptionQps增加异常次数。

image.png

rollingCounterInsecond和rollingCounterInMinute是两个不同时间窗口,sentinel指标的统计就是根据滑动时间窗口统计的,关于指标时间窗口,后续有文章介绍,见:滑动时间窗口
9、SentinelDubboProviderFilter
与SentinelDubboConsumerFilter的处理逻辑类似,但是这个是提供方的Filter。

其他

1、如果我们引入这个dubbo适配module,但是不想这个sentinel保护被激活,可以通过下面方式禁用:

<dubbo:consumer filter="-sentinel.dubbo.consumer.filter"/>

<dubbo:provider filter="-sentinel.dubbo.provider.filter"/>

三、我的小结

1、dubbo项目接入sentinel只需要引入该模块jar包即可,但是若需要接入到dashboard还需要引入一个transport依赖。
2、通过介绍的sentinel-dubbo-adapter模块的源码,可以发现:dubbo接口资源的原理就是通过dubbo的扩展机制对提供端和消费端进行资源的保护
3、资源保护的核心源码,这里没有介绍,主要因为涉及是sentinel的底层核心,这里后续需要大量篇幅介绍。


谢谢阅读我的这篇文章,文中如有不当之处,请指正。

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 135,473评论 19 139
  • dubbo.xsd 文件说明 当我们要使用Dubbo进行 配置时,需要像下面那样引入dubbo.xsd这个文件. ...
    Mis_Gtw阅读 4,736评论 0 1
  • 0 准备 安装注册中心:Zookeeper、Dubbox自带的dubbo-registry-simple;安装Du...
    七寸知架构阅读 14,734评论 0 88
  • 有时候突然地想起一些片段 内心真的是崩溃的 有的习惯真的是改不了的 特别是我这样执着的人
    小挪阅读 1,222评论 0 0
  • 思路 要求小于O(n^2)的复杂度,又不能修改,目测就是O(nlogn)的复杂度,所以想到可能是用二分搜索。但是数...
    yangqi916阅读 1,651评论 0 0