博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
.net core中Quartz的使用
阅读量:5310 次
发布时间:2019-06-14

本文共 4111 字,大约阅读时间需要 13 分钟。

原来工作中有用到定时任务Quartz,不过是在MVC项目中,现在net core项目中也要用到,就开始改版。中间发现在网上的教程只有执行定时计划的过程,却很少有人写注册的过程,觉得有点略坑。所以写此文章一是自己做个记录,二是希望能帮助到其他人。后面还把此功能做出了多任务定时执行,网上关于net core的教程更是少了,花费了不少时间实现了出来。

Quartz版本:3.0.7

1.NuGet中下载安装Quartz

2.新建Quartz帮助类

 (1)新建QuartzJob类,代码如下:

public class QuartzJob : IJob    {        public async Task Execute(IJobExecutionContext context)        {            var jobKey = context.JobDetail.Key;//获取job信息            var triggerKey = context.Trigger.Key;//获取trigger信息            LogHelper.Info($"{DateTime.Now} QuartzJob:==>>自动执行.{jobKey.Name}|{triggerKey.Name}");            await Task.CompletedTask;        }    }

  ps: 上面代码中的jobKey和triggerKey可获取到自己定义的job和trigger的信息,这样做多任务时可区分要执行的是哪个任务. 另LogHelper.Info是自己封装好的日子记录类,可替换为自己的日志类

(2)新建QuartzFactory类,代码如下: 

public class QuartzFactory : IJobFactory    {        private readonly IServiceProvider _serviceProvider;        public QuartzFactory(IServiceProvider serviceProvider)        {            _serviceProvider = serviceProvider;        }        public IJob NewJob(TriggerFiredBundle bundle, IScheduler scheduler)        {            var jobDetail = bundle.JobDetail;            var job = (IJob)_serviceProvider.GetService(jobDetail.JobType);            return job;        }        public void ReturnJob(IJob job)        {        }    }

 (3)新建QuartzService类,代码如下:

#region 单任务        public static void StartJob
() where TJob : IJob { var scheduler = new StdSchedulerFactory().GetScheduler().Result; var job = JobBuilder.Create
() .WithIdentity("job") .Build(); var trigger1 = TriggerBuilder.Create() .WithIdentity("job.trigger") .StartNow() .WithSimpleSchedule(x => x.WithInterval(TimeSpan.FromSeconds(5)).RepeatForever()) .ForJob(job) .Build(); scheduler.AddJob(job, true); scheduler.ScheduleJob(job, trigger1); scheduler.Start(); } #endregion #region 多任务 public static void StartJobs
() where TJob : IJob { var scheduler = new StdSchedulerFactory().GetScheduler().Result; var job = JobBuilder.Create
() .WithIdentity("jobs") .Build(); var trigger1 = TriggerBuilder.Create() .WithIdentity("job.trigger1") .StartNow() .WithSimpleSchedule(x => x.WithInterval(TimeSpan.FromSeconds(5)).RepeatForever()) .ForJob(job) .Build(); var trigger2 = TriggerBuilder.Create() .WithIdentity("job.trigger2") .StartNow() .WithSimpleSchedule(x => x.WithInterval(TimeSpan.FromSeconds(11)).RepeatForever()) .ForJob(job) .Build(); var dictionary = new Dictionary
> { {job, new HashSet
{trigger1, trigger2}} }; scheduler.ScheduleJobs(dictionary, true); scheduler.Start(); } #endregion #region 配置 public static void AddQuartz(this IServiceCollection services, params Type[] jobs) { services.AddSingleton
(); services.Add(jobs.Select(jobType => new ServiceDescriptor(jobType, jobType, ServiceLifetime.Singleton))); services.AddSingleton(provider => { var schedulerFactory = new StdSchedulerFactory(); var scheduler = schedulerFactory.GetScheduler().Result; scheduler.JobFactory = provider.GetService
(); scheduler.Start(); return scheduler; }); } #endregion

3.在Startup.cs中注册代码

public void ConfigureServices(IServiceCollection services){            services.AddQuartz(typeof(QuartzJob));            //........}public void Configure(IApplicationBuilder app, IHostingEnvironment env, ILoggerFactory loggerFactory){    QuartzService.StartJobs
(); //........}

 ps: 因AddQuartz方法定义的是Type[]类型,所以可传多个执行类,如:services.AddQuartz(typeof(QuartzJob1), typeof(QuartzJob2)); 不过这样做StartJob()方法就得另处理下,这里就略过

 

OK,大功告成,这个东西折腾了两天终于尘埃落定了,执行结果如下:

 

转载于:https://www.cnblogs.com/dangzhensheng/p/10496278.html

你可能感兴趣的文章
数组--冒泡排序法
查看>>
.NET 中list和数组与字符串的相互转换
查看>>
7月11日实习日志
查看>>
classmethod和staticmethod
查看>>
MapReduce源码分析之Task中关于对应TaskAttempt存储Map方案的一些思考
查看>>
python中的__all__和__slots__
查看>>
【题解】SHOI2014概率充电器
查看>>
006_Python3 数字(Number)
查看>>
SVN发布网站
查看>>
实现一个可host asp.net程序的小型IIS(Cassinidev介绍)
查看>>
计算机加入域vbs脚本
查看>>
SqlMapConfig.xml配置文件详解
查看>>
Mapper
查看>>
数据结构与算法实验题 9.2 材料
查看>>
java 开发业务逻辑的思考(1)- 通知短信发送
查看>>
如何在修改bug时切换分支保留修改又不提交
查看>>
【CSON原创】javascript实现3D房间
查看>>
第四步 部分细节
查看>>
FPGA的软核、硬核以及固核的概念
查看>>
Remote Desktop Connection Manager (RDCMan) 介绍
查看>>