.net 6 配置QuartZ定时任务的过程
项目中需要用到QuartZ执行定时任务,在此记录一下学习过程。
Quartz安装
在VS2022中,通过Nuget包管理器安装Quartz 3.8.1 ,这是.net 6 依赖的最高版本。
创建定时器任务
1、创建QuartzConfigurator
新建QuartzConfiguratorExtensions类,用于注册触发器和任务,代码如下:
////// 添加任务和触发器 /// ////// /// /// public static void AddJobAndTrigger (this IServiceCollectionQuartzConfigurator quartz, IConfiguration config) where T : IJob { // Use the name of the IJob as the appsettings.json key string jobName = typeof(T).Name; // Try and load the schedule from configuration var configKey = $"Quartz:{jobName}"; var cronSchedule = config[configKey]; // Some minor validation if (string.IsNullOrEmpty(cronSchedule)) { throw new Exception($"No Quartz.NET Cron schedule found for job in configuration at {configKey}"); } // register the job as before var jobKey = new JobKey(jobName); quartz.AddJob (opts => opts.WithIdentity(jobKey)); quartz.AddTrigger(opts => opts .ForJob(jobKey) .WithIdentity(jobName + "-trigger") .WithCronSchedule(cronSchedule)); // use the schedule from configuration } /// /// 添加任务和触发器(带参数传递) /// ////// /// /// 需要传递的参数 /// 默认通过 工作描述时传递参数 /// public static void AddJobAndTriggerWithParameter (this IServiceCollectionQuartzConfigurator quartz, IConfiguration config, IDictionary ? keyValuePairs = null, bool isJobDetailJobDataMap = true) where T : IJob { // Use the name of the IJob as the appsettings.json key string jobName = typeof(T).Name; // Try and load the schedule from configuration var configKey = $"Quartz:{jobName}"; var cronSchedule = config[configKey]; // Some minor validation if (string.IsNullOrEmpty(cronSchedule)) { throw new Exception($"No Quartz.NET Cron schedule found for job in configuration at {configKey}"); } // register the job as before var jobKey = new JobKey(jobName); if (keyValuePairs != null && isJobDetailJobDataMap) { switch (isJobDetailJobDataMap) { case true: quartz.AddJob (opts => opts .WithIdentity(jobKey) .UsingJobData(new JobDataMap(keyValuePairs))); quartz.AddTrigger(opts => opts .ForJob(jobKey) .WithIdentity(jobName + "-trigger") .WithCronSchedule(cronSchedule)); // use the schedule from configuration break; case false: quartz.AddJob (opts => opts .WithIdentity(jobKey)); quartz.AddTrigger(opts => opts .ForJob(jobKey) .WithIdentity(jobName + "-trigger") .WithCronSchedule(cronSchedule) .UsingJobData(new JobDataMap(keyValuePairs))); // use the schedule from configuration break; } } else { quartz.AddJob (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 configuration q.AddJobAndTrigger(builder.Configuration); }); builder.Services.AddQuartzHostedService(q => q.WaitForJobsToComplete = true);
3、创建工作单元WorkerJob
新建类TestWorkerJob,并继承IJob,代码如下:
[PersistJobDataAfterExecution]//在执行完成后,保留JobDataMap数据 [DisallowConcurrentExecution]//不允许并发执行,即必须等待上次完成后才能执行下一次 public class TestWorkerJob : IJob { private readonly ILogger_logger; public TestWorkerJob(ILogger 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 * * * * ?" } }
然后,启动项目,就可以看到任务可以正常运行啦。
最后
最后附上学习链接,
.NET6+Quartz实现定时任务
KSO - 在.NET6中项目级使用配置Quartz.NET定时任务,并使用IHostedService实现项目启动自动加载任务,常用的Corn表达式_net6 webapi 在配置中引入注入quartz
到此这篇关于.net 6 配置QuartZ定时任务的文章就介绍到这了,更多相关.net 6 QuartZ定时任务内容请搜索科站长以前的文章或继续浏览下面的相关文章希望大家以后多多支持科站长!
上一篇:如何使用.NET8 创建使用MySQL数据库的webapi项目
栏 目:ASP.NET
下一篇:在.NET6中使用配置Quartz.NET定时任务并使用IHostedService实现项目启动自动加载任务
本文地址:https://fushidao.cc/wangluobiancheng/3229.html
您可能感兴趣的文章
- 03-31详解如何在.NET代码中使用本地部署的Deepseek语言模型
- 02-06.net core如何使用Nacos注册中心
- 01-28使用.NET8构建一个高效的时间日期帮助类
- 01-26.NET Core GC压缩(compact_phase)底层原理解析
- 01-24在ASP.NET中读写TXT文本文件的多种方法
- 01-24在ASP.NET中读写XML数据的多种方法
- 01-24.NET轻松实现Excel转PDF的三种方法详解
- 01-23.NET9 AOT部署方案详解
- 01-23.NET NativeAOT 用法指南
- 01-23iis部署前后端分离项目全过程(Vuet前端和.NET6后端)


阅读排行
推荐教程
- 03-31详解如何在.NET代码中使用本地部署的Deepseek语言模型
- 11-23移动互联网广告有哪些模式?
- 11-22.net 应对网站访问压力的方案总结
- 11-22详解ASP.NET提取多层嵌套json数据的方法
- 11-23网站投放广告如何达到最好的效果
- 11-22.net 应对网站访问压力的方案总结
- 11-23网站打开速度慢解决办法
- 11-23草根站长为什么喜欢做门户站
- 11-22ASP.NET MVC分页问题解决
- 11-22ASP.NET编程简单实现生成静态页面的方法