Dubbo 路由机制的实现

dubbo 路由机制是在服务间的调用时，通过将服务提供者按照设定的路由规则来决定调用哪一个具体的服务。

路由服务结构

dubbo 实现路由都是通过实现 routerfactory 接口。当前版本 dubbo-2.7.5 实现该接口类如下：

路由实现工厂类是在 router 包下

由于 routerfactory 是 spi 接口，同时在获取路由 routerfactory#getrouter 方法上有 @adaptive("protocol") 注解，所以在获取路由的时候会动态调用需要的工厂类。

可以看到 getrouter 方法返回的是一个 router 接口，该接口信息如下

其中 router#route 是服务路由的入口，对于不同类型的路由工厂，有特定的 router 实现类。

以上就是通过解析 url，获取到具体的 router，通过调用 router#router 过滤出符合当前路由规则的 invokers。

服务路由实现

上面展示了路由实现类，这几个实现类型中，conditionrouter 条件路由是最为常用的类型，由于文章篇幅有限，本文就不对全部的路由类型逐一分析，只对条件路由进行具体分析，只要弄懂这一个类型，其它类型的解析就能容易掌握。

条件路由参数规则

在分析条件路由前，先了解条件路由的参数配置，官方文档如下：

条件路由规则内容如下：

条件路由实现分析

分析路由实现，主要分析工厂类的 xxxrouterfactory#getrouter 和 xxxrouter#route 方法。

conditionrouterfactory#getrouter

conditionrouterfactory 中通过创建 conditionrouter 对象来初始化解析相关参数配置。

在 conditionrouter 构造函数中，从 url 里获取 rule 的字符串格式的规则，解析规则在 conditionrouter#init 初始化方法中。

public void init(string rule) {
    try {
        if (rule == null || rule.trim().length() == 0) {
            throw new illegalargumentexception("illegal route rule!");
        }
        // 去掉 consumer. 和 provider. 的标识
        rule = rule.replace("consumer.", "").replace("provider.", "");
        // 获取 消费者匹配条件 和 提供者地址匹配条件 的分隔符
        int i = rule.indexof("=>");
        // 消费者匹配条件
        string whenrule = i < 0 ? null : rule.substring(0, i).trim();
        // 提供者地址匹配条件
        string thenrule = i < 0 ? rule.trim() : rule.substring(i + 2).trim();
        // 解析消费者路由规则
        map<string, matchpair> when = stringutils.isblank(whenrule) || "true".equals(whenrule) ? new hashmap<string, matchpair>() : parserule(whenrule);
        // 解析提供者路由规则
        map<string, matchpair> then = stringutils.isblank(thenrule) || "false".equals(thenrule) ? null : parserule(thenrule);
        // note: it should be determined on the business level whether the `when condition` can be empty or not.
        this.whencondition = when;
        this.thencondition = then;
    } catch (parseexception e) {
        throw new illegalstateexception(e.getmessage(), e);
    }
}

以路由规则字符串中的=>为分隔符，将消费者匹配条件和提供者匹配条件分割，解析两个路由规则后，赋值给当前对象的变量。

调用 parserule 方法来解析消费者和服务者路由规则。

// 正则验证路由规则
protected static final pattern route_pattern = pattern.compile("([&!=,]*)\\s*([^&!=,\\s]+)");


