一、简介
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中实现对资源的保护。
二、源码分析
包结构
如图所示
分析
1、DubboFallback是个回调接口,在发送BlockException异常时会调用。
2、DefaultDubboFallback是DubboFallback接口的实现类,可以发现调用该接口时会抛出SentinelRpcException异常。dubbo应用若捕获到这个异常说明资源是被保护了。
3、DubboFallbackRegistry是一个DubboFallback接口的注册器,其中注册了consumerFallback和providerFallback;
4、AbstractDubboFilter
AbstractDubboFilter是一个抽象类。
只提供了一个受保护的方法,用来获取资源的名称。
资源名称=interfaceName:methodName(clazzName,clazzName)
5、DubboAppContextFilter
源码如图:
可以发现:
- 该filter是默认激活的且针对消费者的
- 注释的解释可以发现,该Filter的作用是把当前消费者应用名称设置到每一个调用上下文中
- 应用名称设置到invocation的attachment的dubboApplication中。
那么为什么要需要这个呢?
- 在RPC调用时,dubbo消费者并没有提供应用程序名称给提供方
- 如果消费者不使用该适配器但是又需要基于调用者进行流量控制,开发者可以手动把应用程序的attachment的应用名称设置为“dubboApplication”
- 有了消费者的应用名称后,可以对某一个调用者进行流程控制,如果这里没有配置的话,默认就是全部调用者。
6、DubboUtils
这个类就是获取DubboAppContextFilter类设置消费者名称了。
7、dubbo/com.alibaba.dubbo.rpc.Filter
这里把自定义的Filter添加到指定的文件中,通过dubbo的SPI扩展机制可以加载这些扩展的Filter,想了解dubbo的SPI扩展机制可以网上找下资料。
8、SentinelDubboConsumerFilter
直接看源码:
这里需要注意Tracer.trace方法:
后续回调用ClusterNode的trace方法,方法中会调用父类的increaseExceptionQps增加异常次数。
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的底层核心,这里后续需要大量篇幅介绍。
谢谢阅读我的这篇文章,文中如有不当之处,请指正。