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

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

news 2026/1/27 23:15:49

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

Java 8 Stream API 入门到实践详解

一、告别 for 循环&#xff01; 传统痛点&#xff1a; Java 8 之前&#xff0c;集合操作离不开冗长的 for 循环和匿名类。例如&#xff0c;过滤列表中的偶数&#xff1a; List<Integer> list Arrays.asList(1, 2, 3, 4, 5); List<Integer> evens new ArrayList…...

编程新知 2026/1/12 10:41:22

鸿蒙中用HarmonyOS SDK应用服务 HarmonyOS5开发一个医院挂号小程序

一、开发准备 ​​环境搭建​​&#xff1a; 安装DevEco Studio 3.0或更高版本配置HarmonyOS SDK申请开发者账号 ​​项目创建​​&#xff1a; File > New > Create Project > Application (选择"Empty Ability") 二、核心功能实现 1. 医院科室展示 /…...

编程新知 2025/9/5 12:16:40

GitHub 趋势日报 (2025年06月08日)

&#x1f4ca; 由 TrendForge 系统生成 | &#x1f310; https://trendforge.devlive.org/ &#x1f310; 本日报中的项目描述已自动翻译为中文 &#x1f4c8; 今日获星趋势图 今日获星趋势图 884 cognee 566 dify 414 HumanSystemOptimization 414 omni-tools 321 note-gen …...

编程新知 2025/12/13 1:32:15

全志A40i android7.1 调试信息打印串口由uart0改为uart3

一&#xff0c;概述 1. 目的 将调试信息打印串口由uart0改为uart3。 2. 版本信息 Uboot版本&#xff1a;2014.07&#xff1b; Kernel版本&#xff1a;Linux-3.10&#xff1b; 二&#xff0c;Uboot 1. sys_config.fex改动 使能uart3(TX:PH00 RX:PH01)&#xff0c;并让boo…...

编程新知 2026/1/26 18:06:21

Android第十三次面试总结（四大 组件基础）

Activity生命周期和四大启动模式详解 一、Activity 生命周期 Activity 的生命周期由一系列回调方法组成&#xff0c;用于管理其创建、可见性、焦点和销毁过程。以下是核心方法及其调用时机&#xff1a; ​onCreate()​​ ​调用时机​&#xff1a;Activity 首次创建时调用。​…...

编程新知 2025/10/15 15:07:34

Hive 存储格式深度解析：从 TextFile 到 ORC，如何选对数据存储方案？

在大数据处理领域&#xff0c;Hive 作为 Hadoop 生态中重要的数据仓库工具&#xff0c;其存储格式的选择直接影响数据存储成本、查询效率和计算资源消耗。面对 TextFile、SequenceFile、Parquet、RCFile、ORC 等多种存储格式&#xff0c;很多开发者常常陷入选择困境。本文将从底…...

编程新知 2025/12/6 10:54:35

【java面试】微服务篇

【java面试】微服务篇 一、总体框架二、Springcloud&#xff08;一&#xff09;Springcloud五大组件&#xff08;二&#xff09;服务注册和发现1、Eureka2、Nacos &#xff08;三&#xff09;负载均衡1、Ribbon负载均衡流程2、Ribbon负载均衡策略3、自定义负载均衡策略4、总结 …...

编程新知 2026/1/26 19:23:29

FOPLP vs CoWoS

以下是 FOPLP&#xff08;Fan-out panel-level packaging 扇出型面板级封装&#xff09;与 CoWoS&#xff08;Chip on Wafer on Substrate&#xff09;两种先进封装技术的详细对比分析&#xff0c;涵盖技术原理、性能、成本、应用场景及市场趋势等维度&#xff1a; 一、技术原…...

编程新知 2025/10/24 6:08:42

JavaScript 标签加载

目录 JavaScript 标签加载script 标签的 async 和 defer 属性&#xff0c;分别代表什么&#xff0c;有什么区别1. 普通 script 标签2. async 属性3. defer 属性4. type"module"5. 各种加载方式的对比6. 使用建议 JavaScript 标签加载 script 标签的 async 和 defer …...

编程新知 2025/10/2 20:58:12

[QMT量化交易小白入门]-六十二、ETF轮动中简单的评分算法如何获取历史年化收益32.7%

本专栏主要是介绍QMT的基础用法，常见函数，写策略的方法，也会分享一些量化交易的思路，大概会写100篇左右。 QMT的相关资料较少，在使用过程中不断的摸索，遇到了一些问题，记录下来和大家一起沟通，共同进步。 文章目录 相关阅读1. 策略概述2. 趋势评分模块3 代码解析4 木头…...

编程新知 2025/9/15 21:14:31