V2AS问路
Quartz.Net源码Example之Quartz.Examples
阅读原文时间：2023年07月09日阅读：2

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) 的日期和时间，

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

  2. 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}");

  3. 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))

  4. 注意：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说明

  1. 01_SimpleJobScheduler

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

  2. 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(); 获取调度任务数据

  3. 03_SchedulingCapabilitiesUsingCronTriggers

    cron的触发器实例

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

  4. 04_JobParametersAndJobsStateMaintenance

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

  5. 05_SchedulingJobsSettingMisfireInstructions

    JobDataMap实例（同上）和 一个单元测试

    • UsingJobData(StatefulDumbJob.ExecutionDelay, 10000L) 在IJobDetail实例时调用该方法赋值
    • WithMisfireHandlingInstructionNowWithExistingCount() 设置了运行失败后的计数---通过await Task.Delay(10000L)实现的

  6. 06_JobExecutionExceptions

    JobExecutionException的例子

    • 作业重新开始执行

      // 将Exception异常转换为JobExecutionException异常
      JobExecutionException e2 = new JobExecutionException(e);
      // 如果报错不可以修复，可以让该触发器结束执行，避免一直报错
      e2.UnscheduleAllTriggers = true;
      // 如果报错可以修复，可以在报错修复后重新执行
      e2.RefireImmediately = true;
      throw e2;

  7. 07_InterrupInProgressJobs

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

    // 调度程序中中断作业，job.Key 作业的唯一key
await sched.Interrupt(job.Key);
// IJob实例中判断中断代码片段
// 当该值为true时，要求中断
context.CancellationToken.IsCancellationRequested

  8. 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")

  9. 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. 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. 11_RunningLargeNumberOfJobs

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

  12. 12_RemoteClientServerJobScheduling

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

  13. 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. 14_RunJobsByPriorityWithTriggersPriority

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

    ITrigger实例.WithPriority(10)

  15. 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. 16_RunningAsynchronousJobs

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

手机扫一扫

移动阅读更方便

阿里云服务器
腾讯云服务器
七牛云服务器

你可能感兴趣的文章