俄罗斯网站设计,如何组建一个小型局域网,陕西省建设网站 五大员过期,南充市房地产备案查询项目中需要用到QuartZ执行定时任务#xff0c;在此记录一下学习过程。
Quartz安装
在VS2022中#xff0c;通过Nuget包管理器安装Quartz 3.8.1 #xff0c;这是.net 6 依赖的最高版本。
创建定时器任务
1、创建QuartzConfigurator 新建QuartzConfiguratorExtensions类在此记录一下学习过程。
Quartz安装
在VS2022中通过Nuget包管理器安装Quartz 3.8.1 这是.net 6 依赖的最高版本。
创建定时器任务
1、创建QuartzConfigurator 新建QuartzConfiguratorExtensions类用于注册触发器和任务代码如下 /// summary/// 添加任务和触发器/// /summary/// typeparam nameT/typeparam/// param namequartz/param/// param nameconfig/param/// exception crefException/exceptionpublic static void AddJobAndTriggerT(this IServiceCollectionQuartzConfigurator quartz, IConfiguration config) where T : IJob{// Use the name of the IJob as the appsettings.json keystring jobName typeof(T).Name;// Try and load the schedule from configurationvar configKey $Quartz:{jobName};var cronSchedule config[configKey];// Some minor validationif (string.IsNullOrEmpty(cronSchedule)){throw new Exception($No Quartz.NET Cron schedule found for job in configuration at {configKey});}// register the job as beforevar jobKey new JobKey(jobName);quartz.AddJobT(opts opts.WithIdentity(jobKey));quartz.AddTrigger(opts opts.ForJob(jobKey).WithIdentity(jobName -trigger).WithCronSchedule(cronSchedule)); // use the schedule from configuration}/// summary/// 添加任务和触发器带参数传递/// /summary/// typeparam nameT/typeparam/// param namequartz/param/// param nameconfig/param/// param namekeyValuePairs需要传递的参数/param/// param nameIsTriggerJobDataMap默认通过 工作描述时传递参数/param/// exception crefException/exceptionpublic static void AddJobAndTriggerWithParameterT(this IServiceCollectionQuartzConfigurator quartz, IConfiguration config,IDictionarystring, object? keyValuePairs null, bool isJobDetailJobDataMap true) where T : IJob{// Use the name of the IJob as the appsettings.json keystring jobName typeof(T).Name;// Try and load the schedule from configurationvar configKey $Quartz:{jobName};var cronSchedule config[configKey];// Some minor validationif (string.IsNullOrEmpty(cronSchedule)){throw new Exception($No Quartz.NET Cron schedule found for job in configuration at {configKey});}// register the job as beforevar jobKey new JobKey(jobName);if (keyValuePairs ! null isJobDetailJobDataMap){switch (isJobDetailJobDataMap){case true:quartz.AddJobT(opts opts.WithIdentity(jobKey).UsingJobData(new JobDataMap(keyValuePairs)));quartz.AddTrigger(opts opts.ForJob(jobKey).WithIdentity(jobName -trigger).WithCronSchedule(cronSchedule)); // use the schedule from configurationbreak;case false:quartz.AddJobT(opts opts.WithIdentity(jobKey));quartz.AddTrigger(opts opts.ForJob(jobKey).WithIdentity(jobName -trigger).WithCronSchedule(cronSchedule).UsingJobData(new JobDataMap(keyValuePairs))); // use the schedule from configurationbreak;}}else{quartz.AddJobT(opts opts.WithIdentity(jobKey));quartz.AddTrigger(opts opts.ForJob(jobKey).WithIdentity(jobName -trigger).WithCronSchedule(cronSchedule)); // use the schedule from configuration}} 2、在Program.cs 中注入服务
builder.Services.AddQuartz(q
{创建计划单元时间轴载体//StdSchedulerFactory schedulerFactory new StdSchedulerFactory();//var scheduler await schedulerFactory.GetScheduler();//await scheduler.Start();q.UseMicrosoftDependencyInjectionJobFactory();// Register the job, loading the schedule from configurationq.AddJobAndTriggerFromKingdeeWorkerJob(builder.Configuration);
});
builder.Services.AddQuartzHostedService(q q.WaitForJobsToComplete true); 3、创建工作单元WorkerJob 新建类TestWorkerJob并继承IJob代码如下 [PersistJobDataAfterExecution]//在执行完成后保留JobDataMap数据[DisallowConcurrentExecution]//不允许并发执行即必须等待上次完成后才能执行下一次public class TestWorkerJob : IJob{private readonly ILoggerTesteWorkerJob _logger;public TestWorkerJob(ILoggerTestWorkerJob logger){ _logger logger;}public Task Execute(IJobExecutionContext context){_logger.LogInformation(DateTime.Now --- Hello world!);Task.Delay(50000);Thread.Sleep(10000);return Task.CompletedTask;}} 假如我们的定时任务执行一次需要耗时比较久而且后一次执行需要等待前一次完成并且需要前一次执行的结果作为参考那么就需要设置任务的任性。因为默认情况下工作单元在每一次运行都是一个新的实例相互之间独立运行互不干扰。所以如果需要存在一定的关联就要设置任务的特性主要有两个如下所示
[PersistJobDataAfterExecution]//在执行完成后保留JobDataMap数据 [DisallowConcurrentExecution]//不允许并发执行即必须等待上次完成后才能执行下一次 以上两个特性只需要标记在任务对应的类上即可。
4、appsettings.json配置 在appsettings.json文件中添加一项Quartz子项的必须与WorkerJob的名字保持一致value是Cron表达式
{Quartz: {FromKingdeeWorkerJob: 0/5 * * * * ?}
} 然后启动项目就可以看到任务可以正常运行啦。
最后 最后附上学习链接
.NET6Quartz实现定时任务_.net6 quartz-CSDN博客
KSO - 在.NET6中项目级使用配置Quartz.NET定时任务并使用IHostedService实现项目启动自动加载任务常用的Corn表达式_net6 webapi 在配置中引入注入quartz-CSDN博客
