quartz.net 3.x 使用总结

using System;using System.Collections.Specialized;using System.Threading.Tasks;using Quartz;using Quartz.Impl;using Quartz.Logging;namespace ConsoleApp1{ ???????public class Program ???{ ???????private static void Main(string[] args) ???????{ ???????????LogProvider.SetCurrentLogProvider(new ConsoleLogProvider()); ???????????????RunProgramRunExample().GetAwaiter().GetResult(); ???????????Console.WriteLine("Press any key to close the application"); ???????????Console.ReadKey(); ???????} ???????private static async Task RunProgramRunExample() ???????{ ???????????try ???????????{ ???????????????// Grab the Scheduler instance from the Factory ???????????????NameValueCollection props = new NameValueCollection ???????????????{ ???????????????????{ "quartz.serializer.type", "binary" } ???????????????}; ???????????????StdSchedulerFactory factory = new StdSchedulerFactory(props); ???????????????IScheduler scheduler = await factory.GetScheduler(); ???????????????// and start it off ???????????????await scheduler.Start(); ???????????????// define the job and tie it to our HelloJob class ???????????????IJobDetail job = JobBuilder.Create<HelloJob>() ???????????????????.WithIdentity("job1", "group1") ???????????????????.Build(); ???????????????// Trigger the job to run now, and then repeat every 10 seconds ???????????????ITrigger trigger = TriggerBuilder.Create() ???????????????????.WithIdentity("trigger1", "group1") ???????????????????.StartNow() ???????????????????.WithSimpleSchedule(x => x ???????????????????????.WithIntervalInSeconds(1) ???????????//在这里配置执行延时 ???????????????????????.RepeatForever()) ???????????????????.Build(); ???????????????// Tell quartz to schedule the job using our trigger ???????????????await scheduler.ScheduleJob(job, trigger); ???????????????// some sleep to show what‘s happening// ???????????????await Task.Delay(TimeSpan.FromSeconds(5));// and last shut down the scheduler when you are ready to close your program// ???????????????await scheduler.Shutdown(); ??????????
 ???
//如果解除await Task.Delay(TimeSpan.FromSeconds(5))和await scheduler.Shutdown()的注释，
//5秒后输出"Press any key to close the application"，
//scheduler里注册的任务也会停止。

 ???????????} ???????????catch (SchedulerException se) ???????????{ ???????????????Console.WriteLine(se); ???????????} ???????} ???????// simple log provider to get something to the console ???????private class ConsoleLogProvider : ILogProvider ???????{ ???????????public Logger GetLogger(string name) ???????????{ ???????????????return (level, func, exception, parameters) => ???????????????{ ???????????????????if (level >= LogLevel.Info && func != null) ???????????????????{ ???????????????????????Console.WriteLine("[" + DateTime.Now.ToLongTimeString() + "] [" + level + "] " + func(), parameters); ???????????????????} ???????????????????return true; ???????????????}; ???????????} ???????????public IDisposable OpenNestedContext(string message) ???????????{ ???????????????throw new NotImplementedException(); ???????????} ???????????public IDisposable OpenMappedContext(string key, string value) ???????????{ ???????????????throw new NotImplementedException(); ???????????} ???????} ???} ???public class HelloJob : IJob ???{ ???????public async Task Execute(IJobExecutionContext context) ???????{
　　　　　　　　//任务主体，这里强制要求必须是异步方法，如果不想用异步可以使用quartz 2.x版本 ???????????await Console.Out.WriteLineAsync("Greetings from HelloJob!"); ???????} ???}}