Quartz.NET 作业调度(四):持久化与集群

Quartz.NET 中提供了 RAMJobStore 和 AdoJobStore 两种数据存储方式,默认是 RAMJobStore(内存存储),不需要任何其他配置。内存的方式一般可能测试环境用的比较多,生产环境可能更倾向于持久化存储,当然还是要根据实际需求来定。

我们也可以自定义 JobStore 方式,比如 MongoDB、DynamoDB、RavenDB、Redis 等等,只要实现 IJobStore 接口即可。不过常用的网上基本都有人已经有现成的,如果想自己实现,可以参考 Quartz.NET 或者其他实现方式的源码。

RAMJobStore

RAMJobStore 是 JobStore 最简单的使用方式,所有 Job 和 Trigger 相关的数据都保存在内存中,性能上肯定是很高的。 内存方式的缺点也非常明显,如果重启或者宕机所有数据就会消失。所以在 JobStore 的选择上,要根据实际项目对数据的依赖性来决定到底用什么方式。

Quartz.NET 作业调度(二):Job 中提到通过 PersistJobDataAfterExecution 可以实现有状态的 Job。但基于 RAMJobStore 也只能保证程序不重启的情况下能保存状态,一旦重启,一切回到解放前,每次看到都是类似下面截图的效果。

RAMJobStore

AdoJobStore

AdoJobStore 是通过 ADO.NET 将数据存储在数据库中,使用数据库的方式必然没有内存方式性能高,但通过创建合理的数据库索引,也不会差。官方为我们提供了对应的 SQL 语言 https://github.com/quartznet/quartznet/tree/master/database,我们只需要在自己的数据库上执行,表和索引就全部创建完成了。

QuartzDB

除此之外,我们需要增加一个配置文件 quartz.config。调度器启动的时候会自动加载文件内的配置,注意这个文件需要修改属性 "复制输出到目录" => "如果较新则复制" 或 "始终复制"。以代码的方式设置这些配置属性也可以,个人觉得通过配置文件显得比较干净一些。优先级:代码设置 > quartz.config

说明:文件内的 "#"开头代表注释,在行最后加上 !END 表示之后的全部忽略

#数据连接字符串
quartz.dataSource.myDS.connectionString=Database=Quartz;Server=172.17.30.108;User ID=sa;Password=mingdao!@#123
#数据库类型
quartz.dataSource.myDS.provider=SqlServer
#设置存储类型
quartz.jobStore.type=Quartz.Impl.AdoJobStore.JobStoreTX, Quartz
#驱动类型
quartz.jobStore.driverDelegateType=Quartz.Impl.AdoJobStore.SqlServerDelegate, Quartz
#数据源名称,于 quartz.dataSource 的属性名一样
quartz.jobStore.dataSource=myDS
#JobDataMaps 中的值只能是字符串,具体可以看官方推荐这样设置的原因
quartz.jobStore.useProperties=true
#数据存储序列号方式
quartz.serializer.type=json
// 创建作业调度器
ISchedulerFactory factory = new StdSchedulerFactory();
IScheduler scheduler = await factory.GetScheduler();

await scheduler.Start();

var jobDataMap = new JobDataMap();
jobDataMap.Add("times", "1");

// 创建一个作业
IJobDetail job = JobBuilder.Create<HelloJob>()
    .WithIdentity("job1", "jobGroup1")
    .UsingJobData(jobDataMap)
    .Build();

// 创建一个触发器
ITrigger trigger = TriggerBuilder.Create()
    .WithIdentity("trigger1", "triggerGroup1")
    .StartNow()
    .WithSimpleSchedule(x => x
        .WithIntervalInSeconds(1)
        .WithRepeatCount(10))
    .Build();

var jobExist = await scheduler.CheckExists(job.Key);
if (!jobExist)
{
  await scheduler.ScheduleJob(job, trigger);
}

如下图,执行了一定次数后,应用程序被停止:

shutdown result
db result

通过数据库查看到 Job 和 Trigger 的基本信息、Job Data、Trigger 触发次数等。应用程序再次重启,Trigger 和 Job Data 的数据都是延续之前的。作业全部执行完毕后,Job 和 Trigger 失效,数据也会自动被删除。

restart result
db result

Cluster

Quartz.NET 中集群配置还是比较简单的,只需要增加两个配置属性就可以实现,但 Quartz.NET 中的集群可能和想象的不太一样,集群中的多个节点是不会同时工作的,只有一个节点是处于工作状态,其他节点属于待命状态,只有当工作节点挂了,其他节点中的一个才会自动升级为工作节点。

官方并不推荐将多个节点部署到不同的服务器上,因为毕竟是作业调度程序,对时间一致性要求比较高,不同的服务器可能存在时间差异,所以如果部署到多台服务器要特别注意。

#是否是集群模式
quartz.jobStore.clustered=true
#自动生成唯一的instanceId
quartz.scheduler.instanceId=AUTO

node1 和 node2 多次重启的效果:


node1

node2

参考链接:

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 213,186评论 6 492
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 90,858评论 3 387
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 158,620评论 0 348
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 56,888评论 1 285
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 66,009评论 6 385
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 50,149评论 1 291
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 39,204评论 3 412
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 37,956评论 0 268
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,385评论 1 303
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 36,698评论 2 327
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 38,863评论 1 341
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 34,544评论 4 335
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 40,185评论 3 317
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,899评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,141评论 1 267
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 46,684评论 2 362
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 43,750评论 2 351

推荐阅读更多精彩内容