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

中小型研发团队架构实践九：任务调度Job

news 来源：原创 2024/5/4 3:38:05

一、Job 简介

Job 类似于数据库中的作业，多用于实现定时执行任务。适用场景主要包括定时轮询数据库同步、定时处理数据、定时邮件通知等。

我们的 Job 分为操作系统级别定时任务 WinJob 和 HttpJob，其中，WinJob 使用开源的任务调度框架 Quartz.NET+ ZooKeeper 实现，HttpJob 的服务端是自主开发实现的，可以直接定时调用你的计划任务，如微服务。下面分别予以介绍。

二、WinJob

WinJob 使用 Quartz.NET+ZooKeeper 来实现，Quartz.NET 实现调度，ZooKeeper 使用 MasterElection 来实现高可用，解决单点问题。

Quartz.NET 是一个全功能的开源任务调度框架，通过简单的配置就可以实现强大的任务调度功能，使得开发人员不用过多关注任务的调度，只用关注项目的业务逻辑。使用任务调度框架的价值：

提高开发效率：开发人员只需要编写业务代码，而具体的任务调度只需要通过配置就可以实现。
提高软件的可靠性：同一应用多个任务之间可以很好的隔离起来，互不影响。
降低开发人员成本和开发复杂度：开发人员不需要对线程、Timer 很了解，就能实现一个强大的执行计划应用。
容易迁移：只需实现 Quartz.IJob 接口即可，调用一次业务逻辑的入口即可。
容易扩展：新业务只需增加配置即可。

基于 Quartz.NET 实现 Job 调度的方法：

在后端服务声明实例化一个调度器，在启动服务的时候启动调度器，相应的代码如下所示：

 1 /// <summary>         
 2 /// 当前调度服务的调度器         
 3 /// </summary>         
 4 public IScheduler CurrentSched 
 5 { 
 6    get; private set; 
 7 }
 8 public JobService()         
 9 {    
10    InitializeComponent();  
11 
12    StdSchedulerFactory schedulerFactory = new StdSchedulerFactory();                
13    CurrentSched = schedulerFactory.GetScheduler();       
14 }        
15 protected override void OnStart(string[] args)        
16 {    
17    CurrentSched.Start();                 
18    logger.Info("调度服务成功启动！");         
19 }

创建相应的任务和触发器，之后把任务和关联的触发器加入之前声明的调度器 CurrentSched，相应的代码如下所示：

 1 /// <summary>         
 2 /// 演示一个任务多触发器的使用        
 3 /// </summary>         
 4 private static void JobWithManyTriggerDemo()         
   {                 
 5     IJobDetail simpleJob = JobBuilder.Create<SimpleJob>().WithIdentity("任务名称", "任务组名").Build(); // 创建一个 simpleJob 任务                 
 6     ITrigger simpleTrigger = TriggerBuilder.Create().WithIdentity("触发器名称 3", "触发器组名").StartNow()        
 7         .WithSimpleSchedule(x => x.WithIntervalInSeconds(5).RepeatForever()).Build();   // 创建一个简单触发器，每隔 5 秒执行一次         
 8 
 9     CurrentSched.ScheduleJob(simpleJob, simpleTrigger);    // 把 simpleJob 任务、简单触发器加入调度器         
10 
11     ITrigger cronTrigger = TriggerBuilder.Create().WithIdentity("触发器名称 4", "触发器组名").StartNow()        
12         .WithCronSchedule("/10 * * ? * *").ForJob(simpleJob).Build();   // 创建一个为任务“simpleJob”服务的 Cron 触发器，每隔 10 秒执行一次       
13 
14      CurrentSched.ScheduleJob(cronTrigger);   // 把 Cron 触发器加入调度器         
15 }

在业务逻辑层继承 IJob 接口，并实现 Execute 方法，在该方法内实现需要调度的业务逻辑，相应的代码如下所示：

 1 /// <summary>     
 2 /// 简单任务     
 3 /// </summary>     
 4 public class SimpleJob : IJob     
 5 {             
 6     ILog logger = LogManager.GetLogger(typeof(SimpleJob));    
 7     public void Execute(IJobExecutionContext context)                 
 8     {       
 9         Console.WriteLine("简单的任务演示！" + DateTime.Now.ToString("HH:mm:ss"));       
10         logger.Info("简单的任务演示！" + DateTime.Now.ToString("HH:mm:ss"));                    
11         // 业务逻辑处理                    
12         Thread.Sleep(2000);             
13      }     
14 }

三、HttpJob

通过自主开发的 JobServer，结合自主开发的 Job 集中式管理平台，可以实现满足绝大部分场景的 Job 调度。这种 Job 调度使用方式使你只需关注实现业务系统的业务逻辑部分即可，无需在业务系统中额外关注如何使用 Quartz.NET。

3.1、HttpJob 的服务端实现

JobServer 实现的主要逻辑：

借助 Quartz，可实现多个线程（如 10 个线程）同时调用多个 HttpJob；
实现了 Get、Post、Head 三种方式的请求；
借助 ZooKeeper的 MasterElection 来实现高可用，实现自动主备切换；
记录日志，方便追踪。

3.2、HttpJob 的后台——Job 集中式管理平台

在集中式 Job 管理平台中，配置相应的 Job 信息。配置完 Job 信息后，JobServer 获取到这些 Job 信息后，就能够定时执行这些 Job。要配置的 Job 信息包括 Job 的任务名称、任务组名、请求地址、请求类型、开始时间、触发器类型、次数、间隔时间 (s)、Cron-Like 表达式以及状态。

其中请求地址就是 JobServer 实际定时调用的任务的 http 地址，例如 HttpJobDemo 的 WebForm1.aspx 这个任务的运行地址 http://localhost:10786/WebForm1.aspx。