发布：2023/4/7 10:56:01作者：管理员 来源：本站 浏览次数：780
开发工具：VS2017
语言：C#
DotNet版本：.Net FrameWork 4.0及以上
一、安装Quartz
在“程序包管理器控制台”输入（下划线所示）：
PM> Install-Package Quartz
安装完毕之后，引用的DLL如下：
二、编写以下代码（具体见注释）
using Quartz;
using Quartz.Impl;
using System;
using System.Threading;
namespace QuartzConsoleApp
{
class Program
{
static void Main(string[] args)
{
//创建一个标准调度器工厂
ISchedulerFactory factory = new StdSchedulerFactory();
//通过从标准调度器工厂获得一个调度器，用来启动任务
IScheduler scheduler = factory.GetScheduler();
//调度器的线程开始执行，用以触发Trigger
scheduler.Start();
//使用组别、名称创建一个工作明细，此处为所需要执行的任务
IJobDetail detail1 = JobBuilder.Create<MyFirstJob>().WithIdentity("MyJob1", "MyGroup").Build();
//通过使用UsingJobData添加传递到context(类型：IJobExecutionContext)的属性
IJobDetail detail2 = JobBuilder.Create<MySecondJob>().WithIdentity("MyJob2", "MyGroup").UsingJobData("Title","Hello World").
UsingJobData("Pi",Math.PI).UsingJobData("Cnxy","http://www.cnc6.cn").Build();
IJobDetail detail3 = JobBuilder.Create<MyThridJob>().WithIdentity("MyJob3", "MyGroup").Build();
//使用组别、名称创建一个触发器，其中触发器立即执行，且每隔1秒或3秒执行一个任务，重复执行
ITrigger trigger1 = TriggerBuilder.Create().WithIdentity("MyTrigger1", "MyGroup").StartNow().WithSimpleSchedule(x => x.WithIntervalInSeconds().RepeatForever()).Build();
ITrigger trigger2 = TriggerBuilder.Create().WithIdentity("MyTrigger2", "MyGroup").StartNow().WithSimpleSchedule(x => x.WithIntervalInSeconds().RepeatForever()).Build();
ITrigger trigger3 = TriggerBuilder.Create().WithIdentity("MyTrigger3", "MyGroup").StartNow().WithSimpleSchedule(x => x.WithIntervalInSeconds().RepeatForever()).Build();
//开始执行使用指定的触发器运行执行的工作任务
scheduler.ScheduleJob(detail1, trigger1);
scheduler.ScheduleJob(detail2, trigger2);
scheduler.ScheduleJob(detail3, trigger3);
}
}
//运行并发运行
class MyFirstJob : IJob
{
public void Execute(IJobExecutionContext context)
{
//JobDetail.Key：标识JobDetail的唯一ID
//Trigger.Key：标识Trigger的唯一ID
Console.WriteLine($"1,现在时间：{DateTime.Now:yyyy-MM-dd HH:mm:ss}，" +
$"工作明细：{context.JobDetail.Key.Name}，工作触发器：{context.Trigger.Key.Name}");
}
}
//运行并发运行
class MySecondJob : IJob
{
//获得值的方式：3、属性注入
public string Cnxy { set; get; }
public void Execute(IJobExecutionContext context)
{
//获得值的方式：1、通过IJobExecutionContext.JobDetail.JobDataMap["Key"]获得所对应的值
string value1 = (string)context.JobDetail.JobDataMap["Title"];
//获得值的方式：2、也可以通过IJobExecutionContext.MergedJobDataMap["Key"]获得所对应的值
double value2 = (double)context.MergedJobDataMap["Pi"];
Console.WriteLine($"2,现在时间：{DateTime.Now:yyyy-MM-dd HH:mm:ss}，" +
$"Title：{value1}，Pi：{value2}，CNXY：{Cnxy}");
}
}
//不运行并发运行
[DisallowConcurrentExecution]
class MyThridJob : IJob
{
public void Execute(IJobExecutionContext context)
{
Console.WriteLine($"3,现在时间：{DateTime.Now:yyyy-MM-dd HH:mm:ss}");
Thread.Sleep();
}
}
}
以上代码使用一个调度器（Scheduler）来运行一个指定的触发器（Trigger，包含运行时间间隔）并触发工作任务（JobDetail）。
三、运行结果如下：
