Quartz.Net源码Example之Quartz.Examples

Quartz.Examples

反射-Example批量执行

实现思路：定义一个统一的接口，需要实现的类全部实现该接口；通过反射获取实现该接口的实例并触发其中的方法。

定义统一的接口

// 所有要实现类都要有Run方法

public interface IExample

{

	Task Run();

}

利用反射实例化

//反射的方式获得程序配置信息

Assembly asm = typeof(Program).GetTypeInfo().Assembly;

// 获得该程序的所有类型

Type[] types = asm.GetTypes();

List<Type> typeList = new List<Type>();

foreach (Type t in types)

{

	// 判断是否继承的IExample接口

    if (new List<Type>(t.GetInterfaces()).Contains(typeof(IExample)))

    {

    	typeList.Add(t);

    }

}

// 实例化第一个接口实现类

IExample example = ObjectUtils.InstantiateType<IExample>(typeList[0]);

// 执行接口中的Run方法

await example.Run().ConfigureAwait(false);

DateTimeOffset

UTC时间为协调世界时 (UTC) 的日期和时间，

不建议使用DateTime，因为DateTime一般默认为本地时间+时区，不会有时间偏移的概念，不同时区的时间相等但是不是同一时间。

DateTimeOffset.Now和DateTimeOffset.UtcNow

相同点获得的实际值一样（ToUnixTimeSecondes）

// Now秒：   1675238417

// UtcNow秒：1675238417

Console.WriteLine($"Now秒：   {DateTimeOffset.Now.ToUnixTimeSeconds()}");

Console.WriteLine($"UtcNow秒：{DateTimeOffset.UtcNow.ToUnixTimeSeconds()}");

不同点展示不一样，Now为本地时区时间，UtcNow为0时区的时间。

// Now时间   ：2023/2/1 16:00:17 +08:00

// UtcNow时间：2023/2/1 8:00:17 +00:00

Console.WriteLine($"Now时间   ：{DateTimeOffset.Now}");

Console.WriteLine($"UtcNow时间：{DateTimeOffset.UtcNow}");

DateTime与DateTimeOffset 转换

//DateTimeOffset 转 DateTime

// 时区丢失，即dateTime.Kind为UnSpecified

DateTime dateTime=dateTimeOffset.DateTime;

// 时区为Local

DateTime dateTime=DateTime.SpecifyKind(dateTimeOffset,DateTimeKind.Local);

// 本地时区换算为本地时间，且dateTime.Kind为Local

DateTime dateTime=dateTimeOffset.LocalTime;

// 本地时区换算为utc时间(0时区)，且dateTime.Kind为Utc

DateTime dateTime=dateTimeOffset.UtcDateTime;

// DateTime转DateTimeOffset

// 直接转换为本地时间+时区

DateTimeOffset dateTimeOffset = new DateTimeOffset(dateTime);

// Utc时间 dateTimeOffset与dateTime时区会不同，造成展示的时间不同

DateTimeOffset dateTimeOffset = new DateTimeOffset(dateTime, TimeZoneInfo.Local.GetUtcOffset(dateTime));

// 设置时间+查找时区相对应的时间 dateTimeOffset与dateTime会相同

DateTimeOffset dateTimeOffset = new DateTimeOffset(dateTime, TimeZoneInfo.FindSystemTimeZoneById("Central Standard Time").GetUtcOffset(dateTime))

注意：Quartz.NET使用了DateTimeOffset进行的时间操作

TimeSpan

时间间隔，例如

TimeSpan.FromSeconds(65) 返回65秒的TimeSpan实例

TimeSpan.Zero 间隔是0秒

new TimeSpan(2, 14, 18) 间隔2小时14分钟18秒

DateTime减法

DateTime departure = new DateTime(2010, 6, 12, 18, 32, 0);

DateTime arrival = new DateTime(2010, 6, 13, 22, 47, 0);

TimeSpan travelTime = arrival - departure;

// 结果：6/13/2010 10:47:00 PM - 6/12/2010 6:32:00 PM = 1.04:15:00

DateBuilder

Quzrtz.NET自带设置类，方便设置和操作DateTimeOffset类。

// date时间后的一个小时，例如date为8:44:59,调用方法后获得时间为 9:00:00

// 如果参数为null，则为当前时间

static DateTimeOffset EvenHourDate(DateTimeOffset? date)