private static map<string, matchpair> parserule(string rule)
        throws parseexception {
    /**
     * 条件变量和条件变量值的映射关系
     * 比如 host => 127.0.0.1 则保存着 host 和 127.0.0.1 的映射关系
    */
    map<string, matchpair> condition = new hashmap<string, matchpair>();
    if (stringutils.isblank(rule)) {
        return condition;
    }
    // key-value pair, stores both match and mismatch conditions
    matchpair pair = null;
    // multiple values
    set<string> values = null;
    final matcher matcher = route_pattern.matcher(rule);
    while (matcher.find()) { 
        // 获取正则前部分匹配（第一个括号）的内容
        string separator = matcher.group(1);
        // 获取正则后部分匹配（第二个括号）的内容
        string content = matcher.group(2);
        // 如果获取前部分为空，则表示规则开始位置，则当前 content 必为条件变量
        if (stringutils.isempty(separator)) {
            pair = new matchpair();
            condition.put(content, pair);
        }
        // 如果分隔符是 &,则 content 为条件变量
        else if ("&".equals(separator)) {
            // 当前 content 是条件变量，用来做映射集合的 key 的，如果没有则添加一个元素
            if (condition.get(content) == null) {
                pair = new matchpair();
                condition.put(content, pair);
            } else {
                pair = condition.get(content);
            }
        }
        // 如果当前分割符是 = ，则当前 content 为条件变量值
        else if ("=".equals(separator)) {
            if (pair == null) {
                throw new parseexception("illegal route rule \""
                        + rule + "\", the error char '" + separator
                        + "' at index " + matcher.start() + " before \""
                        + content + "\".", matcher.start());
            }
            // 由于 pair 还没有被重新初始化，所以还是上一个条件变量的对象，所以可以将当前条件变量值在引用对象上赋值
            values = pair.matches;
            values.add(content);
        }
        // 如果当前分割符是 = ，则当前 content 也是条件变量值
        else if ("!=".equals(separator)) {
            if (pair == null) {
                throw new parseexception("illegal route rule \""
                        + rule + "\", the error char '" + separator
                        + "' at index " + matcher.start() + " before \""
                        + content + "\".", matcher.start());
            }
            // 与 = 时同理
            values = pair.mismatches;
            values.add(content);
        }
        // 如果当前分割符为 ','，则当前 content 也为条件变量值
        else if (",".equals(separator)) { // should be separated by ','
            if (values == null || values.isempty()) {
                throw new parseexception("illegal route rule \""
                        + rule + "\", the error char '" + separator
                        + "' at index " + matcher.start() + " before \""
                        + content + "\".", matcher.start());
            }
            // 直接向条件变量值集合中添加数据
            values.add(content);
        } else {
            throw new parseexception("illegal route rule \"" + rule
                    + "\", the error char '" + separator + "' at index "
                    + matcher.start() + " before \"" + content + "\".", matcher.start());
        }
    }
    return condition;
}

上面就是解析条件路由规则的过程，条件变量的值都保存在 matchpair 中的 matches、mismatches 属性中，=和,的条件变量值放在可以匹配的 matches 中，!=的条件变量值放在不可匹配路由规则的 mismatches 中。赋值过程中，代码还是比较优雅。

实际上 matches、mismatches 就是保存的是条件变量值。

conditionrouter#route

router#route的作用就是匹配出符合路由规则的 invoker 集合。

// 在初始化中进行被复制的变量
// 消费者条件匹配规则
protected map<string, matchpair> whencondition;
// 提供者条件匹配规则
protected map<string, matchpair> thencondition;


public <t> list<invoker<t>> route(list<invoker<t>> invokers, url url, invocation invocation)
        throws rpcexception {
    if (!enabled) {
        return invokers;
    }
    // 验证 invokers 是否为空
    if (collectionutils.isempty(invokers)) {
        return invokers;
    }
    try {
        // 校验消费者是否有规则匹配，如果没有则返回传入的 invoker
        if (!matchwhen(url, invocation)) {
            return invokers;
        }
        list<invoker<t>> result = new arraylist<invoker<t>>();
        if (thencondition == null) {
            logger.warn("the current consumer in the service blacklist. consumer: " + netutils.getlocalhost() + ", service: " + url.getservicekey());
            return result;
        }
        // 遍历传入的 invokers，匹配提供者是否有规则匹配
        for (invoker<t> invoker : invokers) {
            if (matchthen(invoker.geturl(), url)) {
                result.add(invoker);
            }
        }
        // 如果 result 不为空，或当前对象 force=true 则返回 result 的 invoker 列表 
        if (!result.isempty()) {
            return result;
        } else if (force) {
            logger.warn("the route result is empty and force execute. consumer: " + netutils.getlocalhost() + ", service: " + url.getservicekey() + ", router: " + url.getparameteranddecoded(rule_key));
            return result;
        }
    } catch (throwable t) {
        logger.error("failed to execute condition router rule: " + geturl() + ", invokers: " + invokers + ", cause: " + t.getmessage(), t);
    }
    return invokers;
}

