C#作业调度FluentScheduler学习笔记

一、简介

FluentScheduler是一个简单的任务调度框架，定时任务管理器。

GitHub地址：https://github.com/fluentscheduler/FluentScheduler

二、示例程序

2.1、界面

新建一个WinForm程序FluentSchedulerClient，项目右键->属性->应用程序->输出类型，选择控制台应用程序。

2.2、引用

项目右键->管理 NuGet 程序包->FluentScheduler。

2.3、作业

新建一个类DataSyncJob并继承IJob，代表它是一个作业，同时实现IJob.Execute方法。

using System;using System.Collections.Generic;using System.Linq;using System.Text;using System.Threading.Tasks;using FluentScheduler;namespace LinkTo.Test.FluentSchedulerClient{    public class DataSyncJob : IJob    {        void IJob.Execute()        {            Console.WriteLine($"This is DataSyncService submmit...:{Guid.NewGuid().ToString("N")}");        }    }}

同上，再建一个作业TestJob：

using System;using System.Collections.Generic;using System.Linq;using System.Text;using System.Threading.Tasks;using FluentScheduler;namespace LinkTo.Test.FluentSchedulerClient{    public class TestJob : IJob    {        void IJob.Execute()        {            Console.WriteLine($"This is TestService submmit...:{Guid.NewGuid().ToString("N")}");        }    }}

2.4、调度工厂

新建一个工厂类FluentSchedulerFactory并继承Registry：

using System;using System.Collections.Generic;using System.Linq;using System.Text;using System.Threading.Tasks;using FluentScheduler;namespace LinkTo.Test.FluentSchedulerClient{    public class FluentSchedulerFactory : Registry    {        public FluentSchedulerFactory()        {            //让Job进行单线程跑，避免没跑完时的重复执行。(全局)            NonReentrantAsDefault();            //让Job进行单线程跑，避免没跑完时的重复执行。(单个任务)            //Schedule<DataSyncJob>().NonReentrant().ToRunNow().AndEvery(5).Seconds();            //立即执行每5秒一次的计划任务。（指定一个时间间隔运行，根据自己需求，可以是秒、分、时、天、月、年等。）            Schedule<DataSyncJob>().ToRunNow().AndEvery(5).Seconds();            ////立即执行一个每个月第一个星期一18：00的计划任务            //Schedule<DataSyncJob>().ToRunNow().AndEvery(1).Months().OnTheFirst(DayOfWeek.Monday).At(18, 0);            ////延迟5秒执行的一次计划任务。（指定一个时间间隔运行，根据自己需求，可以是秒、分、时、天、月、年等。）            //Schedule<DataSyncJob>().ToRunOnceIn(5).Seconds();            ////指定时间执行计划任务（最常用，这里是在每天18：00执行。）            //Schedule(() => Console.WriteLine("It's 18:00 now.")).ToRunEvery(1).Days().At(18, 0);            ////在同一个计划中执行多个任务            //Schedule<DataSyncJob>().AndThen<TestJob>().ToRunNow().AndEvery(5).Seconds();        }    }}

FluentScheduler调度周期，有点类似于Quartz.NET的Cron表达式的自然语言翻译，更容易理解。另外，FluentScheduler可以在同一计划中执行多个任务，个人觉得也是特色之一。

2.5、调度

using System;using System.Collections.Generic;using System.ComponentModel;using System.Data;using System.Drawing;using System.Linq;using System.Text;using System.Threading.Tasks;using System.Windows.Forms;using FluentScheduler;namespace LinkTo.Test.FluentSchedulerClient{    public partial class Main : Form    {        public Main()        {            InitializeComponent();            //按钮状态            btnStart.Enabled = true;            btnStop.Enabled = false;        }        /// <summary>        /// 开始        /// </summary>        /// <param name="sender"></param>        /// <param name="e"></param>        private void btnStart_Click(object sender, EventArgs e)        {            JobManager.Initialize(new FluentSchedulerFactory());            //按钮状态            btnStart.Enabled = false;            btnStop.Enabled = true;        }        /// <summary>        /// 停止        /// </summary>        /// <param name="sender"></param>        /// <param name="e"></param>        private void btnStop_Click(object sender, EventArgs e)        {            JobManager.Stop();            //按钮状态            btnStart.Enabled = true;            btnStop.Enabled = false;        }    }}

2.6、结果