Quartz.NET 作业调度(二):Job

JobBuilder

Create

通过 JobBuilder 的 Create 方法,指定一个作业任务(一个实现了 IJob 接口的 Job 类)。IJob 接口只有一个 Execute 方法,我们需要在 Execute 方法中完善我们要执行的业务代码。

IJobDetail job = JobBuilder.Create<HelloJob>()
                .Build();
public class HelloJob : IJob
{
  public async Task Execute(IJobExecutionContext context)
  {
    await Console.Out.WriteLineAsync("Hi,everybody");
  }
}

Execute 方法中的 context 参数包含作业执行的所有上下文信息,我们可以通过 context 中的一些属性获取需要的数据。如:

context.Scheduler 调度器信息
context.Trigger 触发器信息
context.JobDetail 作业信息
context.ScheduledFireTimeUtc 当前触发时间
context.NextFireTimeUtc 下一次将被触发时间
......

Identity

Job 注册到 Quartz 调度器的时候需要设置一个标识的 name,同时可以为 name 设置一个组,方便我们对 Job 分类,在同一个组内的 name 必须是唯一的。如果没有指定,name会自动生成,group 为 DEFAULT。

IJobDetail job = JobBuilder.Create<HelloJob>()
                .WithIdentity("job1", "jobGroup1");
                .Build();

UsingJobData

通过 JobBuilder 的 UsingJobData 方法我们可以为这个 Job 设置一些附属信息,当 Job 被执行的时候,我们在 Execute 方法中通过 context.JobDetail.JobDataMap 获取这些信息以供业务代码使用,也可以通过定义同名的属性,它将会自动注入到属性值。

var jobDataMap = new JobDataMap();
jobDataMap.Add("name", "beck");

IJobDetail job = JobBuilder.Create<HelloJob>()
                .WithIdentity("job1", "jobGroup1");
                .UsingJobData(jobDataMap)
                .Build();
public class HelloJob : IJob
{
  // 映射JobDetail.JobDataMap的name
  public string Name { get; set; }
  public async Task Execute(IJobExecutionContext context)
  {
    //var name = context.JobDetail.JobDataMap["name"].ToString();
    await Console.Out.WriteLineAsync($"Hi {Name}");
  }
}

注意:Job 和 Trigger 中都可以通过 UsingJobData 来设置附属信息,在 Execute 方法中,context.MergedJobDataMap 属性中既包含 Job 的 DataMap,也包含 Trigger 的 DataMap。当存在同名的参数时,Trigger 会覆盖 Job 的参数值。

StoreDurably

默认情况下,当 Job 没有对应的 Trigger 时,Job 是不能直接被加入调度器中的,或者在 Trigger 过期之后, 没有关联 Trigger 的 Job 也会被删除。我们可以通过 JobBuilder 的 StoreDurably 使 Job 独立存储于调度器中。

IJobDetail job = JobBuilder.Create<HelloJob>()
                .WithIdentity("job1", "jobGroup1")
                .UsingJobData(jobDataMap)
                .StoreDurably()
                .Build();

Job

State

Job 默认是无状态的,每次执行 Job ,context.JobDetail 获取到值都是原始数据,对其的任何修改都不会生效。
如:我们试图修改 JobDataMap 中的 times 属性,希望每次执行后都加1。

var jobDataMap = new JobDataMap();
jobDataMap.Add("times", 1);
public class HelloJob : IJob
{
  public int Times { get; set; }
  public async Task Execute(IJobExecutionContext context)
  {
    context.JobDetail.JobDataMap["times"] = Times + 1;
    await Console.Out.WriteLineAsync($"execute {Times} times");
  }
}
无状态的结果

实际并不会有效,Job 注册之后,调度器内保存了这个对象,默认情况下是每次通过反射new一个新实例来执行的,所以每次修改必然不会有效。但我们可以通过在 Job 类上加上 PersistJobDataAfterExecution Attribute,就可以非常简单的把 Job 变成有状态。

[PersistJobDataAfterExecution]
public class HelloJob : IJob
{
  // ...
}
有状态的结果

Concurrency

当多个 Trigger 同时触发一个 Job 或者 一个 Job 执行较长,Trigger 条件已经被多次触发,这种情况下,Job 就出现了并发问题。在并发情况下,数据的准确性必然会有影响。

我们设置 Trigger 触发周期为1s一次,在 Job 的 Exceute 方法中加入代码:

Thread.Sleep(2000);
并发的结果

很明显结果的错误的,但这时我们可以通过在 Job 类上加上 DisallowConcurrentExecution Attribute,就可以完美解决并发问题。

[DisallowConcurrentExecution]
public class HelloJob : IJob
{
  // ...
}
无并发的结果

参考链接:

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

推荐阅读更多精彩内容

  • 概述 了解Quartz体系结构 Quartz对任务调度的领域问题进行了高度的抽象,提出了调度器、任务和触发器这3个...
    张晨辉Allen阅读 2,217评论 2 11
  • 入门简介: 基本上任何公司都会用到调度这个功能, 比如我们公司需要定期执行调度生成报表, 或者比如博客什么的定时更...
    水车阅读 6,163评论 0 9
  • Quartz是一个完全由java编写的功能丰富的开源作业调度库,可以集成到几乎任何Java应用程序中,小到独立应用...
    ProteanBear阅读 7,004评论 3 24
  • 1.引言 Quartz是一个开源的任务调度框架。基于定时、定期的策略来执行任务是它的核心功能,比如2018年除夕夜...
    木子道阅读 2,419评论 0 1
  • 夜深了, 你还未眠, 在想什么呢? 不如早点歇息, 那才是走向未来的你自己……
    小剧在成长阅读 203评论 2 5