原來(lái)工作中有用到定時(shí)任務(wù)Quartz,不過(guò)是在MVC項(xiàng)目中,現(xiàn)在net core項(xiàng)目中也要用到,就開(kāi)始改版。中間發(fā)現(xiàn)在網(wǎng)上的教程只有執(zhí)行定時(shí)計(jì)劃的過(guò)程,卻很少有人寫(xiě)注冊(cè)的過(guò)程,覺(jué)得有點(diǎn)略坑。所以寫(xiě)此文章一是自己做個(gè)記錄,二是希望能幫助到其他人。后面還把此功能做出了多任務(wù)定時(shí)執(zhí)行,網(wǎng)上關(guān)于net core的教程更是少了,花費(fèi)了不少時(shí)間實(shí)現(xiàn)了出來(lái)。
Quartz版本:3.0.7
1.NuGet中下載安裝Quartz
2.新建Quartz幫助類(lèi)
(1)新建QuartzJob類(lèi),代碼如下:
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:==>>自動(dòng)執(zhí)行.{jobKey.Name}|{triggerKey.Name}"); await Task.CompletedTask; } }
ps: 上面代碼中的jobKey和triggerKey可獲取到自己定義的job和trigger的信息,這樣做多任務(wù)時(shí)可區(qū)分要執(zhí)行的是哪個(gè)任務(wù). 另LogHelper.Info是自己封裝好的日子記錄類(lèi),可替換為自己的日志類(lèi)
(2)新建QuartzFactory類(lèi),代碼如下:
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類(lèi),代碼如下:
#region 單任務(wù) public static void StartJob<TJob>() where TJob : IJob { var scheduler = new StdSchedulerFactory().GetScheduler().Result; var job = JobBuilder.Create<TJob>() .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 多任務(wù) public static void StartJobs<TJob>() where TJob : IJob { var scheduler = new StdSchedulerFactory().GetScheduler().Result; var job = JobBuilder.Create<TJob>() .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<IJobDetail, IReadOnlyCollection<ITrigger>> { {job, new HashSet<ITrigger> {trigger1, trigger2}} }; scheduler.ScheduleJobs(dictionary, true); scheduler.Start(); } #endregion #region 配置 public static void AddQuartz(this IServiceCollection services, params Type[] jobs) { services.AddSingleton<IJobFactory, QuartzFactory>(); 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<IJobFactory>(); scheduler.Start(); return scheduler; }); } #endregion
3.在Startup.cs中注冊(cè)代碼
public void ConfigureServices(IServiceCollection services) { services.AddQuartz(typeof(QuartzJob)); //........ } public void Configure(IApplicationBuilder app, IHostingEnvironment env, ILoggerFactory loggerFactory) { QuartzService.StartJobs<QuartzJob>(); //........ }
ps: 因AddQuartz方法定義的是Type[]類(lèi)型,所以可傳多個(gè)執(zhí)行類(lèi),如:services.AddQuartz(typeof(QuartzJob1), typeof(QuartzJob2)); 不過(guò)這樣做StartJob()方法就得另處理下,這里就略過(guò)
OK,大功告成,這個(gè)東西折騰了兩天終于塵埃落定了,執(zhí)行結(jié)果如下:
以上就是本文的全部?jī)?nèi)容,希望對(duì)大家的學(xué)習(xí)有所幫助,也希望大家多多支持服務(wù)器之家。