当前位置： 首页 > news >正文

dolphinscheduler服务注册中心源码解析(三)RPC提供者服务整合注册中心注册服务实现源码

news 2026/2/8 21:06:38

RPC提供者服务整合注册中心注册服务实现源码

  • 1.概述
  • 2.源码解读思路
  • 3.实现
    • 2.1.应用服务的RPC服务接口定义
      • 2.1.1.MasterServer应用中提供的RPC接口服务
      • 2.1.2.WorkerServer应用中提供的RPC接口服务
    • 2.2.应用服务的RPC服务接口实现
      • 2.2.1.MasterServer应用中提供的RPC接口服务实现类
      • 2.2.2.WorkerServer应用中提供的RPC接口服务实现类
    • 2.3.应用服务注册到注册中心
      • 2.3.1.master应用注册到注册中心
        • 2.3.1.1.MasterServer服务启动类
        • 2.3.1.2.Master服务注册客户端MasterRegistryClient
        • 2.3.1.3.MasterConfig配置类
      • 2.3.2.worker应用注册到注册中心
        • 2.3.2.1.WorkerServer启动类
        • 2.3.2.2.Worker服务注册客户端WorkerRegistryClient
        • 2.3.2.3.WorkerConfig配置类
  • 4.总结

1.概述

上一篇文章我们就Dolphinscheduler框架中注册中心的实现源码(主要是基于Zookeeper的注册中心插件的实现)进行了讲解说明， 我们知道了注册中心服务其实对应就提供了一个RegistryClient客户端工具类，其他应用服务的项目中如果有RPC提供者服务需要注册到Zookeeper或者其他注册中心， 只需要以来注册中心的工程，然后配置注册插件对应的配置参数信息，然后在在应用服务启动之后，就可以使用RegistryClient来进行服务注册及发现了。本篇文章我们一起来看看应用服务(MasterServer/WorkerServer/AlertServer)中的RPC提供者服务注册到服务中心的整个设计实现。

2.源码解读思路

之前在RPC框架的源码解析的文章中， 我们已经解读关于单台节点上的RPC提供者服务是如何在应用服务启动时完成RPC接口实现类的扫描、注册的。

但那只是单机的环境下， 在分布式环境就需要考虑，我们在有多个应用服务，我每台服务上都有RPC提供者服务， 我应该怎么告诉订阅方， 我这里都有那些节点可以提供远程调用服务。主要的源码及业务核心流程实现如下：
在这里插入图片描述

1&#

相关文章：

dolphinscheduler服务注册中心源码解析(三)RPC提供者服务整合注册中心注册服务实现源码

RPC提供者服务整合注册中心注册服务实现源码 1.概述2.源码解读思路3.实现2.1.应用服务的RPC服务接口定义2.1.1.MasterServer应用中提供的RPC接口服务2.1.2.WorkerServer应用中提供的RPC接口服务2.2.应用服务的RPC服务接口实现2.2.1.MasterServer应用中提供的RPC接口服务实现类2…...

编程日记 2024/12/24 12:31:05

电脑不小心删除了msvcr120.dll文件怎么办？“缺失msvcr120.dll文件”要怎么解决？

一、文件丢失与损坏的常见原因及解决办法 1. 不小心删除系统文件 常见情况：有时在清理电脑垃圾文件时，可能会不小心删除一些重要的系统文件，如msvcr120.dll等。解决办法： 恢复文件：如果刚删除不久，可以尝…...

编程日记 2024/12/24 12:28:56

js 深度克隆

深度克隆（Deep Clone）是指复制一个对象或数组及其所有嵌套结构的副本，使得克隆后的对象与原对象完全独立。JavaScript 提供了一些方法实现深度克隆，但每种方法有其优缺点。 1. 常用方法 1.1 使用 JSON.parse 和 JSON.stringify …...

编程日记 2024/12/24 12:24:52

深度学习之超分辨率算法——FRCNN

– 对之前SRCNN算法的改进 输出层采用转置卷积层放大尺寸，这样可以直接将低分辨率图片输入模型中，解决了输入尺度问题。改变特征维数，使用更小的卷积核和使用更多的映射层。卷积核更小，加入了更多的激活层。共享其中的映射层&…...

编程日记 2024/12/24 12:23:51

软件测试之压力测试【详解】

压力测试 压力测试是一种软件测试，用于验证软件应用程序的稳定性和可靠性。压力测试的目标是在极其沉重的负载条件下测量软件的健壮性和错误处理能力，并确保软件在危急情况下不会崩溃。它甚至可以测试超出正常工作点的测试，并评估软件在极端…...

编程日记 2024/12/24 12:19:46

电脑出现 0x0000007f 蓝屏问题怎么办，参考以下方法尝试解决

