wordpress外贸网站好用的模板,游戏的制作方法,一个企业可以做多个网站吗,珠海专业做网站制作背景#xff1a; 默认情况下#xff0c;Quartz.Net作业是持久化在内存中的#xff0c;即 quartz.jobStore.type Quartz.Simpl.RAMJobStore, Quartz#xff0c;这种模式有以下弊端#xff1a; ① 想在A服务器上控制B服务器上已经发布了的job和trigger不方便 默认情况下Quartz.Net作业是持久化在内存中的即 quartz.jobStore.type Quartz.Simpl.RAMJobStore, Quartz这种模式有以下弊端 ① 想在A服务器上控制B服务器上已经发布了的job和trigger不方便 ② 很难实现Web端(寄宿在IIS上)管理作业客户端(发布成服务)的这种模式。 ③ 最大弊端就是一旦服务器宕机或者重启调度器Schdeuler对应的所有作业job、trigger及其对应关系将丢失不得不重新发布 解决方案 针对问题1. 可以借助Remote代理的模式通过TCP协议在A服务器上直接获取B服务器上的Scheduler然后进行操作。(详情点击) 针对问题2. 客户端作为Server端进行调度的执行Web端通过Remote模式获取客户端的中的Scheduler然后进行作业的管理问题是一旦客户端端挂机Web端是连接不上的。 针对问题3. 无论代理还是不代理只要Server端一挂机保存在内存中的作业都会丢失所以这个时候我们需要另辟蹊径将作业持久化进行迁移比如迁移到数据库中这样话即使服务器宕机数据库中存储的作业信息仍然存在下次只需要开启Scheduler即可无须配置job和trigger了同时也解决了上述问题1和问题2即都可以直接修改数据库即可。
该章节也是为开篇提出的目标三铺最后一道路下面着重介绍持久化SQLServer数据库。
步骤1准备数据库脚本。 下载地址为https://github.com/quartznet/quartznet/blob/master/database/tables/tables_sqlServer.sql执行后的数据库如下图 重点介绍一下以上表的含义 qrtz_blob_triggers : 以Blob 类型存储的触发器。 qrtz_calendars存放日历信息 quartz可配置一个日历来指定一个时间范围。 qrtz_cron_triggers存放cron类型的触发器。 qrtz_fired_triggers存放已触发的触发器。 qrtz_job_details存放一个jobDetail信息。 qrtz_job_listenersjob**监听器**。 qrtz_locks 存储程序的悲观锁的信息(假如使用了悲观锁)。 qrtz_paused_trigger_graps存放暂停掉的触发器。 qrtz_scheduler_state调度器状态。 qrtz_simple_triggers存放简单触发器的信息。 qrtz_trigger_listeners触发器监听器。 qrtz_triggers将Trigger和job进行关联的表。
注cron方式需要用到的4张数据表 qrtz_cron_triggersqrtz_fired_triggersqrtz_job_detailsqrtz_triggers。
步骤2代码进行持久化数据库配置 需要配置的信息有SQLServer版本、数据库连接字符串、存储类型、数据源名称、驱动类型代码如下 1 var properties new NameValueCollection();2 //SQLServer版本3 properties.Add(quartz.dataSource.myDS.provider, SqlServer-20);4 //表名前缀(可有可无)5 //properties.Add(quartz.jobStore.tablePrefix, QRTZ_);6 //数据库连接字符串7 properties.Add(quartz.dataSource.myDS.connectionString, Data Source.;Initial Catalogquartz;User IDsa;Password123456);8 //properties.Add(quartz.dataSource.myDS.connectionString, Server .;Database quartz;Trusted_Connection True;); 9 //JobStore设置JobStoreTX: 带有事务JobStoreCMT不带有事务
10 //存储类型
11 properties.Add(quartz.jobStore.type, Quartz.Impl.AdoJobStore.JobStoreTX, Quartz);
12 //数据源名称
13 properties.Add(quartz.jobStore.dataSource, myDS);
14 //驱动类型
15 properties.Add(quartz.jobStore.driverDelegateType, Quartz.Impl.AdoJobStore.StdAdoDelegate, Quartz); 步骤3向数据库中持久化作业并开启调度。
代码如下 1 var factory new StdSchedulerFactory(properties);2 IScheduler scheduler factory.GetScheduler();3 var job JobBuilder.CreateHelloJob4()4 .WithIdentity(ypfJob1, ypfJobGroup1)5 .Build();6 var trigger TriggerBuilder.Create()7 .WithIdentity(ypfTrigger1, ypfTriggerGroup1)8 .WithCronSchedule(/3 * * * * ?)9 .Build();
10 if (!scheduler.CheckExists(job.Key))
11 {
12 scheduler.ScheduleJob(job, trigger);
13 }
14 scheduler.Start(); 运行结果为 此时分析数据库中的数据
QRTZ_CRON_TRIGGERS 表即存放cron类型的trigger QRTZ_JOB_DETAILS 表即存放job的信息 QRTZ_TRIGGERS 表将Trigger和job进行关联的表 QRTZ_FIRED_TRIGGERS 表 下面做几个实验验证持久化问题 实验1去掉代码中job和trigger的创建及关联直接进行调度器的启动。 实验结果调度正常按照每3s执行一次证明作业持久化数据库成功。 实验2修改数据库中的cron表达式为每5s执行一次然后保持实验1中的代码注释运行代码。 实验结果调度变为每隔5s执行一次了证明作业持久化数据库成功。 实验3我们在上面的数据库表中发现一个现象第一个字段都为Sched_Name即调度器的名称而且默认都为QuartzScheduler那么如何增加多个不同名称的调度器呢获取的时候又是怎么获取指定的调度器呢都是通过下面的这句代码配置
properties.Add(quartz.scheduler.instanceName, Ypf1Scheduler); 分享完整代码 var properties new NameValueCollection();//SQLServer版本properties.Add(quartz.dataSource.myDS.provider, SqlServer-20);//表名前缀(可有可无)//properties.Add(quartz.jobStore.tablePrefix, QRTZ_);//数据库连接字符串properties.Add(quartz.dataSource.myDS.connectionString, Data Source.;Initial Catalogquartz;User IDsa;Password123456);//properties.Add(quartz.dataSource.myDS.connectionString, Server .;Database quartz;Trusted_Connection True;); //JobStore设置JobStoreTX: 带有事务JobStoreCMT不带有事务//存储类型properties.Add(quartz.jobStore.type, Quartz.Impl.AdoJobStore.JobStoreTX, Quartz);//数据源名称properties.Add(quartz.jobStore.dataSource, myDS);//驱动类型properties.Add(quartz.jobStore.driverDelegateType, Quartz.Impl.AdoJobStore.StdAdoDelegate, Quartz);//Scheuler的名称用于处理多个调度器的情况指定和获取都是用这句代码如果不指定的话默认均为QuartzScheduler名称{properties.Add(quartz.scheduler.instanceName, Ypf1Scheduler);}var factory new StdSchedulerFactory(properties);IScheduler scheduler factory.GetScheduler();var job JobBuilder.CreateHelloJob4().WithIdentity(ypfJob1, ypfJobGroup1).Build();var trigger TriggerBuilder.Create().WithIdentity(ypfTrigger1, ypfTriggerGroup1).WithCronSchedule(/10 * * * * ?).Build();//Scheduler只要存在相同的job名称将不在关联 这里需要根据实际要求来处理if (!scheduler.CheckExists(job.Key)){scheduler.ScheduleJob(job, trigger);}scheduler.Start(); 发现数据中上述的几张表中多了一条数据 PS前面有博友【 搵中求胜】给我留言提示集群的问题这里借助他的话给大家一个提醒 在使用 Quartz.Impl.AdoJobStore 做集群时一旦出现连接超时或者底层的SQL错误这个Job将彻底堵住即使数据库连接恢复该JOB也得不到恢复继承自IJob的Execute方法将不会被调用。
因此必须有一个Timer对这些超时未执行的Job做重置或者移除再加入切误参考网上DEMO做一个Manager继承IJob因为Manager也被堵住了 二. 双机热备的集群模式
集群的两种形式 1.读写分离即master - slave在SQLServer通过“发布-订阅”来实现写是落库到master读从slave中一个主多个从。 2.双机热备即一主多备高可用主挂掉了备会自动顶上去 Quartz.Net集群采用的就是这种形式备用服务启动最短大约需要7.5s。
配置代码在持久化的基础上多了两句 properties[quartz.jobStore.clustered] true; properties[quartz.scheduler.instanceId] AUTO; 下面分享完成的一段代码 1 var properties new NameValueCollection();2 3 properties[quartz.dataSource.sqlserver.provider] SqlServer-20;4 properties[quartz.dataSource.sqlserver.connectionString] Data Source.;Initial Catalogquartz;User IDsa;Password123456;5 properties[quartz.jobStore.type] Quartz.Impl.AdoJobStore.JobStoreTX, Quartz;6 //注意这个名字改为了sqlserver上面的都要跟着改也可以改为别的名7 properties[quartz.jobStore.dataSource] sqlserver;8 properties[quartz.jobStore.driverDelegateType] Quartz.Impl.AdoJobStore.SqlServerDelegate, Quartz;9
10 //cluster 集群指定
11 properties[quartz.jobStore.clustered] true;
12 properties[quartz.scheduler.instanceId] AUTO;
13
14 //Scheuler的名称用于处理多个调度器的情况指定和获取都是用这句代码如果不指定的话默认均为QuartzScheduler名称
15 {
16 properties.Add(quartz.scheduler.instanceName, QuartzSchoolScheduler);
17 }
18
19 var factory new StdSchedulerFactory(properties);
20 var scheduler factory.GetScheduler();
21 var job JobBuilder.CreateHelloJob4()
22 .WithIdentity(job3, jobGroup3)
23 .Build();
24 //trigger 2s执行一次
25 var trigger TriggerBuilder.Create()
26 .WithIdentity(trigger3, triggerGroup3)
27 .WithSimpleSchedule(x x.WithIntervalInSeconds(2).RepeatForever())
28 .Build();
29 var isExists scheduler.CheckExists(job.Key);
30 if (!isExists)
31 {
32 //开始调度
33 scheduler.ScheduleJob(job, trigger);
34 }
35 scheduler.Start(); 数据库表的变化 QRTZ_SIMPROP_TRIGGERS 表 与cron的trigger存放的位置不同 QRTZ_JOB_DETAILS 表 QRTZ_TRIGGERS 表 QRTZ_FIRED_TRIGGERS 表 运行结果 生成一下代码直接在bin文件里打开然后再打开一个发现第一个正常运行第二个不运行。 关闭第一个客户端7.5s后发现第二个正常启动运行验证双机热备。