// 同DateBuilder.EvenHourDate(null);

static DateTimeOffset EvenHourDateAfterNow()

// data时间前的一个小时，例如date为8:44:59,调用方法后获得时间为 8:00:00

static DateTimeOffset EvenHourDateBefore(DateTimeOffset? date)

// 同EvenHourDate，不过由小时变为了分钟; EvenMinuteDateBefore和EvenMinuteDateAfterNow同上

static DateTimeOffset EvenMinuteDate(DateTimeOffset? date)

// EvenSecondDate EvenSecondDateBefore EvenSecondDateAfterNow同上

/*

当前时间以IntervalUnit为单位增加interval的时间

IntervalUnit为枚举类

        Millisecond,	毫秒

        Second,			秒

        Minute,			分

        Hour,			小时

        Day,			天

        Week,			周

        Month,			月

        Year			年

例如：DateBuilder.FutureDate(1, IntervalUnit.Hour); 当前时间增加一小时后的DateTimeOffset实例

*/

static DateTimeOffset FutureDate(int interval, IntervalUnit unit)

// 创建一个当前时间的DateBuilder实例，可通过Build()方法获得DateTimeOffset

static DateBuilder NewDate

/*

	TimeZoneInfo 时区，根据时区不同获取不同时区的当前时间

*/

static DateBuilder NewDateInTimeZone(TimeZoneInfo tz)

// 获得下一分/秒的时间

static DateTimeOffset NextGivenMinuteDate(DateTimeOffset? date, int minuteBase)

static DateTimeOffset NextGivenSecondDate(DateTimeOffset? date, int secondBase)

// 当前时间加上hour小时，minute分钟，second秒

static DateTimeOffset TodayAt(int hour, int minute, int second)

// 当前时间加上1天，hour小时，minute分钟，second秒

static DateTimeOffset TomorrowAt(int hour, int minute, int second)

各Demo说明

01_SimpleJobScheduler

最简单的调度程序，任务是打印当前时间
02_SchedulingCapabilitiesUsingSimpleTriggers

简单的触发器实例-重复执行，定时执行等
- TriggerBuilder.Create()创建ISimpleTrigger的实例
- .WithSimpleSchedule(x => x.WithIntervalInSeconds(10).WithRepeatCount(10)) 每隔10s循环10次，共11次
- sched.RescheduleJob(trigger.Key, trigger) 重启触发器trigger为触发器实例
- SchedulerMetaData metaData = await sched.GetMetaData(); 获取调度任务数据
03_SchedulingCapabilitiesUsingCronTriggers

cron的触发器实例

具体cron触发可通过查看cron在线生成来确定触发周期
04_JobParametersAndJobsStateMaintenance

JobDataMap添加数据，IJob实例中获取并修改的实例
05_SchedulingJobsSettingMisfireInstructions

JobDataMap实例（同上）和一个单元测试
- UsingJobData(StatefulDumbJob.ExecutionDelay, 10000L) 在IJobDetail实例时调用该方法赋值
- WithMisfireHandlingInstructionNowWithExistingCount() 设置了运行失败后的计数---通过await Task.Delay(10000L)实现的

06_JobExecutionExceptions

JobExecutionException的例子

作业重新开始执行

// 将Exception异常转换为JobExecutionException异常

JobExecutionException e2 = new JobExecutionException(e);

// 如果报错不可以修复，可以让该触发器结束执行，避免一直报错

e2.UnscheduleAllTriggers = true;

// 如果报错可以修复，可以在报错修复后重新执行

e2.RefireImmediately = true;

throw e2;

07_InterrupInProgressJobs

调度程序中每七秒中断一次作业，共中断50次

// 调度程序中中断作业，job.Key 作业的唯一key

await sched.Interrupt(job.Key);

// IJob实例中判断中断代码片段

// 当该值为true时，要求中断

context.CancellationToken.IsCancellationRequested

08_ExcludeTimePeriodsUsingCalendars

通过判断ModifiedByCalendar，来排除不执行的时间

// 创建日历

AnnualCalendar holidays = new AnnualCalendar();

// 生成一个排除的时间

DateTime fourthOfJuly = new DateTime(DateTime.UtcNow.Year, 7, 4);

// 在日历中添加该时间

holidays.SetDayExcluded(fourthOfJuly, true);

// 将日历添加到调度程序中，，第一个参数为实例名称，第三个参数为替换之前的日历，第四个参数为更新触发器

