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

using System;using System.Collections.Specialized;using System.Data;using System.Threading.Tasks;using Microsoft.Data.Sqlite;using Microsoft.Extensions.Logging;using Quartz;using Quartz.Impl;using Quartz.Impl.AdoJobStore.Common;using Quartz.Spi;namespace EqidManager{    using IOCContainer = IServiceProvider;    public class QuartzStartup    {        public IScheduler Scheduler { get; set; }        private readonly ILogger _logger;        private readonly IJobFactory iocJobfactory;        public QuartzStartup(IOCContainer IocContainer, ILoggerFactory loggerFactory)        {            _logger = loggerFactory.CreateLogger<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");        }    }}

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);