如何掌握Quartz.net分布式定时任务的姿势

本文介绍了如何掌握Quartz.net分布式定时任务的姿态。内容非常详细。有兴趣的朋友可以参考一下，希望对大家有帮助。

00-1010长话短说，我们今天来谈谈分布式计时任务，我的日志记录：

ASP.NET的核心Quartz.Net实施网络计时任务

AspNetCore结合Redis实践消息队列

经过仔细分析，朋友们知道还是有问题的：

水平扩展的网络应用程序的Quartz.net计时任务将被触发多次，因为网络应用程序实例使用默认的内存作业存储，多个实例在内存中维护作业和触发器的副本。

我的计时任务是同步任务，但是重复执行不是大问题。但是对于具体业务的计时任务，反复执行可能是致命的。

基于此，我们来看看Quartz.net分布式定时任务的姿态。

00-1010显然，水平扩展的多实例需要一个独立于web实例的机制来存储Job和Trigger。

提供Quartz.NET ADO.NET工作商店来存储任务数据。

首先，使用SQL脚本在数据库中生成指定的表结构。执行该脚本后，您将看到数据库中有几个以QRTZ_开头的表

quartz.config使用AdoJobStore以编码或quartz.config的形式添加配置

00-1010

引言

从https://github.com/Quartznet/Quartznet/tree/master/database/tables下载适当的数据库表脚本，以生成指定的表结构。

00-1010通过这次编码添加AdoJobStore配置。

第一次启动会将代码中的作业和触发器保存到sqlite，然后直接从sqlite加载作业和触发器。

使用系统；

使用系统。收藏品。专业化；

使用系统。数据；

使用系统。线程化。任务；

使用微软。Data . Sqlite

使用微软。扩展。日志记录；

使用石英；

使用石英。Impl

使用石英。Impl . AdoJobStore.Common

使用石英。Spi

命名空间EqidManager

{

使用IOCContainer=IServiceProvider

公共类QuartzStartup

{

公共IScheduler Scheduler { get设置；}

私有只读ILogger _ logger

私有只读IJobFactory iocJobfactory

公共QuartzStartup(Iocontainer、ILoggerFactory、LoggerFactory)

{

_logger=loggerFactory。C

reateLogger<QuartzStartup>();
           iocJobfactory = new IOCJobFactory(IocContainer);

           DbProvider.RegisterDbMetadata("sqlite-custom", new DbMetadata()
           {
               AssemblyName = typeof(SqliteConnection).Assembly.GetName().Name,
               ConnectionType = typeof(SqliteConnection),
               CommandType = typeof(SqliteCommand),
               ParameterType = typeof(SqliteParameter),
               ParameterDbType = typeof(DbType),
               ParameterDbTypePropertyName = "DbType",
               ParameterNamePrefix = "@",
               ExceptionType = typeof(SqliteException),
               BindByName = true
           });

           var properties = new NameValueCollection
           {
               ["quartz.jobStore.type"] = "Quartz.Impl.AdoJobStore.JobStoreTX, Quartz",
               ["quartz.jobStore.useProperties"] = "true",
               ["quartz.jobStore.dataSource"] = "default",
               ["quartz.jobStore.tablePrefix"] = "QRTZ_",
               ["quartz.jobStore.driverDelegateType"] = "Quartz.Impl.AdoJobStore.SQLiteDelegate, Quartz",
               ["quartz.dataSource.default.provider"] = "sqlite-custom",
               ["quartz.dataSource.default.connectionString"] = "Data Source=EqidManager.db",
               ["quartz.jobStore.lockHandler.type"] = "Quartz.Impl.AdoJobStore.UpdateLockRowSemaphore, Quartz",
               ["quartz.serializer.type"] = "binary"
           };

           var schedulerFactory = new StdSchedulerFactory(properties);
           Scheduler = schedulerFactory.GetScheduler().Result;
           Scheduler.JobFactory = iocJobfactory;
       }

       public async Task<IScheduler> ScheduleJob()
       {
           var _eqidCounterResetJob = JobBuilder.Create<EqidCounterResetJob>()
             .WithIdentity("EqidCounterResetJob")
             .Build();

           var _eqidCounterResetJobTrigger = TriggerBuilder.Create()
               .WithIdentity("EqidCounterResetCron")
               .StartNow()
               //每天凌晨0s
               .WithCronSchedule("0 0 0 * * ?")      Seconds,Minutes,Hours，Day-of-Month，Month，Day-of-Week，Year（optional field）
               .Build();
       
          // 这里一定要先判断是否已经从SQlite中加载了Job和Trigger
           if (!await Scheduler.CheckExists(new JobKey("EqidCounterResetJob")) &&
               !await Scheduler.CheckExists(new TriggerKey("EqidCounterResetCron")))
           {
               await Scheduler.ScheduleJob(_eqidCounterResetJob, _eqidCounterResetJobTrigger);
           }
           
           await Scheduler.Start();
           return Scheduler;
       }

       public void EndScheduler()
       {
           if (Scheduler == null)
           {
               return;
           }

           if (Scheduler.Shutdown(waitForJobsToComplete: true).Wait(30000))
               Scheduler = null;
           else
           {
           }
           _logger.LogError("Schedule job upload as application stopped");
       }
   }
}

 

上面是Quartz.NET 从sqlite中加载Job和Trigger的核心代码

这里要提示两点：

①  IOCJobFactory 是自定义JobFactory，目的是与ASP.NET Core原生依赖注入结合
② 在调度任务的时候，先判断是否已经从sqlite加载了Job和Trigger

3.添加Quartz.Net UI轮子

附赠Quartz.NET的调度UI: CrystalQuartz， 方便在界面管理和调度任务
① Install-Package CrystalQuartz.AspNetCore -IncludePrerelease
② Startup启用CrystalQuartz

using CrystalQuartz.AspNetCore;
/*
 * app is IAppBuilder
 * scheduler is your IScheduler (local or remote)
 */
var quartz = app.ApplicationServices.GetRequiredService<QuartzStartup>();
var _schedule = await  quartz.ScheduleJob();
app.UseCrystalQuartz(() => scheduler);

③ 在localhost:YOUR_PORT/quartz地址查看调度

    

关于如何掌握Quartz.net分布式定时任务的姿势就分享到这里了，希望