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

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

news 2025/9/17 17:34:10

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

多云管理“拦路虎”：深入解析网络互联、身份同步与成本可视化的技术复杂度​

一、引言：多云环境的技术复杂性本质​​ 企业采用多云策略已从技术选型升维至生存刚需。当业务系统分散部署在多个云平台时，​​基础设施的技术债呈现指数级积累​​。网络连接、身份认证、成本管理这三大核心挑战相互嵌套：跨云网络构建数据…...

编程新知 2025/9/13 18:53:26

【入坑系列】TiDB 强制索引在不同库下不生效问题

文章目录 背景SQL 优化情况线上SQL运行情况分析怀疑1：执行计划绑定问题？尝试：SHOW WARNINGS 查看警告探索 TiDB 的 USE_INDEX 写法Hint 不生效问题排查解决参考背景 项目中使用 TiDB 数据库，并对 SQL 进行优化了，添加了强制索引。 UAT 环境已经生效，但 PROD 环境强制索…...

编程新知 2025/9/13 17:43:37

MySQL中【正则表达式】用法

MySQL 中正则表达式通过 REGEXP 或 RLIKE 操作符实现（两者等价），用于在 WHERE 子句中进行复杂的字符串模式匹配。以下是核心用法和示例： 一、基础语法 SELECT column_name FROM table_name WHERE column_name REGEXP pattern; …...

编程新知 2025/9/13 11:37:54

如何理解 IP 数据报中的 TTL？

目录 前言理解 前言 面试灵魂一问：说说对 IP 数据报中 TTL 的理解？我们都知道，IP 数据报由首部和数据两部分组成，首部又分为两部分：固定部分和可变部分，共占 20 字节，而即将讨论的 TTL 就位于首…...

编程新知 2025/9/13 0:08:53

智能分布式爬虫的数据处理流水线优化：基于深度强化学习的数据质量控制

在数字化浪潮席卷全球的今天，数据已成为企业和研究机构的核心资产。智能分布式爬虫作为高效的数据采集工具，在大规模数据获取中发挥着关键作用。然而，传统的数据处理流水线在面对复杂多变的网络环境和海量异构数据时，常出现数据质…...

编程新知 2025/9/7 8:50:57

Go 并发编程基础：通道（Channel）的使用

在 Go 中，Channel 是 Goroutine 之间通信的核心机制。它提供了一个线程安全的通信方式，用于在多个 Goroutine 之间传递数据，从而实现高效的并发编程。 本章将介绍 Channel 的基本概念、用法、缓冲、关闭机制以及 select 的使用。 一、Channel…...

编程新知 2025/8/28 22:40:10

android RelativeLayout布局

<?xml version"1.0" encoding"utf-8"?> <RelativeLayout xmlns:android"http://schemas.android.com/apk/res/android"android:layout_width"match_parent"android:layout_height"match_parent"android:gravity&…...

编程新知 2025/9/7 8:49:46

elementUI点击浏览table所选行数据查看文档

项目场景&#xff1a; table按照要求特定的数据变成按钮可以点击 解决方案&#xff1a; <el-table-columnprop"mlname"label"名称"align"center"width"180"><template slot-scope"scope"><el-buttonv-if&qu…...

编程新知 2025/9/7 8:49:12

消息队列系统设计与实践全解析

文章目录 &#x1f680; 消息队列系统设计与实践全解析&#x1f50d; 一、消息队列选型1.1 业务场景匹配矩阵1.2 吞吐量/延迟/可靠性权衡&#x1f4a1; 权衡决策框架 1.3 运维复杂度评估&#x1f527; 运维成本降低策略 &#x1f3d7;️ 二、典型架构设计2.1 分布式事务最终一致…...

编程新知 2025/9/7 8:48:53

Python网页自动化Selenium中文文档

1. 安装 1.1. 安装 Selenium Python bindings 提供了一个简单的API&#xff0c;让你使用Selenium WebDriver来编写功能/校验测试。 通过Selenium Python的API&#xff0c;你可以非常直观的使用Selenium WebDriver的所有功能。 Selenium Python bindings 使用非常简洁方便的A…...

编程新知 2025/7/8 0:22:23