当前位置:首页 > 技术 > 正文内容

解析ScheduleMaster的节点管理机制

访客 技术 2026年6月21日 1

ScheduleMaster是一个基于.NET Core 3.1构建的开源分布式任务调度系统,支持跨平台部署。

生命周期事件

生命周期事件增强了应用控制能力。通过ASP.NET Core的HostedService模型,将生命周期管理封装在AppLifeCycleManager服务中。在其StartAsync方法中注册了必要的事件处理函数:

public Task StartAsync(CancellationToken token)
{
    _appLifecycle.OnStarted += OnApplicationStarted;
    _appLifecycle.OnStopping += OnApplicationStopping;
    _appLifecycle.OnStopped += OnApplicationStopped;

    return Task.CompletedTask;
}

这里主要关注的是启动和停止时的状态变更逻辑。

节点注册模式

ScheduleMaster采用中心化架构,包含一个master节点和多个worker节点。根据注册方式的不同,分为自动和手动两种注册模式。

自动注册模式

类似于微服务中的服务注册发现,自动注册模式允许节点在启动时自动向控制中心注册其配置信息。默认情况下,这些信息从配置文件读取,但也可以通过命令行参数覆盖:

private void OnApplicationStarted()
{
    if (CmdParser.ShouldAutoRegister())
    {
        ConfigCache.SetNodeConfiguration(_configuration);
    }
}

public static void SetNodeConfiguration(IConfiguration config)
{
    var nodeConfig = new NodeConfig();
    config.Bind("NodeConfig", nodeConfig);
    // 处理命令行参数覆盖配置项
    ApplyCommandLineOverrides(nodeConfig);
}

判断是否开启自动注册模式的代码如下:

public static bool ShouldAutoRegister()
{
    string option = Environment.GetEnvironmentVariable("SCHED_AUTOREG");
    string cmdOption = CmdParser.GetArgValue("autoreg");
    if (!string.IsNullOrEmpty(cmdOption))
    {
        option = cmdOption;
    }
    return option != "false";
}

注意:master节点仅支持自动注册模式。

手动注册模式

为了增加灵活性,系统还提供了手动注册模式。在这种模式下,worker节点需要先在master控制台创建并连接后才能使用。核心流程包括验证双方的信任状态,并确保数据匹配。

健康检查

健康检查用于检测不可用的worker节点,防止它们参与调度。使用ASP.NET Core自带的健康检查中间件实现。每次健康检查失败都会增加计数器,连续失败次数超过阈值则标记该节点为离线状态。

访问控制

为了保证接口的安全性,系统实现了动态密钥验证机制。每个节点或连接请求都需要携带有效的密钥才能被正确处理。

节点访问

所有对任务的操作最终都会分发到相应的worker节点上执行。例如,启动任务时会查询可用的worker节点,并依次调用远程API完成操作。

.NET Core, 分布式系统, 任务调度, ASP.NET Core, 微服务

相关文章

Linux crontab 详解

1) crontab 是什么cron 是 Linux 的定时任务守护进程;crontab 是用来编辑/查看“按时间周期执行命令”的表(cron table)。常见两类:用户 crontab:每个用户一份(crontab -e 编辑)系统级 crontab / cron.d:可指定执行用户(/etc/crontab、/etc/cron.d/*)2) crontab 时间...

富文本里可以允许的 HTML 属性

一、所有标签默认允许的安全属性(极少)class        (可选)id           (通常建议禁用)title️ 注意:id 容易被滥用做锚点注入,很多系统直接禁用class 允许的话最好只允许固定前缀(如 editor-*)二、a 标签允许属性<a href="" t...

Mac 安装 Node.js 指南

方法一:通过官网安装包(最简单,适合初学者)如果你只是想快速安装并开始使用,这是最直接的方法。访问 Node.js 官网。页面会显示两个版本:LTS (Recommended For Most Users):长期支持版,最稳定。建议选这个。Current:最新特性版,包含最新功能但可能不够稳定。下载 .pkg 安装包并运行。按照安装向导点击“下一步”即可完成。方法二:使用 Homebrew 安装(...

Dom\HTML_NO_DEFAULT_NS 的副作用:自动加闭合标签

在使用Dom\HTMLDocument时,Dom\HTML_NO_DEFAULT_NS 将禁止在解析过程中设置元素的命名空间, 此设置是为了与DOMDocument向后兼容而存在的。当使用它时,已知的一个副作用就是:自动加闭合标签例如 </img> 为什么会这样?当你使用:Dom\HTML_NO_DEFAULT_NS文档会变成 无命名空间模式,此时内部更接近 XML...

Laravel 事件和监听器创建

在 Laravel 中,使用 Artisan 命令创建 Events(事件) 和 Listeners(监听器) 是非常高效的。你可以通过以下几种方式来实现:1. 手动创建单个 Event如果你只想创建一个事件类,可以使用 make:event 命令:Bashphp artisan make:event UserRegistered执行后,文件将生成在 app/Even...

自定义域名解析神器 dnsmasq

什么是 dnsmasq?dnsmasq 是一个轻量级、功能强大的网络服务工具,专为小型和中等规模网络设计。它是一个综合的网络基础设施解决方案[1]。dnsmasq 能做什么?功能说明应用场景DNS 转发与缓存将 DNS 查询转发到上游服务器(ISP、Google DNS 等),并在本地缓存结果加快 DNS 查询速度,减少外部 DNS 流量本地 DNS解析本地网络设备的主机名,无需编辑&n...

发表评论

访客

◎欢迎参与讨论,请在这里发表您的看法和观点。