上一篇說了如何使用 Topshelf 元件快速建立Windows服務，接下來介紹如何使用 Quartz.net
關于Quartz.net的好處，網上搜尋都是一大把一大把的，我就不再多介紹。
先介紹需要用到的插件：
Quartz版本我用的 2.6.2的， 沒有用3.0以上的，因為你用了就會知道，會列印出一大堆坑爹的日志檔案，
我是沒有找到如何屏蔽的辦法，如果你們誰有，歡迎分享出來，我也學習一下，哈哈。
整個項目結構如下：
AppConfigHelper 檔案需要改動一下，增加如下屬性 1 /// <summary>
2 /// 程式辨別
3 /// </summary>
4 [ConfigurationProperty("AppKey", IsRequired = true)]
5 public string AppKey
6 {
7 get { return base["AppKey"].ToString(); }
8 internal set { base["AppKey"] = value; }
9 }
10
11 /// <summary>
12 /// 程式集資訊
13 /// </summary>
14 [ConfigurationProperty("TypeInfo", IsRequired = true)]
15 public string TypeInfo
16 {
17 get { return base["TypeInfo"].ToString(); }
18 internal set { base["TypeInfo"] = value; }
19 } AppConfig檔案也做稍微改動
1 <?xml version="1.0" encoding="utf-8" ?>
2 <configuration>
3 <!--該節點一定要放在最上邊-->
4 <configSections>
5 <section name="AppConfigHelper" type="Quartz.WinService.AppConfigHelper,Quartz.WinService"/>
6 </configSections>
7
8 <!--TopSelf服務配置檔案 -->
9 <AppConfigHelper
10 ServiceName="ProcessPrintLogService"
11 Desc="日志列印服務"
12 AppKey="ProcessPrintLogService"
13 TypeInfo="ProcessService.ProcessPrintLogService,ProcessService"
14 />
15
16 <startup>
17 <supportedRuntime version="v4.0" sku=".NETFramework,Version=v4.5.2" />
18 </startup>
19 </configuration> ProcessPrintLogService 就是Windows服務要執行的邏輯程式檔案，可以執行任何你想要的功能 ProcessService.ProcessPrintLogService,ProcessService 是 命名空間.類名,命名空間 的格式，用于後邊反射程式集用
假如你要執行其他業務邏輯程式，隻需要更換這裡的配置就行， ProcessPrintLogService 業務邏輯内容如下：這就是我們要執行的業務邏輯，定時列印一段日志内容，
可以建立一個類庫，裡邊專門存放你要執行的業務邏輯 1 namespace ProcessService
2 {
3 /// <summary>
4 /// 日志列印服務
5 /// </summary>
6 public class ProcessPrintLogService
7 {
8 private Logger log = LogManager.GetCurrentClassLogger();
9 /// <summary>
10 /// 服務入口
11 /// </summary>
12 public void DoWork()
13 {
14 //log.Info("******************排行榜服務開始執行******************");
15 try
16 {
17 PrintLogMethod();
18 }
19 catch (Exception ex)
20 {
21 log.Error(string.Format("排行榜服務異常，原因：{0}", ex));
22 }
23 finally
24 {
25 //log.Info("******************排行榜服務結束執行******************");
26 }
27 }
28
29
30 private void PrintLogMethod()
31 {
32 log.Trace(string.Format("我是日志:{0}号", Thread.CurrentThread.ManagedThreadId));
33 }
34 }
35 } 然後需要新增加兩個檔案：quartz.config 和 quartz_jobs.xml
quartz.config檔案内容如下：
# You can configure your scheduler in either <quartz> configuration section
# or in quartz properties file
# Configuration section has precedence
quartz.scheduler.instanceName = ServiceQuartzScheduler
# configure thread pool info
quartz.threadPool.type = Quartz.Simpl.SimpleThreadPool, Quartz
quartz.threadPool.threadCount = 10
quartz.threadPool.threadPriority = Normal
# job initialization plugin handles our xml reading, without it defaults are used
quartz.plugin.xml.type = Quartz.Plugin.Xml.XMLSchedulingDataProcessorPlugin, Quartz
quartz.plugin.xml.fileNames = ~/quartz_jobs.xml
# 3.0以上用以下配置
# quartz.plugin.xml.type = Quartz.Plugin.Xml.XMLSchedulingDataProcessorPlugin, Quartz.Plugins
# quartz.plugin.xml.fileNames = ~/quartz_jobs.xml
# export this server to remoting context
# quartz.scheduler.exporter.type = Quartz.Simpl.RemotingSchedulerExporter, Quartz
# quartz.scheduler.exporter.port = 555
# quartz.scheduler.exporter.bindName = QuartzScheduler
# quartz.scheduler.exporter.channelType = tcp
# quartz.scheduler.exporter.channelName = httpQuartz quartz.scheduler.instanceName = ServiceQuartzScheduler 是排程的執行個體名稱，可以随意自定義命名
其他的都是固定的，不需要修改
quartz_jobs.xml 檔案内容如下：
<?xml version="1.0" encoding="UTF-8"?>
<job-scheduling-data xmlns="http://quartznet.sourceforge.net/JobSchedulingData" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" version="2.0">
<processing-directives>
<overwrite-existing-data>true</overwrite-existing-data>
</processing-directives>
<schedule>
<!--排程配置-->
<job>
<name>ProcessPrintLogService</name>
<group>ProcessPrintLogServiceGroup</group>
<description>日志列印服務</description>
<job-type>Quartz.WinService.QuartzWork,Quartz.WinService</job-type>
<durable>true</durable>
<recover>false</recover>
</job>
<trigger>
<cron>
<name>ProcessPrintLogServiceTrigger</name>
<group>ProcessPrintLogServiceTriggerGroup</group>
<job-name>ProcessPrintLogService</job-name>
<job-group>ProcessPrintLogServiceGroup</job-group>
<misfire-instruction>SmartPolicy</misfire-instruction>
<cron-expression>0/3 * * * * ? </cron-expression>
</cron>
</trigger>
</schedule>
</job-scheduling-data> 這個xml配置檔案很重要! 需要重點說下
首先 job節點 和 trigger節點 都可以定義多個，也就是一個服務可以跑多個不同的業務邏輯程式
先說 job節點
- name(必填) 任務名稱，多個job的name不能相同，這裡一般使用業務邏輯程式的名稱就行了
- group(選填) 任務所屬分組，用于辨別任務所屬分組，一般用業務邏輯程式的名稱+Group字尾 如:<group>sampleGroup</group>
- description(選填) 任務描述，用于描述任務具體内容，如:<description>列印日志服務</description>
- job-type(必填) 任務類型，任務的具體類型及所屬程式集，格式：實作了IJob接口的包含完整命名空間的類名,程式集名稱，如:<job-type>Quartz.Server.SampleJob, Quartz.Server</job-type>
- durable(選填) 具體作用不知，官方示例中預設為true，如:<durable>true</durable>
- recover(選填) 具體作用不知，官方示例中預設為false，如:<recover>false</recover>
這裡的 job-type 節點調用的任務類型需要說下，這裡設定的就是上邊項目結構中的 QuartzWork 類，具體内容如下：
namespace Quartz.WinService
{
public class QuartzWork : IJob
{
private Logger log = LogManager.GetCurrentClassLogger();
//ConcurrentDictionary是線程安全的字典集
private readonly ConcurrentDictionary<string, Lazy<Delegate>> _dynamicCache = new ConcurrentDictionary<string, Lazy<Delegate>>();
//記錄目前工作接口是否已經工作
private static readonly Dictionary<string, bool> WorkingNow = new Dictionary<string, bool>();
/// <summary>
/// 任務排程執行入口
/// 實作IJob的Execute方法,在Execute方法裡編寫要處理的業務邏輯，系統就會按照Quartz的配置，定時處理
/// 當Job的trigger觸發的時候, Execute(..) 方法就會在scheduler的工作線程中執行
/// </summary>
/// <param name="context"></param>
public void Execute(IJobExecutionContext context)
{
try
{
Task.Factory.StartNew(() =>
{
var service = AppConfigHelper.Initity();
WorkNow(service);
});
}
catch (Exception ex)
{
log.Fatal($"執行Quartz排程異常，資訊：{ex.Message}");
}
//return Task.FromResult(true); //傳回一個bool類型的Task, Quartz 3.0版本以上需要用到
}
private void WorkNow(AppConfigHelper service)
{
string key = service.AppKey; //key值
lock (this)
{
if (!WorkingNow.ContainsKey(key))
{
WorkingNow.Add(key, false);
}
//如果執行則跳出
if (WorkingNow[key])
{
log.Trace($"服務key:{key} 正在運作,此次服務忽略");
return;
}
//并且設定為執行狀态
WorkingNow[key] = true;
}
try
{
var type = Type.GetType(service.TypeInfo); //這裡通過App.config檔案設定
if (type != null)
{
//建立指定類型的執行個體,相當于通過反射new了一個對象執行個體
var provider = Activator.CreateInstance(type);
Dynamic(provider, "DoWork", key);
}
else
{
log.Error($"任務:{key} 執行個體化失敗");
}
}
catch (Exception ex)
{
log.Fatal($"任務:{key} 執行個體化異常：{ex.Message}");
}
finally
{
WorkingNow[key] = false;
}
}
//Delegate.CreateDelegate 官方定義:用來動态建立指定類型的委托，該委托可以對指定的類執行個體調用的指定的方法。
//簡單來說:就是可以調用指定類裡邊指定的方法,前提是,使用時需要執行個體化該類
//GetOrAdd函數會根據指定key判斷是否存在對應内容,存在則傳回
//DynamicInvoke 動态調用委托方法
//obj參數就是指定類的執行個體化對象,methodName指定類中的方法名
private void Dynamic(object obj, string methodName, string key)
{
var dmc = _dynamicCache.GetOrAdd(key, t => new Lazy<Delegate>(() => Delegate.CreateDelegate(typeof(Action), obj, methodName)));
dmc.Value.DynamicInvoke(); //動态調用委托方法
}
}
} 接下來說 trigger 節點
trigger 任務觸發器，用于定義使用何種方式出發任務(job)，同一個job可以定義多個trigger ，多個trigger 各自獨立的執行排程，
每個trigger 中必須且隻能定義一種觸發器類型(calendar-interval、simple、cron)
說白些就是，假如你要一個服務分别在 上午 8:00~18:00 和 淩晨 00:00 ~ 6:00 這兩個時間段執行任務，那麼你可以設定兩個 trigger 觸發器，
分别設定為這兩個時間段即可實作你要的結果，怎麼樣，很牛X吧
- name(必填) 觸發器名稱，一般以 業務邏輯類+Trigger結尾， 如果需要設定多個 trigger節點，該名稱不能相同
- group(選填) 觸發器組 一般以 業務邏輯類+TriggerGroup結尾，多個 trigger節點，該名稱可以相同
- job-name(必填) 要排程的任務名稱，該job-name必須和對應job節點中的name名稱完全相同
- job-group(選填) 排程任務(job)所屬分組，該值必須和job節點中的group名稱完全相同
- misfire-instruction 不知道幹啥用,這麼寫就行 <misfire-instruction>SmartPolicy</misfire-instruction>
- cron-expression(必填) cron表達式，如:<cron-expression>0/10 * * * * ?</cron-expression>每10秒執行一次
需要注意的是修改了quartz_jobs.xml檔案後，quartz服務預設不會重新加載該檔案，若要讓修改後的檔案生效需要重新開機下服務才行。
另外，quartz.config檔案 和 quartz_jobs.xml檔案 都需要在項目中設定，右鍵-->屬性-->複制到輸出目錄-->始終複制
這裡提供一個線上生成 cron表達式位址： https://cron.qqe2.com
服務注冊檔案 RegistService 增加了自動重新開機功能，完整内容如下：
namespace Quartz.WinService
{
public class RegistService
{
/// <summary>
/// 注冊入口
/// </summary>
/// <param name="config">配置檔案</param>
/// <param name="isreg">是否注冊</param>
public static void Regist(AppConfigHelper config, bool isreg = false)
{
//這裡也可以使用HostFactory.Run()代替HostFactory.New()
var host = HostFactory.New(x =>
{
x.Service<QuartzHost>(s =>
{
//通過 new QuartzHost() 建構一個服務執行個體
s.ConstructUsing(name => new QuartzHost());
//當服務啟動後執行什麼
s.WhenStarted(tc => tc.Start());
//當服務停止後執行什麼
s.WhenStopped(tc => tc.Stop());
//當服務暫停後執行什麼
s.WhenPaused(w => w.Stop());
//當服務繼續後執行什麼
s.WhenContinued(w => w.Start());
});
if (!isreg) return; //false表示不注冊
//服務用本地系統賬号來運作
x.RunAsLocalSystem();
//啟用自動重新開機服務
x.EnableServiceRecovery(v =>
{
v.RestartService(2); //2分鐘後重新開機
});
//服務的描述資訊
x.SetDescription(config.Description);
//服務的顯示名稱
x.SetDisplayName(config.ServiceName);
//服務的名稱（最好不要包含空格或者有空格屬性的字元）Windows 服務名稱不能重複。
x.SetServiceName(config.ServiceName);
}).Run(); //啟動服務 如果使用HostFactory.Run()則不需要該方法
}
}
} 服務注冊中調用的 QuartzHost 類内容如下：
namespace Quartz.WinService
{
public class QuartzHost
{
private Logger log = LogManager.GetCurrentClassLogger();
private readonly IScheduler scheduler;
public QuartzHost()
{
//初始化排程服務
//scheduler = StdSchedulerFactory.GetDefaultScheduler().Result; //3.0以上寫法
scheduler = StdSchedulerFactory.GetDefaultScheduler();
}
/// <summary>
/// 排程開始
/// </summary>
public void Start()
{
try
{
scheduler.Start();
log.Info("Quartz排程服務開始工作");
}
catch (Exception ex)
{
log.Fatal(string.Format("Quartz排程服務開始異常！錯誤資訊：{0}", ex));
throw;
}
}
/// <summary>
/// 排程停止
/// </summary>
public void Stop()
{
try
{
if (scheduler != null)
{
scheduler.Shutdown(true);
}
log.Info("Quartz排程服務結束工作");
}
catch (Exception ex)
{
log.Fatal(string.Format("Quartz排程服務停止異常！錯誤資訊：{0}", ex));
throw;
}
}
}
} 項目檔案位址：https://gitee.com/gitee_zhang/Quartz.WinService.git
參考文檔： https://blog.csdn.net/clb929/article/details/90341485
https://blog.csdn.net/weixin_33948416/article/details/92989386
https://www.cnblogs.com/lzrabbit/archive/2012/04/14/2446942.html
作者：PeterZhang
出處：https://www.cnblogs.com/peterzhang123
本文版權歸作者和部落格園共有，歡迎轉載，但必須給出原文連結，并保留此段聲明，否則保留追究法律責任的權利。