Job 类似于数据库中的作业,多用于实现定时执行任务。适用场景主要包括定时轮询数据库同步、定时处理数据、定时邮件通知等。
我们的 Job 分为操作系统级别定时任务 WinJob 和 HttpJob,其中,WinJob 使用开源的任务调度框架 Quartz.NET+ ZooKeeper 实现,HttpJob 的服务端是自主开发实现的,可以直接定时调用你的计划任务如微服务。下面分别予以介绍。
WinJob 使用 Quartz.NET+ZooKeeper 来实现,Quartz.NET 实现调度,ZooKeeper 使用 MasterElection 来实现高可用,解决单点问题。ZooKeeper 后继有文章单独介绍,这里重点介绍 Quartz.NET 框架的使用。
Quartz.NET 是一个全功能的开源任务调度框架,通过简单的配置就可以实现强大的任务调度功能,使得开发人员不用过多关注任务的调度,只用关注项目的业务逻辑。使用任务调度框架的价值:
基于 Quartz.NET 实现 Job 调度的方法:
在后端服务声明实例化一个调度器,在启动服务的时候启动调度器,相应的代码如下所示:
- /// <summary>
- /// 当前调度服务的调度器
- /// </summary>
- public IScheduler CurrentSched
- {
- get; private set;
- }
- public JobService()
- {
- InitializeComponent();
- StdSchedulerFactory schedulerFactory = new StdSchedulerFactory();
- CurrentSched = schedulerFactory.GetScheduler();
- }
- protected override void OnStart(string[] args)
- {
- CurrentSched.Start();
- logger.Info("调度服务成功启动!");
- }
创建相应的任务和触发器,之后把任务和关联的触发器加入之前声明的调度器 CurrentSched,相应的代码如下所示:
- /// <summary>
- /// 演示一个任务多触发器的使用
- /// </summary>
- private static void JobWithManyTriggerDemo() {
- IJobDetail simpleJob = JobBuilder.Create<SimpleJob>().WithIdentity("任务名称", "任务组名").Build(); // 创建一个 simpleJob 任务
- ITrigger simpleTrigger = TriggerBuilder.Create().WithIdentity("触发器名称 3", "触发器组名").StartNow()
- .WithSimpleSchedule(x => x.WithIntervalInSeconds(5).RepeatForever()).Build(); // 创建一个简单触发器,每隔 5 秒执行一次
- CurrentSched.ScheduleJob(simpleJob, simpleTrigger); // 把 simpleJob 任务、简单触发器加入调度器
- ITrigger cronTrigger = TriggerBuilder.Create().WithIdentity("触发器名称 4", "触发器组名").StartNow()
- .WithCronSchedule("/10 * * ? * *").ForJob(simpleJob).Build(); // 创建一个为任务“simpleJob”服务的 Cron 触发器,每隔 10 秒执行一次
- CurrentSched.ScheduleJob(cronTrigger); // 把 Cron 触发器加入调度器
- }
在业务逻辑层继承 IJob 接口,并实现 Execute 方法,在该方法内实现需要调度的业务逻辑,相应的代码如下所示:
- /// <summary>
- /// 简单任务
- /// </summary>
- public class SimpleJob : IJob
- {
- ILog logger = LogManager.GetLogger(typeof(SimpleJob));
- public void Execute(IJobExecutionContext context)
- {
- Console.WriteLine("简单的任务演示!" + DateTime.Now.ToString("HH:mm:ss"));
- logger.Info("简单的任务演示!" + DateTime.Now.ToString("HH:mm:ss"));
- // 业务逻辑处理
- Thread.Sleep(2000);
- }
- }
通过自主开发的 JobServer,结合自主开发的 Job 集中式管理平台,可以实现满足绝大部分场景的 Job 调度。 这种 Job 调度使用方式使你只需关注实现业务系统的业务逻辑部分即可,无需在业务系统中额外关注如何使用 Quartz.NET。
JobServer 实现的主要逻辑:
在集中式 Job 管理平台中,配置相应的 Job 信息。配置完 Job 信息后,JobServer 获取到这些 Job 信息后,就能够定时执行这些 Job。要配置的 Job 信息包括 Job 的任务名称、任务组名、请求地址、请求类型、开始时间、触发器类型、次数、间隔时间 (s)、Cron-Like 表达式以及状态。
其中请求地址就是 JobServer 实际定时调用的任务的 http 地址,例如 HttpJobDemo 的 webForm1.aspx 这个任务的运行地址 http://localhost:10786/WebForm1.aspx。
采用 HttpJob 的优势:
采用 HttpJob 的约束:
Cron 表达式格式:秒 分 时 日 月 周 年(可选)。要遵守的规范请见下表:
本系列文章涉及内容清单如下(并不按这顺序发布),其中有感兴趣的,欢迎关注:
来源: http://www.infoq.com/cn/articles/architecture-practice-04-job-schedule