C#作业调度FluentScheduler学习笔记

0
17

一、简介

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

<

发布回复

请输入评论!
请输入你的名字