我們都知道默認的Quartz底層采用的是RAMJobStore，所有的Job,Trigger,Calendar都是用Dictionary,SortSet等等這樣的數(shù)據(jù)結構進行儲存，相對來說性
能肯定快的沒法說，但是面對災難重啟的時候還是很拿不出手的，而且都是全內存的，也沒法實現(xiàn)多機器搭建Quartz集群，這一點還是很討厭，雖然官方已經
提供了一些關系性持久化存儲方案，但面對如今這么火的nosql，不進行官方支持還是有點可惜，不過基于Quartz本身的插拔式設計，一切都不是問題。
一：IJobStore
從github上下載源碼：https://github.com/quartznet/quartznet，從源碼你會發(fā)現(xiàn)IJobStore幾乎實現(xiàn)了所有對Trigger,Job和Scheduler所有的容器管理操作。
然后你可以看到它的幾個實現(xiàn)子類，全內存的RAMJobStore。
public class RAMJobStore: IJobStore
{
....
}
以及JobStoreSupport下的帶鎖JobStoreTX和不帶鎖的JobStoreCMT。
public class JobStoreSupport: IJobStore
{
....
}//帶鎖機制public class JobStoreTX: JobStoreSupport
{
....
}//不帶鎖public class JobStoreCMT: JobStoreSupport
{
....
}
所以你應該明白，本節(jié)課跟大家講到的Redis和Mongodb的JobStore存儲，必然也是實現(xiàn)了IJobStore接口，對吧。
二：MongoDB的JobStore
1. 安裝mongodb
既然要使用mongodb，你必然要有mongodb的安裝程序，可以去官網： wget https://fastdl.mongodb.org/linux/mongodb-linux-x86_64-3.4.5.tgz 一下，
這里我采用linux平臺的centos。
2. nuget上pull些dll
大家可以在nuget控制臺執(zhí)行Install-Package Quartz.Spi.MongoDbJobStore，如下所示：
PM> Install-Package Quartz.Spi.MongoDbJobStore 正在嘗試收集與目標為“.NETFramework,Version=v4.5.2”的項目“ConsoleApplication1”有關的包“Quartz.Spi.MongoDbJobStore.2.0.0”的依賴項信息 正在嘗試解析程序包“Quartz.Spi.MongoDbJobStore.2.0.0”的依賴項，DependencyBehavior 為“Lowest” 正在解析操作以安裝程序包“Quartz.Spi.MongoDbJobStore.2.0.0” 已解析操作以安裝程序包“Quartz.Spi.MongoDbJobStore.2.0.0” 正在將程序包“Common.Logging.Core.3.3.1”添加到文件夾“C:\1\ConsoleApplication1\packages” 已將程序包“Common.Logging.Core.3.3.1”添加到文件夾“C:\1\ConsoleApplication1\packages” 已將程序包“Common.Logging.Core.3.3.1”添加到“packages.config” 已將“Common.Logging.Core 3.3.1”成功安裝到 ConsoleApplication1 正在將程序包“Common.Logging.3.3.1”添加到文件夾“C:\1\ConsoleApplication1\packages” 已將程序包“Common.Logging.3.3.1”添加到文件夾“C:\1\ConsoleApplication1\packages” 已將程序包“Common.Logging.3.3.1”添加到“packages.config” 已將“Common.Logging 3.3.1”成功安裝到 ConsoleApplication1 正在將程序包“MongoDB.Bson.2.4.2”添加到文件夾“C:\1\ConsoleApplication1\packages” 已將程序包“MongoDB.Bson.2.4.2”添加到文件夾“C:\1\ConsoleApplication1\packages” 已將程序包“MongoDB.Bson.2.4.2”添加到“packages.config” 已將“MongoDB.Bson 2.4.2”成功安裝到 ConsoleApplication1 正在將程序包“Quartz.2.4.1”添加到文件夾“C:\1\ConsoleApplication1\packages” 已將程序包“Quartz.2.4.1”添加到文件夾“C:\1\ConsoleApplication1\packages” 已將程序包“Quartz.2.4.1”添加到“packages.config” 已將“Quartz 2.4.1”成功安裝到 ConsoleApplication1 正在將程序包“System.Runtime.InteropServices.RuntimeInformation.4.3.0”添加到文件夾“C:\1\ConsoleApplication1\packages” 已將程序包“System.Runtime.InteropServices.RuntimeInformation.4.3.0”添加到文件夾“C:\1\ConsoleApplication1\packages” 已將程序包“System.Runtime.InteropServices.RuntimeInformation.4.3.0”添加到“packages.config” 已將“System.Runtime.InteropServices.RuntimeInformation 4.3.0”成功安裝到 ConsoleApplication1 正在將程序包“MongoDB.Driver.Core.2.4.2”添加到文件夾“C:\1\ConsoleApplication1\packages” 已將程序包“MongoDB.Driver.Core.2.4.2”添加到文件夾“C:\1\ConsoleApplication1\packages” 已將程序包“MongoDB.Driver.Core.2.4.2”添加到“packages.config” 已將“MongoDB.Driver.Core 2.4.2”成功安裝到 ConsoleApplication1 正在將程序包“MongoDB.Driver.2.4.2”添加到文件夾“C:\1\ConsoleApplication1\packages” 已將程序包“MongoDB.Driver.2.4.2”添加到文件夾“C:\1\ConsoleApplication1\packages” 已將程序包“MongoDB.Driver.2.4.2”添加到“packages.config” 已將“MongoDB.Driver 2.4.2”成功安裝到 ConsoleApplication1 正在將程序包“Quartz.Spi.MongoDbJobStore.2.0.0”添加到文件夾“C:\1\ConsoleApplication1\packages” 已將程序包“Quartz.Spi.MongoDbJobStore.2.0.0”添加到文件夾“C:\1\ConsoleApplication1\packages” 已將程序包“Quartz.Spi.MongoDbJobStore.2.0.0”添加到“packages.config” 已將“Quartz.Spi.MongoDbJobStore 2.0.0”成功安裝到 ConsoleApplication1
也可以到github中下載源碼：https://github.com/chrisdrobison/mongodb-quartz-net
3. 啟動運行
然后可以看一下此頁面上的Basic Usage##上的默認配置：
1 var properties = new NameValueCollection(); 2 properties[StdSchedulerFactory.PropertySchedulerInstanceName] = instanceName; 3 properties[StdSchedulerFactory.PropertySchedulerInstanceId] = $"{Environment.MachineName}-{Guid.NewGuid()}"; 4 properties[StdSchedulerFactory.PropertyJobStoreType] = typeof (MongoDbJobStore).AssemblyQualifiedName; 5 // I treat the database in the connection string as the one you want to connect to 6 properties[$"{StdSchedulerFactory.PropertyJobStorePrefix}.{StdSchedulerFactory.PropertyDataSourceConnectionString}"] = "mongodb://localhost/quartz"; 7 // The prefix is optional 8 properties[$"{StdSchedulerFactory.PropertyJobStorePrefix}.collectionPrefix"] = "prefix"; 9 10 var scheduler = new StdSchedulerFactory(properties);11 return scheduler.GetScheduler();
<1> PropertySchedulerInstanceName： 就是對Scheduler的Name進行的配置，大家可以根據(jù)情況定義一個簡明釋義的名字。
<2> PropertySchedulerInstanceId： 可以看到這個項采用的是machineName+NewGuid來保證Scheduler容器的SchedulerID唯一，唯一性特別重要，因為在
Cluster 中就是用它來保證唯一性的,不過上面的代碼有點累贅，其實只要寫上“AUTO”就可以了，由底層的
SimpleInstanceIdGenerator來保證uniqueID的生成，如StdSchedulerFactory.Instantiate方法源碼所示：
1 if (schedInstId.Equals(AutoGenerateInstanceId)) 2 { 3 autoId = true; 4 instanceIdGeneratorType = LoadType(cfg.GetStringProperty(PropertySchedulerInstanceIdGeneratorType)) ?? typeof(SimpleInstanceIdGenerator); 5 } 6 else if (schedInstId.Equals(SystemPropertyAsInstanceId)) 7 { 8 autoId = true; 9 instanceIdGeneratorType = typeof(SystemPropertyInstanceIdGenerator);10 }
<3> PropertyJobStoreType：這個屬性將MongoDbJobStore作為底層的IJobStore實現(xiàn)者。
<4> PropertyDataSourceConnectionString,collectionPrefix： 這兩個沒什么好說的，一個是mongodb的connectionstring，一個是collection的前綴。
好了，下面就是我的完整代碼：
1 static void Main(string[] args) 2 { 3 4 LogManager.Adapter = new Common.Logging.Simple.TraceLoggerFactoryAdapter() 5 { 6 Level = LogLevel.All 7 }; 8 9 var properties = new NameValueCollection();10 properties[StdSchedulerFactory.PropertySchedulerInstanceId] = "AUTO";11 properties[StdSchedulerFactory.PropertyJobStoreType] = typeof(MongoDbJobStore).AssemblyQualifiedName;12 13 // I treat the database in the connection string as the one you want to connect to14 properties[$"{StdSchedulerFactory.PropertyJobStorePrefix}.{StdSchedulerFactory.PropertyDataSourceConnectionString}"] = "mongodb://192.168.23.163/quartz";15 16 // The prefix is optional17 properties[$"{StdSchedulerFactory.PropertyJobStorePrefix}.collectionPrefix"] = "prefix";18 19 var factory = new StdSchedulerFactory(properties);20 21 //scheduler22 IScheduler scheduler = factory.GetScheduler();23 24 scheduler.Start();25 26 var job = JobBuilder.Create<HelloJob>().WithIdentity("test", "datamip").Build();27 28 var trigger = TriggerBuilder.Create().WithCronSchedule("* * * * * ?").Build();29 30 if (!scheduler.CheckExists(job.Key))31 {32 scheduler.ScheduleJob(job, trigger);33 }34 35 Console.Read();36 }
這個我自定義的HelloJob中，我特意記錄一下scheduler的調度時間schedulertime和Trigger應該觸發(fā)的時間nextFireTime。
1 class HelloJob : IJob 2 { 3 static int index = 1; 4 5 public void Execute(IJobExecutionContext context) 6 { 7 Console.WriteLine("{4} index={0},current={1}, scheuler={2},nexttime={3}", 8 index++, DateTime.Now, 9 context.ScheduledFireTimeUtc?.LocalDateTime,10 context.NextFireTimeUtc?.LocalDateTime,11 context.JobDetail.JobDataMap["key"]);12 }13 }
接下來執(zhí)行一下：
然后通過robomongo到數(shù)據(jù)庫看一下，有5個collection，里面都有數(shù)據(jù)，沒毛病。
好了，本篇就說到這里了，當然還有基于redis的JobStore，有興趣大家可以自己嘗試一下。
http://www.cnblogs.com/huangxincheng/p/7078895.html
延伸閱讀
- 騰訊員工人均年薪84.7萬，馬化騰：員工心理健康最重要 2022-07-12
- 前路漫漫，唯劍作伴 2021-05-19
- 突破迷茫，實現(xiàn)自我 ——王*鑫 2020-06-11
- 在萬碼學堂實現(xiàn)了我的人生夢想 2017-11-29
- Swift實現(xiàn)JSON轉Model - HandyJSON使用講解 2017-07-26
- Android高仿qq及微信底部菜單的幾種實現(xiàn)方式 2017-07-26
- ASP.NET Core Web API 最小化項目 2017-07-26
- 【前端】一步一步使用webpack+react+scss腳手架重構項目 2017-07-26
- 【原創(chuàng)】 Docker 中 運行 ASP.NET Core 站點 2017-07-26
- 安卓平臺使用pocketSphinx離線語音識別 2017-07-26
騰訊員工人均年薪84.7萬，馬化騰：員工心理健康最重要