await sched.AddCalendar("holidays", holidays, false, false);

// 引用实例名称

ISimpleTrigger的实例.ModifiedByCalendar("holidays")

09_TriggeringAJobUsingJobListeners

在作业中启用了监听，并在监听中创建了新的作业

创建监听并添加到调度程序中

// 实例化监听

IJobListener listener = new SimpleJob1Listener();

// 创建匹配器，并设置作业的key

IMatcher<JobKey> matcher = KeyMatcher<JobKey>.KeyEquals(job.Key);

// 将监听和匹配器关联

sched.ListenerManager.AddJobListener(listener, matcher);

SimpleJob1Listener

public class SimpleJob1Listener : IJobListener

{

	public virtual string Name => "job1_to_job2";

	// 作业将被执行

    public virtual Task JobToBeExecuted(IJobExecutionContext inContext, CancellationToken canncellationToken)

    {

	    return Task.CompletedTask;

    }

	// 作业完成执行

    public virtual Task JobExecutionVetoed(IJobExecutionContext inContext,CancellationToken canncellationToken)

    {

	    return Task.CompletedTask;

    }

	// 作业执行完成

    public virtual async Task JobWasExecuted(IJobExecutionContext inContext,JobExecutionException? inException,CancellationToken canncellationToken = default)

    {

        //在监听器中创建作业和触发器

        IJobDetail job2 = JobBuilder.Create<SimpleJob2>()

            .WithIdentity("job2")

            .Build();

        ITrigger trigger = TriggerBuilder.Create()

            .WithIdentity("job2Trigger")

            .StartNow()

            .Build();

        try

        {

            // 将触发器和作业添加到调度程序中

            await inContext.Scheduler.ScheduleJob(job2, trigger, canncellationToken);

        }

        catch (SchedulerException e)

        {

            Console.Error.WriteLine("Unable to schedule job2!");

            Console.Error.WriteLine(e.StackTrace);

        }

    }

}

10_RunningJobsByPlugInXmlConfiguration

通过xml配置任务和触发器，xml参见：quartz_jobs.xml

MergedJobDataMap

if (context.MergedJobDataMap.Count > 0)

{

    ICollection<string> keys = context.MergedJobDataMap.Keys;

    foreach (string key in keys)

    {

        var val = context.MergedJobDataMap.GetString(key);

        Console.WriteLine(" - jobDataMap entry: {0} = {1}", key, val);

    }

}

11_RunningLargeNumberOfJobs

500个任务间隔100ms秒执行，可以查看任务执行效率和资源信息
12_RemoteClientServerJobScheduling

代码被注释，官网不建议使用

13_ClusteringJobsExecution

集群作业(感觉就是多个调度服务使用同一个数据库的例子)

使用数据库存储

IScheduler sched = await SchedulerBuilder.Create()

    .WithId("instance_one")

    .WithName("TestScheduler")

    // 线程池

    .UseDefaultThreadPool(x => x.MaxConcurrency = 5)

    //失效后暂停60s

    .WithMisfireThreshold(TimeSpan.FromSeconds(60))

    .UsePersistentStore(x =>

    {

        x.UseProperties = true;

        x.UseClustering();

        // 连接字符串

        x.UseSqlServer(TestConstants.SqlServerConnectionString);

        x.UseJsonSerializer();

    })

    .BuildScheduler();

14_RunJobsByPriorityWithTriggersPriority

触发器优先级的例子，默认是5，在相同时间运行时不同级别同时运行时，级别越高越先执行

ITrigger实例.WithPriority(10)

15_ConfigureJobSchedulingByUsingXmlConfigurations

使用xml进行调度器的配置

var sched = await SchedulerBuilder.Create()

    .WithName("XmlConfiguredInstance")

    .UseDefaultThreadPool(maxConcurrency: 5)

    // 作业和触发器都通过xml进行配置

    .UseXmlSchedulingConfiguration(x =>

    {

    	// xml文件

        x.Files = new[] { "~/quartz_jobs.xml" };

        // FailOnFileNotFound默认为true

        x.FailOnFileNotFound = true;

        // FailOnSchedulingError 默认为false

        x.FailOnSchedulingError = true;

    })

    .BuildScheduler();

16_RunningAsynchronousJobs

由于作业没执行完毕触发器会再次运行作业，因此相同的作业会异步执行

巴特西