C#作业调度FluentScheduler学习笔记

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、结果