Dubbo源码(六)-服务路由

前言

本文基于Dubbo2.6.x版本,中文注释版源码已上传github:xiaoguyu/dubbo

今天,来聊点短的,服务路由 Router,本文讲的是路由的调用路径,不讲路由的规则解析。想了解规则解析的可以去官方文档:服务路由

Dubbo的路由,就是根据规则,规定了哪些服务消费者可调用哪些服务提供者。

怎么用

我们可以在服务治理控制台Dubbo-Admin写入路由规则。

安装Dubbo-Admin

我是使用docker方式安装的,命令如下:

docker run -d \
-p 9001:8080 \
-e admin.root.user.name=admin \
-e admin.root.user.password=admin \
-e admin.registry.address='zookeeper://127.0.0.1:2181' \
-e admin.config-center='zookeeper://127.0.0.1:2181' \
-e admin.metadata-report.address='zookeeper://127.0.0.1:2181' \
--name dubbo-admin  \
apache/dubbo-admin

-e部分的参数说明,看官方介绍Dubbo Admin配置说明

配置规则

浏览器localhost:9001访问Dubbo-Admin控制台,菜单选择 服务治理→条件路由

Dubbo源码(六)-服务路由

点击创建按钮,填写相关参数即可

Dubbo源码(六)-服务路由

详细参数请参考官方文档:路由规则用法示例

源码

先来看看类图

Dubbo源码(六)-服务路由

Router就是路由接口,其有3个实现类。

Router接口有3个方法:

  1. URL getUrl();
  2. List 路由的选择方法,筛选出符合条件的invoker
  3. int getPriority(); 获取优先级,用于排序

订阅

当在Dubbo-Admin中配置了路由规则,会在注册中心的routes节点创建子节点,这里就包含了路由配置的数据

Dubbo源码(六)-服务路由

上一篇文章讲服务目录的时候,说过 RegistryDirectory会订阅providers、consumers、configurators、routers等节点的,这里面就包含了routers

具体的转换逻辑在 RegistryDirectory#toRouters方法中

private List toRouters(List urls) {
    List routers = new ArrayList();
    if (urls == null || urls.isEmpty()) {
        return routers;
    }
    if (urls != null && !urls.isEmpty()) {
        for (URL url : urls) {
            if (Constants.EMPTY_PROTOCOL.equals(url.getProtocol())) {
                continue;
            }
            String routerType = url.getParameter(Constants.ROUTER_KEY);
            if (routerType != null && routerType.length() > 0) {
                url = url.setProtocol(routerType);
            }
            try {
                // 工厂生成route
                Router router = routerFactory.getRouter(url);
                if (!routers.contains(router))
                    routers.add(router);
            } catch (Throwable t) {
                logger.error("convert router url to router error, url: " + url, t);
            }
        }
    }
    return routers;
}

routerFactory是自适应拓展类,此处我们设置的是条件路由,所以routerFactory实际上是 ConditionRouterFactory

public class ConditionRouterFactory implements RouterFactory {

    public static final String NAME = "condition";

    @Override
    public Router getRouter(URL url) {
        return new ConditionRouter(url);
    }

}

这个route工厂也很简单,就是创建了一个ConditionRouter,具体的解析逻辑都在其构造方法中。

规则过滤

路由的核心,就是 Router接口的route方法,那么route方法在哪里被引用呢

Dubbo源码(六)-服务路由
Dubbo源码(六)-服务路由

总结

本文讲了服务路由的数据获取以及调用过程。路由的核心就是筛选invoker

参考资料

Dubbo开发指南

Original: https://www.cnblogs.com/konghuanxi/p/16549554.html
Author: 王谷雨
Title: Dubbo源码(六)-服务路由

原创文章受到原创版权保护。转载请注明出处:https://www.johngo689.com/599017/

转载文章受原作者版权保护。转载请注明原作者出处!

(0)

