Soul网关-day17

Soul网关-hystrix插件（三）

今天正式开始读hystrix的源码，昨天大概复现了熔断，同时发现在Soul-admin控制台处设置的一个参数：ErrorThresholdPercentage和hystrix熔断复现有很大关系，这个数设置的越小，就越容易熔断。

言归正传，昨天分析控制台日志的时候，就大概可以看到我们解析Hystrix插件的抓手：

2021-02-04 22:25:26.420  INFO 13528 --- [work-threads-10] o.d.soul.plugin.base.AbstractSoulPlugin  : hystrix selector success match , selector name :hystrix_test
2021-02-04 22:25:26.420  INFO 13528 --- [work-threads-10] o.d.soul.plugin.base.AbstractSoulPlugin  : hystrix rule success match , rule name :hystrix_test

可以看到AbstractSoulPlugin，这个印象中之前也有读到过它的源码。应该是Soul插件体系的核心所在，下面来看看AbstractSoulPlugin里面究竟有些什么东西：

public abstract class AbstractSoulPlugin implements SoulPlugin

可以看到AbstractSoulPlugin继承了SoulPlugin，SoulPlugin中只有四个比较抽象的方法，分别是

Mono execute(ServerWebExchange exchange, SoulPluginChain chain);
int getOrder();
default String named() { return “”; }
default Boolean skip(ServerWebExchange exchange) { return false; }

而AbstractSoulPlugin仅仅实现了execute()方法；

应该是execute()方法比较通用，所以把execute的实现提升到了abstract层，这样就不用在每个子类中再去实现execute()方法。

同时AbstractSoulPlugin还对SoulPlugin进行了扩充，主要有对于空Selector或者空Rule的处理，以及过滤Selector以及Rule的方法，最后就是打印日志的方法。

今天先解读下最基础的execute方法：

首先看猫大人对于这个execute的注释：

     * Process the Web request and (optionally) delegate to the next* {@code SoulPlugin} through the given {@link SoulPluginChain}.

处理web请求，并 选择性 的根据配置好的PluginChain进行链式代理（一个Plugin将处理好的请求传递给另一个Plugin）。
我就直接在源码上做简单的注解了。

    @Overridepublic Mono<Void> execute(final ServerWebExchange exchange, final SoulPluginChain chain) {//获取当前插件的名称String pluginName = named();//这里有一个PLUGIN_MAP的数据结构，应该是存我们激活的插件的信息的final PluginData pluginData = BaseDataCache.getInstance().obtainPluginData(pluginName);//判断插件是否被激活if (pluginData != null && pluginData.getEnabled()) {//在有插件的基础上查找插件对应注册了的Selectorfinal Collection<SelectorData> selectors = BaseDataCache.getInstance().obtainSelectorData(pluginName);if (CollectionUtils.isEmpty(selectors)) {//对空Selector的处理，并直接返回return handleSelectorIsNull(pluginName, exchange, chain);}//通过exchange从Selector集合中选择匹配的Selectorfinal SelectorData selectorData = matchSelector(exchange, selectors);if (Objects.isNull(selectorData)) {//对空的Selector进行处理return handleSelectorIsNull(pluginName, exchange, chain);}//日志selectorLog(selectorData, pluginName);//获取selector对应的rulefinal List<RuleData> rules = BaseDataCache.getInstance().obtainRuleData(selectorData.getId());if (CollectionUtils.isEmpty(rules)) {return handleRuleIsNull(pluginName, exchange, chain);}RuleData rule;//这根据配置选择rule，并对空rule进行提前的处理，并返回。if (selectorData.getType() == SelectorTypeEnum.FULL_FLOW.getCode()) {//get lastrule = rules.get(rules.size() - 1);} else {rule = matchRule(exchange, rules);}if (Objects.isNull(rule)) {return handleRuleIsNull(pluginName, exchange, chain);}ruleLog(rule, pluginName);//这里用了doExecute，一般用这个名字的都是真正干事的。//这个方法由子类自行实现return doExecute(exchange, chain, selectorData, rule);}//调用和插件链的下一个插件return chain.execute(exchange);}

顺带一提，这个execute方法在Soul中有几个相同的命名，这个execute方法实在SoulPluginChain的子类中被调用的【Soul默认的子类是DefaultSoulPluginChain】，这里应该也是一个Soul有关的拓展点。