quartz.net 基于数据库的简单实现

前面简单学习了通过XML配置或者内存指定的方式实现调度任务。但此用法实战用途较小,企业上多需要分布式集群的方式。quart团队也考虑到了这点,于是有了我们今天要学习的。基于数据库实现分布式。

             NameValueCollection properties = new NameValueCollection();

             // 驱动类型,这里用的mysql,目前支持如下驱动:
//Quartz.Impl.AdoJobStore.FirebirdDelegate
//Quartz.Impl.AdoJobStore.MySQLDelegate
//Quartz.Impl.AdoJobStore.OracleDelegate
//Quartz.Impl.AdoJobStore.SQLiteDelegate
//Quartz.Impl.AdoJobStore.SqlServerDelegate
properties["quartz.jobStore.driverDelegateType"] = "Quartz.Impl.AdoJobStore.MySQLDelegate, Quartz"; // 数据源名称
properties["quartz.jobStore.dataSource"] = "myDS"; // 数据库版本
/* 数据库版本 MySql.Data.dll版本,二者必须保持一致
* MySql-10 1.0.10.1
* MySql-109 1.0.9.0
* MySql-50 5.0.9.0
* MySql-51 5.1.6.0
* MySql-65 6.5.4.0
* MySql-695 6.9.5.0
* System.Data
* SqlServer-20 2.0.0.0
* SqlServerCe-351 3.5.1.0
* SqlServerCe-352 3.5.1.50
* SqlServerCe-400 4.0.0.0
* 其他还有OracleODP,Npgsql,SQLite,Firebird,OleDb
*/
properties["quartz.dataSource.myDS.provider"] = "MySql-65"; // 连接字符串
properties["quartz.dataSource.myDS.connectionString"] = "server=172.17.43.120;database=JobScheduler;charset=utf8;uid=writeuser;pwd=111111"; // 事物类型JobStoreTX自动管理 JobStoreCMT应用程序管理
properties["quartz.jobStore.type"] = "Quartz.Impl.AdoJobStore.JobStoreTX, Quartz"; // 表明前缀
properties["quartz.jobStore.tablePrefix"] = "QRTZ_"; // Quartz Scheduler唯一实例ID,auto:自动生成
properties["quartz.scheduler.instanceId"] = "AUTO"; // 集群
properties["quartz.jobStore.clustered"] = "true"; ISchedulerFactory schedfDataBase = new StdSchedulerFactory(properties);
IScheduler sched = schedfDataBase.GetScheduler(); // 添加任务和触发器
IJobDetail jobDetail = JobBuilder.Create<JobTest>().WithIdentity("jobtest1", "group1").Build();
IJobDetail jobDetail2 = JobBuilder.Create<JobTest2>().WithIdentity("jobtest2", "group1").Build(); ITrigger simpleTrigger = (ISimpleTrigger)TriggerBuilder.Create().WithIdentity("simpleTrigger1", "group1").WithSimpleSchedule(x => x.WithIntervalInSeconds().WithRepeatCount()).Build(); ITrigger crontrigger = (ICronTrigger)TriggerBuilder.Create().WithIdentity("cronTrigger1", "group1").WithCronSchedule("0/5 * * * * ? ").Build(); sched.ScheduleJob(jobDetail, crontrigger); sched.ScheduleJob(jobDetail2, simpleTrigger); // 开始调度
sched.Start();
上一篇:【转载】 原生js判断某个元素是否滚动到底部


下一篇:Qt - 错误总结 - QObject::connect: Cannot queue arguments of type 'PVCI_CAN_OBJ' (Make sure 'PVCI_CAN_OBJ' is registered using qRegisterMetaType().)