上面代码可以看到，只要消费者没有匹配的规则或提供者没有匹配的规则及 force=false 时，不会返回传入的参数的 invoker。

匹配消费者路由规则和提供者路由规则方法是 matchwhen 和 matchthen

这两个匹配方法都是调用同一个方法 matchcondition 实现的。将消费者或提供者 url 转为 map，然后与 whencondition 或 thencondition 进行匹配。

匹配过程中，如果 key （即 samplevalue 值）存在对应的值，则通过 matchpair#ismatch 方法再进行匹配。

private boolean ismatch(string value, url param) {
    // 存在可匹配的规则，不存在不可匹配的规则
    if (!matches.isempty() && mismatches.isempty()) {
        // 不可匹配的规则列表为空时，只要可匹配的规则匹配上，直接返回 true
        for (string match : matches) {
            if (urlutils.ismatchglobpattern(match, value, param)) {
                return true;
            }
        }
        return false;
    }
    // 存在不可匹配的规则，不存在可匹配的规则
    if (!mismatches.isempty() && matches.isempty()) {
        // 不可匹配的规则列表中存在，则返回false
        for (string mismatch : mismatches) {
            if (urlutils.ismatchglobpattern(mismatch, value, param)) {
                return false;
            }
        }
        return true;
    }
    // 存在可匹配的规则，也存在不可匹配的规则
    if (!matches.isempty() && !mismatches.isempty()) {
        // 都不为空时，不可匹配的规则列表中存在，则返回 false
        for (string mismatch : mismatches) {
            if (urlutils.ismatchglobpattern(mismatch, value, param)) {
                return false;
            }
        }
        for (string match : matches) {
            if (urlutils.ismatchglobpattern(match, value, param)) {
                return true;
            }
        }
        return false;
    }
    // 最后剩下的是 可匹配规则和不可匹配规则都为空时
    return false;
}

匹配过程再调用 urlutils#ismatchglobpattern 实现

public static boolean ismatchglobpattern(string pattern, string value, url param) {
    // 如果以 $ 开头，则获取 url 中对应的值
    if (param != null && pattern.startswith("$")) {
        pattern = param.getrawparameter(pattern.substring(1));
    }
    // 
    return ismatchglobpattern(pattern, value);
}



public static boolean ismatchglobpattern(string pattern, string value) {
    if ("*".equals(pattern)) {
        return true;
    }
    if (stringutils.isempty(pattern) && stringutils.isempty(value)) {
        return true;
    }
    if (stringutils.isempty(pattern) || stringutils.isempty(value)) {
        return false;
    }
    // 获取通配符位置
    int i = pattern.lastindexof('*');
    // 如果value中没有 "*" 通配符，则整个字符串值匹配
    if (i == -1) {
        return value.equals(pattern);
    }
    // 如果 "*" 在最后面，则匹配字符串 "*" 之前的字符串即可
    else if (i == pattern.length() - 1) {
        return value.startswith(pattern.substring(0, i));
    }
    // 如果 "*" 在最前面，则匹配字符串 "*" 之后的字符串即可
    else if (i == 0) {
        return value.endswith(pattern.substring(i + 1));
    }
    // 如果 "*" 不在字符串两端，则同时匹配字符串 "*" 左右两边的字符串
    else {
        string prefix = pattern.substring(0, i);
        string suffix = pattern.substring(i + 1);
        return value.startswith(prefix) && value.endswith(suffix);
    }
}

就这样完成全部的条件路由规则匹配，虽然看似代码较为繁杂，但是理清规则、思路，一步一步还是较好解析，前提是要熟悉相关参数的用法及形式，不然代码较难理解。

最后

单纯从逻辑上，如果能够掌握条件路由的实现，去研究其它方式的路由实现，相信不会有太大问题。只是例如像脚本路由的实现，你得先会使用脚本执行引擎为前提，不然就不理解它的代码。最后，在 dubbo-admin 上可以设置路由，大家可以尝试各种使用规则，通过实操才能更好掌握和理解路由机制的实现。

个人博客：
关注公众号 【ytao】，更多原创好文