电脑蓝屏是让许多用户头疼的问题，其中出现 “0x0000007f” 错误代码更是较为常见且棘手。了解其背后成因并掌握修复方法，能帮我们快速恢复电脑正常运行。 一、可能的硬件原因 内存问题 内存条长时间使用可能出现物理损坏，如金手指氧化、芯片…...

编程日记 2024/12/24 12:18:45

分布式系统架构：限流设计模式

1.为什么要限流？ 任何一个系统的运算、存储、网络资源都不是无限的，当系统资源不足以支撑外部超过预期的突发流量时，就应该要有取舍，建立面对超额流量自我保护的机制，而这个机制就是微服务中常说的“限流” 2.四种限流…...

编程日记 2024/12/24 12:17:44

G口带宽服务器与1G独享带宽服务器：深度剖析其差异

在数据洪流涌动的数字化时代，服务器作为数据处理的核心，其性能表现直接关系到业务的流畅度和用户体验的优劣。随着技术的飞速发展，G口带宽服务器与1G独享带宽服务器已成为众多企业的优选方案。然而，这两者之间究竟有何细微差别&am…...

编程日记 2024/12/24 12:16:42

Flamingo：少样本多模态大模型

Flamingo：少样本多模态大模型 论文大纲理解1. 确认目标2. 分析过程（目标-手段分析）3. 实现步骤4. 效果展示5. 金手指 解法拆解全流程核心模式提问Flamingo为什么选择使用"固定数量的64个视觉tokens"这个特定数字?这个数字的选择背…...

编程日记 2024/12/24 12:15:38

推荐一款免费且好用的 国产 NAS 系统 ——FnOS

一、系统基础信息 开发基础：基于最新的Linux内核（Debian发行版）深度开发，兼容主流x86硬件（ARM还没适配），自由组装NAS，灵活扩展外部存储。 使用情况：官方支持功能较多&am…...

编程日记 2024/12/24 12:13:35

2025系统架构师（一考就过）：案例题之一：嵌入式架构、大数据架构、ISA

一、嵌入式系统架构 软件脆弱性是软件中存在的弱点(或缺陷)，利用它可以危害系统安全策略，导致信息丢失、系统价值和可用性降低。嵌入式系统软件架构通常采用分层架构，它可以将问题分解为一系列相对独立的子问题，局部化在每一层中…...

编程日记 2024/12/24 12:11:33

开机存活脚本

vim datastadard_alive.sh #!/bin/bashPORT18086 # 替换为你想要检查的端口号 dt$(date %Y-%m-%d)# 使用netstat检查端口是否存在 if netstat -tuln | grep -q ":$PORT"; thenecho "$dt Port $PORT is in use" > /opt/datastadard/logs/alive.log# 如…...

编程日记 2024/12/24 12:10:32

车载网关性能 --- GW ECU报文（message）处理机制的技术解析

我是穿拖鞋的汉子，魔都中坚持长期主义的汽车电子工程师。 老规矩，分享一段喜欢的文字，避免自己成为高知识低文化的工程师： 所谓鸡汤，要么蛊惑你认命，要么怂恿你拼命，但都是回避问题的根源，以现象替代逻辑，以情绪代替思考，把消极接受现实的懦弱，伪装成乐观面对不幸的…...

编程日记 2024/12/24 12:07:29

CosyVoice安装过程详解

CosyVoice安装过程详解 安装过程参考官方文档 前情提要 环境：Windows子系统WSL下安装的Ubunt22.4python环境管理：MiniConda3git 1. Clone代码 $ git clone --recursive https://github.com/FunAudioLLM/CosyVoice.git # 若是submodule下载失败&…...

编程日记 2024/12/24 12:04:26

传统网络架构与SDN架构对比

传统网络采用分布式控制，每台设备独立控制且管理耗时耗力，扩展困难，按 OSI 模型分层，成本高、业务部署慢、安全性欠佳且开放性不足。而 SDN 架构将控制平面集中到控制器，数据转发由交换机负责，可统一管理提…...

编程日记 2024/12/24 12:03:25

如何打造用户友好的维护页面：6个创意提升WordPress网站体验

在网站运营中，无论是个人博主还是大型企业网站的管理员，难免会遇到需要维护的情况。无论是服务器迁移、插件更新，还是突发的技术故障，都可能导致网站短暂无法访问。这时，设计维护页面能很好的缓解用户的不满&#xff0…...

编程日记 2024/12/24 11:58:12

【hackmyvm】Zday靶机wp

HMVrbash绕过no_root_squash静态编译fogproject 1. 基本信息^toc 这里写目录标题 1. 基本信息^toc2. 信息收集2.1. 端口扫描2.2. 目录扫描 3. fog project Rce3.1. ssh绕过限制 4. NFS no_root_squash5. bash运行不了怎么办 靶机链接 https://hackmyvm.eu/machines/machine.ph…...

编程日记 2024/12/24 11:57:09

redis使用注意哪些事项

