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

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

news 2026/4/12 11:45:11

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

T样条在汽车结构设计中的几何参数化重构与应用

1. T样条技术：汽车设计的几何革命 想象一下，你手里拿着一块橡皮泥，可以随意捏出任何想要的形状——这就是T样条在汽车设计中的魔力。这种先进的几何建模技术正在彻底改变工程师们设计B柱、侧围板等复杂结构的方式。与传统的NURBS&#xff08…...

编程新知 2026/4/12 11:33:36

3分钟免费解锁Spotify高级功能：Windows用户必备的广告拦截方案

3分钟免费解锁Spotify高级功能：Windows用户必备的广告拦截方案 【免费下载链接】BlockTheSpot Video, audio & banner adblock/skip for Spotify 项目地址: https://gitcode.com/gh_mirrors/bl/BlockTheSpot 你是否厌倦了在享受音乐时被突如其来的广告打…...

编程新知 2026/4/12 11:31:25

WarcraftHelper：魔兽争霸3免费优化插件完整指南与配置教程

WarcraftHelper：魔兽争霸3免费优化插件完整指南与配置教程 【免费下载链接】WarcraftHelper Warcraft III Helper , support 1.20e, 1.24e, 1.26a, 1.27a, 1.27b 项目地址: https://gitcode.com/gh_mirrors/wa/WarcraftHelper 还在为魔兽争霸3在现代电脑上频…...

编程新知 2026/4/12 11:17:22

GoldHEN Cheats Manager：PS4游戏修改功能的一站式解决方案

GoldHEN Cheats Manager：PS4游戏修改功能的一站式解决方案 【免费下载链接】GoldHEN_Cheat_Manager GoldHEN Cheats Manager 项目地址: https://gitcode.com/gh_mirrors/go/GoldHEN_Cheat_Manager 在PlayStation 4的定制化游戏体验领域，GoldHEN C…...

编程新知 2026/4/12 11:17:22

本地验证：构建、单元测试与集成测试的自动化执行策略

本地验证：构建、单元测试与集成测试的自动化执行策略 从一次深夜调试说起 上周排查一个内存泄漏问题，花了两小时才发现是单元测试根本没跑起来——CMakeLists里add_test写错了目录路径，但本地make test居然返回了成功。这种“假绿灯”比编译失败更可怕，代码合进主线后CI才…...

编程新知 2026/4/12 10:47:08

抖音下载器技术方案：双引擎策略架构与高效内容获取系统

抖音下载器技术方案：双引擎策略架构与高效内容获取系统 【免费下载链接】douyin-downloader A practical Douyin downloader for both single-item and profile batch downloads, with progress display, retries, SQLite deduplication, and browser fallback supp…...

编程新知 2026/4/12 10:07:55

百度网盘分享链接解析技术：原理、实现与高效下载方案

百度网盘分享链接解析技术：原理、实现与高效下载方案 【免费下载链接】baidu-wangpan-parse 获取百度网盘分享文件的下载地址 项目地址: https://gitcode.com/gh_mirrors/ba/baidu-wangpan-parse 百度网盘作为国内主流的云存储服务，其分享功能为用…...

编程新知 2026/4/12 8:41:34

微软Phi-3轻量模型保姆级教程：快速部署，一键开启智能问答与文本改写

微软Phi-3轻量模型保姆级教程：快速部署，一键开启智能问答与文本改写 1. 为什么选择Phi-3-mini-4k-instruct-gguf Phi-3-mini-4k-instruct-gguf是微软推出的轻量级文本生成模型，特别适合日常办公和内容创作场景。相比其他大模型，…...

编程新知 2026/4/12 7:12:04

科研团队必备：Hunyuan-MT-7B快速部署与多语言评测指南

科研团队必备：Hunyuan-MT-7B快速部署与多语言评测指南 1. 为什么选择Hunyuan-MT-7B 在全球化科研合作日益频繁的今天，语言障碍成为许多团队面临的首要挑战。传统翻译工具要么支持语种有限，要么对专业术语处理不佳，而Hunyuan-MT-…...

编程新知 2026/4/12 6:26:48

深入理解Linux OOM Killer机制与规避策略

深入理解Linux OMM Killer机制与规避策略 在Linux系统中，当内存资源耗尽时，内核会触发OOM Killer（Out-of-Memory Killer）机制，强制终止某些进程以释放内存，确保系统继续运行。这一机制可能导致关键服务被误…...

编程新知 2026/4/12 5:00:21