C#作业调度FluentScheduler学习笔记

当前位置:

首页 > temp > 简明python教程 >

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

栏目列表