使用mongodb作为Quartz.Net下的JobStore实现底层的持久化机制

public class RAMJobStore: IJobStore
{
....
}

public class JobStoreSupport: IJobStore
{
....
}

//带锁机制
public class JobStoreTX: JobStoreSupport
{
....
}

//不带锁
public class JobStoreCMT: JobStoreSupport
{
....
}

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

 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             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             }

 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 to
14             properties[$"{StdSchedulerFactory.PropertyJobStorePrefix}.{StdSchedulerFactory.PropertyDataSourceConnectionString}"] = "mongodb://192.168.23.163/quartz";
15 
16             // The prefix is optional
17             properties[$"{StdSchedulerFactory.PropertyJobStorePrefix}.collectionPrefix"] = "prefix";
18 
19             var factory = new StdSchedulerFactory(properties);
20 
21             //scheduler
22             IScheduler scheduler = factory.GetScheduler();
23 
24             scheduler.Start();
25 
26             var job = JobBuilder.Create().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         }

 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     }