大家都在看

  • mysql中文乱码记录

    0.中文乱码 1.查看mysql中表结构 show create table log_data charset为utf8,代码端:通过gorm修改 在创建表时候修改( 这里在连接数…

    数据库 2023年5月24日
    093
  • Java 考试系统项目源码 springboot mybaits vue.js 支持手机端考试

    新增功能:培训学习模块, PDF电子课程、视频课程、直播课程(自己搭建直播流服务器) 人脸识别(考试时验证,有开关)、补考开关 组建试卷:创建试卷,题目、类型、总分、及格分数、时长…

    数据库 2023年6月6日
    082
  • SQL与数据库编程学习笔记-day2

    SQL与数据库编程学习笔记-day2 修改数据库密码; – 登出数据库(修改数据库密码必须在数据库外执行命令); * – Ps:登出命令:quit* 操作完…

    数据库 2023年5月24日
    075
  • 使用docker实现mysql 8.0主从复制

    使用docker实现mysql 8.0主从复制 1.首先运行 docker pull mysql8.0 拉取镜像 docker pull mysql8.0 2.运行 docker …

    数据库 2023年6月16日
    086
  • Redis概述及基本数据结构

    Redis 是一个基于内存的键值型 NoSQL 数据库 特征: 键值型:value 支持多种不同数据类型,功能丰富 单线程:每个命令具备原子性 延迟低、速度快: 基于内存、IO多路…

    数据库 2023年6月16日
    075
  • tomcat线程池

    tomcat线程池和普通的线程池设计上有所区别,下面主要来看看它是如何设计的 tomcat中线程池的创建 <span>org.apache.tomcat.util.ne…

    数据库 2023年6月16日
    088
  • 使用mybatis连接数据库–针对小白

    实现mybatis连接数据库的步骤: 1.建表 2.pom.xml的配置 <?xml version="1.0" encoding="UTF-8…

    数据库 2023年6月11日
    061
  • Java学习-第一部分-第二阶段-第八节:IO流

    IO流 笔记目录:(https://www.cnblogs.com/wenjie2000/p/16378441.html) IO流体系图 文件 什么是文件 文件.对我们并不陌生,文…

    数据库 2023年6月11日
    094
  • MYSQL(进阶篇)——一篇文章带你深入掌握MYSQL

    MYSQL(进阶篇)——一篇文章带你深入掌握MYSQL 我们在上篇文章中已经学习了MYSQL的基本语法和概念 在这篇文章中我们将讲解底层结构和一些新的语法帮助你更好的运用MYSQL…

    数据库 2023年6月14日
    099
  • 计算机操作系统(慕课版)思维导图

    404. 抱歉,您访问的资源不存在。 可能是网址有误,或者对应的内容被删除,或者处于私有状态。 代码改变世界,联系邮箱 contact@cnblogs.com 园子的商业化努力-困…

    数据库 2023年6月16日
    099
  • 日志:Redo Log 和 Undo Log

    本篇文章主要介绍 Redo Log 和 Undo Log: 利用 Redo Log 和 Undo Log 实现本地事务的原子性、持久性 Redo Log 的写回策略 Redo Lo…

    数据库 2023年6月11日
    082
  • 数据结构知识详解 第一章 绪论

    知识框架 1. 数据结构的基本概念 1.1 基本概念和术语 1.1.1 数据 定义:是信息的载体,是描述客观事实属性的数、字符及所有能输入到计算机中并被计算机程序识别和处理的符号的…

    数据库 2023年6月11日
    079
  • mybatis collection解析以及和association的区别

    1.collection标签 说到mybatis的collection标签,我们肯定不陌生,可以通过它解决一对多的映射问题,举个例子一个用户对应多个系统权限,通过对用户表和权限表的…

    数据库 2023年6月16日
    086
  • Java编程作业

    1、编程题 设计一个用户类User,类中的变量有用户名、密码和记录用户数量的变量,定义3个构造方法:无参的、为用户名赋值的、为用户名和密码赋值的,还有获取和设置密码的方法和返回类信…

    数据库 2023年6月11日
    084
  • 5000+字硬核干货!Redis 分布式集群部署实战

    原理: Redis集群采用一致性哈希槽的方式将集群中每个主节点都分配一定的哈希槽,对写入的数据进行哈希后分配到某个主节点进行存储。 集群使用公式(CRC16 key)& 1…

    数据库 2023年6月9日
    096
  • Linux 利用Cgroup 资源控制

    GreatSQL社区原创内容未经授权不得随意使用,转载请联系小编并注明来源。 GreatSQL是MySQL的国产分支版本,使用上与MySQL一致。 cgroups 是Linux内核…

    数据库 2023年5月24日
    0119
亲爱的 Coder【最近整理,可免费获取】👉 最新必读书单  | 👏 面试题下载  | 🌎 免费的AI知识星球