quartz.net 任務調度分布式，動態添加（1）

try
{
//1.首先創建一個作業調度池
var properties = new NameValueCollection();

properties["quartz.threadPool.type"] = "Quartz.Simpl.SimpleThreadPool, Quartz";
properties["quartz.threadPool.threadCount"] = "10";
properties["quartz.threadPool.threadPriority"] = "Normal";

//存儲類型
properties["quartz.jobStore.type"] = "Quartz.Impl.AdoJobStore.JobStoreTX, Quartz";

//驅動類型
properties["quartz.jobStore.driverDelegateType"] = "Quartz.Impl.AdoJobStore.SqlServerDelegate, Quartz"; //數據源名稱
properties["quartz.jobStore.dataSource"] = "myDS";

//連接字符串
properties["quartz.dataSource.myDS.connectionString"] = @"server=.;Initial Catalog=quartz;Integrated Security=True";
//sqlserver版本
properties["quartz.dataSource.myDS.provider"] = "SqlServer-20";

//是否集群
properties["quartz.jobStore.clustered"] = "true";
properties["quartz.scheduler.instanceId"] = "AUTO";

var factory = new StdSchedulerFactory(properties);

IScheduler scheduler = factory.GetScheduler();

scheduler.Start();
ISchedulerFactory schedFact = new StdSchedulerFactory(properties);
IScheduler sched = schedFact.GetScheduler();
var jobKey = JobKey.Create("myjob1", "group");

if (sched.CheckExists(jobKey))
{
Console.WriteLine("當前job已經存在，無需調度:{0}", jobKey.ToString());
}
else
{
IJobDetail job = JobBuilder.Create<HelloJob>()
.WithDescription("使用quartz進行持久化存儲")
.StoreDurably()
.RequestRecovery()
.WithIdentity(jobKey)
.UsingJobData("count", 1)
.Build();

var trigger = TriggerBuilder.Create()
.WithIdentity("myjob1", "group")
.WithCronSchedule("/10 * * * * ?")
.Build();
//ITrigger trigger = TriggerBuilder.Create().WithSimpleSchedule(x => x.WithIntervalInSeconds(2).RepeatForever()).Build();

sched.ScheduleJob(job, trigger);

Console.WriteLine("調度進行中！！！");
}
}
catch (SchedulerException se)
{
Console.WriteLine(se);
}