Quartz.net 使用群集的计划程序
本文关键字:计划 程序 群集 net Quartz | 更新日期: 2023-09-27 18:34:17
我正在使用聚类选项,但我遇到了一些问题:
-
当我使用两台机器时,我创建的作业在开始时运行,没有连接到他们的定义。例如:如果我将作业定义为每十秒运行一次,它可以在开始时每两秒运行一次,并且只有从第 2 次运行开始它才正确运行一次 - 每十秒一次。
-
两台机器在同一分钟内(但不在同一毫秒内)执行相同的作业并一起运行该作业两次,我尝试使用锁定处理程序属性,但也许我没有很好地定义它。
这是我的代码:
NameValueCollection properties = new NameValueCollection();
properties["quartz.scheduler.instanceName"] = "TestSchedulerNECH";
properties["quartz.scheduler.instanceId"] = "instance_one";
properties["quartz.threadPool.type"] = "Quartz.Simpl.SimpleThreadPool, Quartz";
properties["quartz.threadPool.threadCount"] = "200";
properties["quartz.threadPool.threadPriority"] = "Normal";
properties["quartz.jobStore.misfireThreshold"] = "60000";
properties["quartz.jobStore.type"] = "Quartz.Impl.AdoJobStore.JobStoreTX, Quartz";
properties["quartz.jobStore.useProperties"] = "false";
properties["quartz.jobStore.dataSource"] = "default";
properties["quartz.jobStore.tablePrefix"] = "QRTZ_";
properties["quartz.jobStore.clustered"] = "true";
properties["quartz.jobStore.lockHandler.type"] = "Quartz.Impl.AdoJobStore.UpdateLockRowSemaphore, Quartz";
properties["quartz.jobStore.driverDelegateType"] = "Quartz.Impl.AdoJobStore.SqlServerDelegate, Quartz";
properties["quartz.dataSource.default.connectionString"] = "Server=localhost;Database=mydb;Trusted_Connection=False;User=admin;Password=123456";
properties["quartz.dataSource.default.provider"] = "SqlServer-20";
ISchedulerFactory sf = new StdSchedulerFactory(properties);
IScheduler sched = sf.GetScheduler();
string schedId = sched.SchedulerInstanceId;
for (int i = 1; i <= 5; i++)
{
IJobDetail job = JobBuilder.Create<SimpleRecoveryJob>()
.WithIdentity("job_" + i, schedId)
.RequestRecovery(false)
.Build();
ITrigger trigger = TriggerBuilder.Create()
.StartAt(DateBuilder.FutureDate(10, IntervalUnit.Second))
.WithCronSchedule("0/10 * * * * ? *")
.ForJob(job)
.EndAt(DateBuilder.FutureDate(3, IntervalUnit.Minute))
.Build();
sched.ScheduleJob(job, trigger);
}
sched.Start();
有人可以帮助我吗?
我知道
这是一个旧线程,但是如果我们想禁止并发执行,我们必须将DisallowConcurrentExecution属性添加到作业类中。