Quartz.NET
由于要同时执行多个计划。复制了一份FeedingSchedule，各自实例化了调度器，执行时报错说数据库哪重复了
1.多个计划，怎样指向同一数据库，并可以重启后各自恢复
2.由于多个计划共享同一个job，怎样避免并发执行同一个job(我用了锁+DisallowConcurrentExecution，不知这样可行吗？)
private async Task FeedingSchedule()
{
await Task.Run(() => {
//实例化调度器
NameValueCollection pars = new NameValueCollection
{
//线程池个数20
["quartz.threadPool.threadCount"] = "20",
//scheduler名字
["quartz.scheduler.instanceName"] = "MyAdoJobStoreScheduler",
//类型为JobStoreXT,事务
["quartz.jobStore.type"] = "Quartz.Impl.AdoJobStore.JobStoreTX, Quartz",
//数据源名称
["quartz.jobStore.dataSource"] = "QuartzDb",
//使用mysql的Ado操作代理类
["quartz.jobStore.driverDelegateType"] = "Quartz.Impl.AdoJobStore.MySQLDelegate, Quartz",
//数据源连接字符串
["quartz.dataSource.QuartzDb.connectionString"] = @"server=127.0.0.1;Database=quartzmanager;user id=root;password=123;SslMode=none;",
//数据源的数据库
["quartz.dataSource.QuartzDb.provider"] = "MySql",
//序列化类型
["quartz.serializer.type"] = "json",
//自动生成scheduler实例ID，主要为了保证集群中的实例具有唯一标识
["quartz.scheduler.instanceId"] = "AUTO"
};
//实例化调度器
ISchedulerFactory schedulefactory = new StdSchedulerFactory(pars);
IScheduler scheduler = schedulefactory.GetScheduler().Result;
//开启调度器
scheduler.Start();
List<Feeding> lstFeeding = new List<Feeding>();
lstFeeding.Add(new Feeding()
{
PlanID = 1,
Interval = 2,
PhaseTime = 2,
PlanState = 3,
Step = 1,
Times = 3,
Wait = 4,
lstSubPlan = new List<SubPlan>() {
new SubPlan()
{
Interval = 1,
Times = 2,
},
new SubPlan()
{
Interval = 3,
Times = 4,
}
}
});
lstFeeding.Add(new Feeding()
{
PlanID = 1,
Interval = 2,
PhaseTime = 2,
PlanState = 3,
Step = 2,
Times = 3,
Wait = 2,
lstSubPlan = new List<SubPlan>() {
new SubPlan()
{
Interval = 2,
Times = 2,
},
new SubPlan()
{
Interval = 3,
Times = 4,
}
}
});
foreach (var feeding in lstFeeding)
//for (int i = 0; i < 10; i++)
{
JobKey firstJobKey = JobKey.Create("FirstJob", "Pipeline");
JobKey secondJobKey = JobKey.Create("SecondJob", "Pipeline");
JobKey thirdJobKey = JobKey.Create("ThirdJob", "Pipeline");
// Create job and trigger
IJobDetail firstJob = JobBuilder.Create<FeedingJob.OuterJob>()
.WithIdentity(firstJobKey)
.UsingJobData("outerSays", "Hello World,I'm outSide!")
//.StoreDurably(true)
.Build();
IJobDetail secondJob = JobBuilder.Create<FeedingJob.InnnerJob>()
.WithIdentity(secondJobKey)
.UsingJobData("innerSays", "Hello World,I'm inSide1!")
.UsingJobData("executeNext", "false")
.StoreDurably(true)//指示Quartz在Job成为“孤儿”时不要删除Job（当Job不再有Trigger引用它时）,按顺序触发关键
.Build();
IJobDetail thirdJob = JobBuilder.Create<FeedingJob.InnnerJob>()
.WithIdentity(thirdJobKey)
.UsingJobData("innerSays", "Hello World,I'm inSide2!")
.UsingJobData("executeNext", "true")
.StoreDurably(true)
.Build();
ITrigger firstJobTrigger = TriggerBuilder.Create()
.WithIdentity("Trigger", "Pipeline")
.WithSimpleSchedule(x => x
.WithMisfireHandlingInstructionFireNow()
.WithIntervalInSeconds(4)
.WithRepeatCount(0)).StartAt(DateTime.Now.AddSeconds(1))
.Build();
//创建计划链表
JobChainingJobListener listener = new JobChainingJobListener("JobLink");
listener.AddJobChainLink(firstJobKey, secondJobKey);
listener.AddJobChainLink(secondJobKey, thirdJobKey);
//将trigger监听器注册到调度器
//scheduler.ListenerManager.AddTriggerListener(new CustomTriggerListener());
scheduler.ListenerManager.AddJobListener(listener, GroupMatcher<JobKey>.GroupEquals("Pipeline"));
// Run it all in chain
scheduler.Start();
scheduler.ScheduleJob(firstJob, firstJobTrigger);
scheduler.AddJob(secondJob, false, true);
scheduler.AddJob(thirdJob, false, true);
int subPlanWait = feeding.lstSubPlan.Sum(o => o.Interval * o.Times);
int totalWait = (feeding.Wait + feeding.PhaseTime) * feeding.Interval + subPlanWait;
Thread.Sleep(totalWait * 1000);
}
//Console.ReadLine();
//scheduler.Shutdown();
//Console.WriteLine("Scheduler shutdown.");
//Console.WriteLine(history);
//Console.ReadLine();
});
}
public class FeedingJob
{
[DisallowConcurrentExecution]
public class OuterJob : IJob
{
private static object _lockOuterJob = new object();
public Task Execute(IJobExecutionContext context)
{
lock (_lockOuterJob)
{
JobKey jobKey = context.JobDetail.Key;
JobDataMap dataMap = context.JobDetail.JobDataMap;
string jobSays = dataMap.GetString("outerSays");
Console.WriteLine($"Outer job executed[{jobKey}]:{DateTime.Now},Content:{jobSays}");
Thread.Sleep(1000);
return Task.CompletedTask;
}
}
}
[DisallowConcurrentExecution]
public class InnnerJob : IJob
{
private static object _lockInnnerJob = new object();
public Task Execute(IJobExecutionContext context)
{
lock (_lockInnnerJob)
{
JobKey jobKey = context.JobDetail.Key;
JobDataMap dataMap = context.JobDetail.JobDataMap;
string jobSays = dataMap.GetString("innerSays");
string executeNext = dataMap.GetString("executeNext");
Console.WriteLine($"Innner job executed[{jobKey}]:{DateTime.Now},Content:{jobSays},executeNext:{executeNext}");
Thread.Sleep(1000);
}
return Task.CompletedTask;
}
}
}