1. 数据类型选择： • Redis支持多种数据类型，如字符串（String）、哈希（Hash）、列表（List）、集合（Set）、有序集合（Sorted Set）等。在选择…...

编程日记 2024/12/24 11:53:03

步进电机位置速度双环控制实现

步进电机位置速度双环控制实现 野火stm32电机教学 提高部分-第11讲 步进电机位置速度双环控制实现(1)_哔哩哔哩_bilibili PID模型 位置环作为外环，速度环作为内环。设定目标位置和实际转轴位置的位置偏差，经过位置PID获得位置期望，然后讲位置期望（位置变化反映了转轴的速…...

编程日记 2024/12/24 11:47:45

优化程序中的数据：从数组到代数

前言 我们往往都希望优化我们的程序，使之达到一个更好的效果，程序优化的一个重点就是速度，加快速度的一个好办法就是使用并行技术，但是，并行时我们要考虑必须串行执行的任务，也就是有依赖关系的任务&#…...

编程日记 2024/12/24 11:46:42

SpringBoot-17-MyBatis动态SQL标签之常用标签

文章目录 1 代码1.1 实体User.java1.2 接口UserMapper.java1.3 映射UserMapper.xml1.3.1 标签if1.3.2 标签if和where1.3.3 标签choose和when和otherwise1.4 UserController.java2 常用动态SQL标签2.1 标签set2.1.1 UserMapper.java2.1.2 UserMapper.xml2.1.3 UserController.ja…...

编程新知 2026/2/7 23:18:39

龙虎榜——20250610

上证指数放量收阴线，个股多数下跌，盘中受消息影响大幅波动。 深证指数放量收阴线形成顶分型，指数短线有调整的需求，大概需要一两天。 2025年6月10日龙虎榜行业方向分析 1. 金融科技 代表标的：御银股份、雄帝科技 驱动…...

编程新知 2026/2/8 15:03:06

从WWDC看苹果产品发展的规律

WWDC 是苹果公司一年一度面向全球开发者的盛会，其主题演讲展现了苹果在产品设计、技术路线、用户体验和生态系统构建上的核心理念与演进脉络。我们借助 ChatGPT Deep Research 工具，对过去十年 WWDC 主题演讲内容进行了系统化分析，形成了这份…...

编程新知 2026/2/2 21:52:33

前端导出带有合并单元格的列表

// 导出async function exportExcel(fileName "共识调整.xlsx") {// 所有数据const exportData await getAllMainData();// 表头内容let fitstTitleList [];const secondTitleList [];allColumns.value.forEach(column > {if (!column.children) {fitstTitleL…...

编程新知 2026/1/25 3:21:09

C++ 基础特性深度解析

目录 引言 一、命名空间（namespace） C 中的命名空间​ 与 C 语言的对比​ 二、缺省参数​ C 中的缺省参数​ 与 C 语言的对比​ 三、引用（reference）​ C 中的引用​ 与 C 语言的对比​ 四、inline（内联函数…...

编程新知 2026/1/15 4:25:16

Device Mapper 机制

Device Mapper 机制详解 Device Mapper（简称 DM）是 Linux 内核中的一套通用块设备映射框架，为 LVM、加密磁盘、RAID 等提供底层支持。本文将详细介绍 Device Mapper 的原理、实现、内核配置、常用工具、操作测试流程，并配以详细的…...

编程新知 2025/12/14 13:11:33

uniapp 开发ios， xcode 提交app store connect 和 testflight内测

uniapp 中配置 配置manifest 文档：manifest.json 应用配置 | uni-app官网 hbuilderx中本地打包 下载IOS最新SDK 开发环境 | uni小程序SDK hbulderx 版本号：4.66 对应的sdk版本 4.66 两者必须一致 本地打包的资源导入到SDK 导入资源 | uni小程序SDK …...

编程新知 2026/1/31 8:35:07

stm32wle5 lpuart DMA数据不接收

配置波特率9600时，需要使用外部低速晶振...

编程新知 2026/2/4 16:29:27

上位机开发过程中的设计模式体会(1)：工厂方法模式、单例模式和生成器模式

简介 在我的 QT/C 开发工作中，合理运用设计模式极大地提高了代码的可维护性和可扩展性。本文将分享我在实际项目中应用的三种创造型模式：工厂方法模式、单例模式和生成器模式。 1. 工厂模式 (Factory Pattern) 应用场景 在我的 QT 项目中曾经有一个需…...

编程新知 2025/8/18 3:01:22

热烈祝贺埃文科技正式加入可信数据空间发展联盟

2025年4月29日，在福州举办的第八届数字中国建设峰会“可信数据空间分论坛”上，可信数据空间发展联盟正式宣告成立。国家数据局党组书记、局长刘烈宏出席并致辞，强调该联盟是推进全国一体化数据市场建设的关键抓手。 郑州埃文科技有限公司&am…...

编程新知 2026/2/7 20:23:55