解析ScheduleMaster的节点管理机制
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, 微服务