[C#]使用Quartz.NET來創建定時工作任務



本文為原創文章、源代碼為原創代碼,如轉載/復制,請在網頁/代碼處明顯位置標明原文名稱、作者及網址,謝謝!


開發工具:VS2017

語言:C#

DotNet版本:.Net FrameWork 4.0及以上

一、安裝Quartz

在“程序包管理器控制台”輸入(下划線所示):

PM> Install-Package Quartz

安裝完畢之后,引用的DLL如下:

二、編寫以下代碼(具體見注釋)

 1 using Quartz;
 2 using Quartz.Impl;
 3 using System;
 4 using System.Threading;
 5 
 6 namespace QuartzConsoleApp
 7 {
 8     class Program
 9     {
10         static void Main(string[] args)
11         {
12             //創建一個標准調度器工廠
13             ISchedulerFactory factory = new StdSchedulerFactory();
14             //通過從標准調度器工廠獲得一個調度器,用來啟動任務
15             IScheduler scheduler =  factory.GetScheduler();
16             //調度器的線程開始執行,用以觸發Trigger
17             scheduler.Start();
18 
19             //使用組別、名稱創建一個工作明細,此處為所需要執行的任務
20             IJobDetail detail1 = JobBuilder.Create<MyFirstJob>().WithIdentity("MyJob1", "MyGroup").Build();
21             //通過使用UsingJobData添加傳遞到context(類型:IJobExecutionContext)的屬性
22             IJobDetail detail2 = JobBuilder.Create<MySecondJob>().WithIdentity("MyJob2", "MyGroup").UsingJobData("Title","Hello World").
23                 UsingJobData("Pi",Math.PI).UsingJobData("Cnxy","http://www.cnc6.cn").Build();
24             IJobDetail detail3 = JobBuilder.Create<MyThridJob>().WithIdentity("MyJob3", "MyGroup").Build();
25             //使用組別、名稱創建一個觸發器,其中觸發器立即執行,且每隔1秒或3秒執行一個任務,重復執行
26             ITrigger trigger1 = TriggerBuilder.Create().WithIdentity("MyTrigger1", "MyGroup").StartNow().WithSimpleSchedule(x => x.WithIntervalInSeconds(1).RepeatForever()).Build();
27             ITrigger trigger2 = TriggerBuilder.Create().WithIdentity("MyTrigger2", "MyGroup").StartNow().WithSimpleSchedule(x => x.WithIntervalInSeconds(3).RepeatForever()).Build();
28             ITrigger trigger3 = TriggerBuilder.Create().WithIdentity("MyTrigger3", "MyGroup").StartNow().WithSimpleSchedule(x => x.WithIntervalInSeconds(2).RepeatForever()).Build();
29             //開始執行使用指定的觸發器運行執行的工作任務
30             scheduler.ScheduleJob(detail1, trigger1);
31             scheduler.ScheduleJob(detail2, trigger2);
32             scheduler.ScheduleJob(detail3, trigger3);
33         }
34     }
35     //運行並發運行
36     class MyFirstJob : IJob
37     {
38         public void Execute(IJobExecutionContext context)
39         {
40             //JobDetail.Key:標識JobDetail的唯一ID
41             //Trigger.Key:標識Trigger的唯一ID
42             Console.WriteLine($"1,現在時間:{DateTime.Now:yyyy-MM-dd HH:mm:ss}," +
43                 $"工作明細:{context.JobDetail.Key.Name},工作觸發器:{context.Trigger.Key.Name}");
44         }
45     }
46     //運行並發運行
47     class MySecondJob : IJob
48     {
49         //獲得值的方式:3、屬性注入
50         public string Cnxy { set; get; }
51         public void Execute(IJobExecutionContext context)
52         {
53             //獲得值的方式:1、通過IJobExecutionContext.JobDetail.JobDataMap["Key"]獲得所對應的值
54             string value1 = (string)context.JobDetail.JobDataMap["Title"];
55             //獲得值的方式:2、也可以通過IJobExecutionContext.MergedJobDataMap["Key"]獲得所對應的值
56             double value2 = (double)context.MergedJobDataMap["Pi"];
57             Console.WriteLine($"2,現在時間:{DateTime.Now:yyyy-MM-dd HH:mm:ss}," +
58                 $"Title:{value1},Pi:{value2},CNXY:{Cnxy}");
59         }
60     }
61 
62     //不運行並發運行
63     [DisallowConcurrentExecution]
64     class MyThridJob : IJob
65     {
66         public void Execute(IJobExecutionContext context)
67         {
68             Console.WriteLine($"3,現在時間:{DateTime.Now:yyyy-MM-dd HH:mm:ss}");
69             Thread.Sleep(3);
70         }
71     }
72 
73 }

以上代碼使用一個調度器(Scheduler)來運行一個指定的觸發器(Trigger,包含運行時間間隔)並觸發工作任務(JobDetail)。

三、運行結果如下:

四、參考鏈接:https://www.cnblogs.com/uptothesky/p/5633421.html


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM