Quartz 第三课 More About Jobs & JobDetails(官方文档翻译)

当学完第二课之后,你欣喜的发现,让jobs工作起来是还是相当简单的。虽然让jobs运行起来很简单,对于其执行的关键内容还是需要知道的。它们是IJob接口中的Execute和JobDetails。

当你定义一个实现IJob接口的类的时候,你需要在里面实现实际需要执行的代码。Quartz.NET需要知道关于这代码的各种信息,这样 Quartz.NET才能像你期望的那样工作。这些细节是在JobDetail类中进行了描述,在上一节以及进行了简单的描述。

JobDetail由JobBuilder进行实例化的。JobBuilder容许开发人员使用 fluent interface.进行自定义JobDetail细节。

让我们花点时间看Job的机制以及在Quartz.NET中的生命周期。在第一节中已经看到的例子让我们再看一遍:

 1 // define the job and tie it to our HelloJob class
 2 IJobDetail job = JobBuilder.Create<HelloJob>()
 3     .WithIdentity("myJob", "group1")
 4     .Build();
 5
 6 // Trigger the job to run now, and then every 40 seconds
 7 ITrigger trigger = TriggerBuilder.Create()
 8   .WithIdentity("myTrigger", "group1")
 9   .StartNow()
10   .WithSimpleSchedule(x => x
11       .WithIntervalInSeconds(40)
12       .RepeatForever())
13   .Build();
14
15 sched.ScheduleJob(job, trigger);

现在定义一个HelloJob 如下所示:

1 public class HelloJob : IJob
2 {
3     public void Execute(IJobExecutionContext context)
4     {
5         Console.WriteLine("HelloJob is executing.");
6     }
7 }

请注意,在这里给scheduler 一个IJobDetail 实例,它只需要一个job实例就能进行运行。当scheduler执行job的时候,scheduler 会在调用Execute方法之前实例化一个job实例。 能实例化job的前提是job类中需要有个无参的构造函数。还有一个需要注意的是,在job类中定义任何数据字段其实没有什么太大的意义,因为在job的运行期间不会保留这些数据字段。

看到这你或许会问,那我如何为一个job提供属性和配置信息呢?并且这么能跟踪保持job的执行状态呢?要回答这些问题,关键要弄懂JobDataMap,它是JobDetail中的一部分。

JobDataMap

JobDataMap中可用于容纳任何数量的您希望提供给job实例在执行时(可序列化)的对象。JobDataMap实现了IDictionary接口,并为其添加了一些用于存储和检索基本类型的数据的实用方法。

 

下面是JobDataMap 快速上手代码,在添加job到scheduler之前先为JobDataMap添加一些数据 :

1 // define the job and tie it to our DumbJob class
2 IJobDetail job = JobBuilder.Create<DumbJob>()
3     .WithIdentity("myJob", "group1") // name "myJob", group "group1"
4     .UsingJobData("jobSays", "Hello World!")
5     .UsingJobData("myFloatValue", 3.141f)
6     .Build();

下面是从执行的job中获取JobDataMap 数据

 1 Getting Values from a JobDataMap
 2 public class DumbJob : IJob
 3 {
 4     public void Execute(JobExecutionContext context)
 5     {
 6       JobKey key = context.JobDetail.Key;
 7
 8       JobDataMap dataMap = context.JobDetail.JobDataMap;
 9
10       string jobSays = dataMap.GetString("jobSays");
11       float myFloatValue = dataMap.GetFloat("myFloatValue");
12
13       Console.Error.WriteLine("Instance " + key + " of DumbJob says: " + jobSays + ", and val is: " + myFloatValue);
14     }
15 }

如果你准备使用一个持久的JobStore (JobStore 将在JobStore 部分进行讨论)你应该关注将在JobDataMap放些什么。因为它会被序列化,所以更容易产生版本问题。在标准的版本中是安全的,除此之外,任何人都可以改变你的实体类。所以不得不关心兼容性会被破坏的情况。

所以你可以把AdoJobStore and JobDataMap 放进map中,仅包含着原始函数与字符串数据,因此消除了序列化的各种问题。

由于Quartz默认JobFactory会再job实例化的时候去实例那些带有set属性的,所以当你添加带有set访问的属性的时候会在JobDataMap中创建对应的key将其保存。这样就不要进行显示区指示在execute方法方法中进行映射。

Trigger也有其相关的JobDataMap。当你需要多个Trigger进行调度和重复scheduler 这是非常有用的。每个Trigger是独立的,并且需要你单独输入配置信息。

JobDataMap 将JobExecutionContext 作为job执行时候的上下文。它里面包含了JobDataMap 和Trigger并且覆盖前面相同的值。

下面是来自JobExecutionContext获取数据的作业执行过程中合并的JobDataMap的一个简单的例子:

 1 public class DumbJob : IJob
 2 {
 3     public void Execute(IJobExecutionContext context)
 4     {
 5         JobKey key = context.JobDetail.Key;
 6
 7         JobDataMap dataMap = context.MergedJobDataMap;  // Note the difference from the previous example
 8
 9         string jobSays = dataMap.GetString("jobSays");
10         float myFloatValue = dataMap.GetFloat("myFloatValue");
11         IList<DateTimeOffset> state = (IList<DateTimeOffset>) dataMap["myStateData"];
12         state.Add(DateTimeOffset.UtcNow);
13
14         Console.Error.WriteLine("Instance " + key + " of DumbJob says: " + jobSays + ", and val is: " + myFloatValue);
15     }
16 }

或者,如果你想依靠的JobFactory“注入数据映射值到你的类,它可能看起来像这个:

 1 public class DumbJob : IJob
 2 {
 3     public string JobSays { private get; set; }
 4     public float FloatValue { private get; set; }
 5
 6     public void Execute(IJobExecutionContext context)
 7     {
 8         JobKey key = context.JobDetail.Key;
 9
10         JobDataMap dataMap = context.MergedJobDataMap;  // Note the difference from the previous example
11
12         IList<DateTimeOffset> state = (IList<DateTimeOffset>) dataMap["myStateData"];
13         state.Add(DateTimeOffset.UtcNow);
14
15         Console.Error.WriteLine("Instance " + key + " of DumbJob says: " + JobSays + ", and val is: " + FloatValue);
16     }
17 }

你会注意到类的整个代码较长,但在execute()方法的代码是干净。人们还可以争辩说,虽然代码越长,它实际上花了更少的编码,如果程序员的IDE用于自动生成的属性,而不必手工编写单独的调用从JobDataMap中检索值。这是你的选择。

Job “Instances”

很多用户花费时间是困惑究竟是什么构成了“Job实例”。我们会尽力讲清楚这里,下面有关的工作状态和并发性的部分。

 

您可以创建一个job类,并通过创建JobDetails的多个实例的调度中存储了很多实例定义” - 每一个都有自己的属性和JobDataMap - 并且他们都增加到scheduler中

例如,你可以创建一个实现所谓的“SalesReportJob”IJob接口的类。这个job可能会被编码到期望发送给它(通过JobDataMap中)来指定销售报告应根据销售人员的姓名参数。然后它们可以创建多个定义的jobJobDetails),如“SalesReportForJoe”“SalesReportForMike”具有joe”“Mike”在相应JobDataMaps作为输入到各自的job指定。

 

Trigger启动,将一个JobDetail(实例定义),它会被自动加载,和job类是指通过对调度配置的JobFactory实例化。默认的JobFactory只是调用使用Activator.CreateInstance 调用job类的默认构造函数,然后尝试在匹配的JobDataMap中的键名该类调用setter属性。您可能希望创建自己的实现的JobFactory来完成的事情,如让你的应用程序的IoC或者DI容器产生/初始化作业实例。

 

In “Quartz speak”, 我们指的是每个存储的JobDetail作为“job定义”或“的JobDetail实例”,我们指的是每一个执行job作为“job实例”或“job定义实例”。通常,如果我们只是用这个词的“job”,我们指的是一个名为定义或JobDetail等。当我们指的是类实现job接口,我们平时使用的术语“job type”。

Job State and Concurrency

现在有一些关于Job的状态数据(aka JobDataMap)和并发性附加说明。可以天剑组合特性到你的job类上,来影响Quartz’的行为。

 

DisallowConcurrentExecution添加到Job类,告诉Quartz不执行给定的job定义的多个实例(即是指给定的job类)并发的属性。注意这里面的所说,必须小心使用。在上一节的例子中,如果“SalesReportJob”有这个属性,比只有一个“SalesReportForJoe”的实例可以在给定时间执行的,但它可以与“SalesReportForMike”的一个实例,同时执行。约束是基于一个实例定义(JobDetail等),而不是在工作类的实例。但是,它(quartz的设计),决定对类本身携带的属性,因为它决定对类进行怎样进行编译。

 

PersistJobDataAfterExecution是可以被添加到Job类,告诉quartz更新JobDetailJobDataMap存储的副本属性在execute()方法成功完成后(未抛出异常),使得同样的job在下一次执行(JobDetail)接收,而不是原先存储的值的更新的值。像DisallowConcurrentExecution属性,这适用于作业定义实例,而不是一个作业类的实例,虽然当时决定让job类携带的属性,因为它往往使对类是如何编码的差异(如有状态将需要显式地理解的执行方法中的代码)。

 

如果使用PersistJobDataAfterExecution属性,你应该认真考虑也使用DisallowConcurrentExecution属性,以避免留下什么数据时,同样的job(JobDetail)的两个实例并发执行存储可能的混淆(竞争条件)

Other Attributes Of Jobs

下面是可用于通过JobDetail等对象的job实例来定义的其他属性的简单总结:

 

持久性 - 如果job是不可持久的,它会自动从调度中删除,一旦不再有与之相关的任何活动的触发器。换句话说,非持久job具有一个寿命由其触发的存在的限制。

可恢复性 - 如果作业要求恢复,它是在调度的硬关闭的时间执行(即它崩溃中运行的过程中,或在机器关闭),然后重新执行当调度程序重新开始。在这种情况下,JobExecutionContext.Recovering属性将返回真。

JobExecutionException

最后,我们需要告诉你的IJob.Execute..)方法的一些细节。你应该从执行方法抛出的唯一类型是JobExecutionException。正因为如此,你通常应该换execute方法的全部内容以try-catch“块。你也应该花一些时间看的JobExecutionException的文档,你的工作可以用它来提供调度各种指令为你想怎么异常进行处理。

时间: 2024-11-10 07:09:50

Quartz 第三课 More About Jobs & JobDetails(官方文档翻译)的相关文章

[译]Quartz.Net 框架 教程(中文版)2.2.x 之第三课 更多关于Jobs和JobDetails

第三课 更多关于Jobs和JobDetails 在这二课我们已经学习到,Jobs接口非常容易实现,只有一个execute方法.我们需要再学习一些知识去理解jobs的本质,Job接口的execute方法以及JobDetails接口. 当你实现Job接口类,Quartz需要你提供job实例的各种参数,Job接口实现类中的代码才知道如何去完成指定类型Job的具体工作.这个过程是通过JobDetail类来完成的,该类会在下一个章节作简要介绍.        JobDetail的实例是调用JobBuild

Quartz.NET笔记(三) More About Jobs &amp; JobDetails

如你所见,Job相当容易实现.这里只是介绍有关Jobs本质, IJob接口的Execute(..)方法以及JobDetails中需要理解的内容. 在所实现的类成为真正的“Job”时,期望任务所具有的各种属性需要通知给Quartz.通过JobDetail类可以完成这个工作,这个类在前面的章节中曾简短提及过.现在,我们花一些时间来讨论Quartz中Jobs的本质和Job实例的生命周期.首先让我们回顾一下第一课中所看到的代码片断: Using Quartz.NET 1 // define the jo

第三课 文件系统(上)

unix_c_03.txt====================第三课 文件系统(上)====================一.系统调用------------应用程序 -----------+| |v |各种库 |(C/C++标准库.Shell命令和脚本. |X11图形程序及库) || |v |系统调用 <----------+(内核提供给外界访问的接口函数,调用这些函数将使进程进入内核态)|v内核(驱动程序.系统功能程序)1. Unix/Linux大部分系统功能是通过系统调用实现的.如o

java工程开发之图形化界面之(第三课)

上面我们讲述了通过JOptionPane进行文本I/O操作,一个是通过JOptionPane来获取的 参考链接:http://blog.sina.com.cn/s/blog_993d254201013pgh.html#cmt_3339216 JOptionPane类 1.属于javax.swing 包. 2.功能:定制四种不同种类的标准对话框. ConfirmDialog 确认对话框.提出问题,然后由用户自己来确认(按"Yes"或"No"按钮) InputDialo

shellKali Linux Web 渗透测试— 初级教程(第三课)

shellKali Linux Web 渗透测试— 初级教程(第三课) 文/玄魂 目录 shellKali Linux Web 渗透测试—初级教程(第三课)... 1 课程目录... 1 通过google hack寻找测试目标... 2 一个asp站点的sql注入... 3 一个php站点的sql注入... 4  课程地址:点击 课程目录 两个基本案例,以sql注入入手,目标为熟悉基本的思路,关注细节信息. 关于google hack,web 扫描,sql注入更详细和复杂的内容后续教程会专门讲解

【C语言探索之旅】 第二部分第三课:数组

内容简介 1.课程大纲 2.第二部分第三课: 数组 3.第二部分第四课预告:字符串 课程大纲 我们的课程分为四大部分,每一个部分结束后都会有练习题,并会公布答案.还会带大家用C语言编写三个游戏. C语言编程基础知识 什么是编程? 工欲善其事,必先利其器 你的第一个程序 变量的世界 运算那点事 条件表达式 循环语句 实战:第一个C语言小游戏 函数 练习题 习作:完善第一个C语言小游戏 C语言高级技术 模块化编程 进击的指针,C语言王牌 数组 字符串 预处理 创建你自己的变量类型 文件读写 动态分配

BeagleBone Black 板第三课:Debian7.5系统安装和远程控制BBB板

BBB板第三课:Debian7.5系统安装和远程控制BBB板 因为BBB板系统是Debian 7.4,据说使用Debian系统可以实现很多BBB板的无缝连接,可以更好的学习和控制BBB板,所以就决定下载Debian7.5系统安装,采用虚拟机的安装方式. 一.系统安装 1.我下载了Debian7.5 32位系统,有三张DVD盘,网上有不少安装资料了,我这里就不详细介绍安装过程了.不过有一点可能很多人都会遇到的问题,就是安装过程中提示插入光盘的问题.虚拟机是Vmware workstation 10

【Linux探索之旅】第一部分第三课:測试并安装Ubuntu

内容简单介绍 1.第一部分第三课:測试并安装Ubuntu 2.第一部分第四课预告:磁盘分区 測试并安装Ubuntu 大家好,经过前两个比較偏理论(是否想起了带着瓜皮帽,手拿折扇的老学究,或者腐儒)的课程,这第三课我们就正式进入实战啦. 可能不少朋友没使用过Linux这个操作系统,那么这一课就是见识一下它的庐山真面目的时候了. 我们这个系列课程所使用的Linux发行版是Ubuntu,由于其使用广泛.技术支持全面.文档完整,另一个非常关键的原因就是Ubuntu的配色偏"土豪金"啊,有木有.

Spark 3000门徒第三课scala高阶函数总结

今晚听了王家林老师3000门徒spark系列课程的第三课,讲述了scala函数,下面写一下心得: 普通函数:def fun1(name:String){println(name)} 函数赋值给变量:val fun1 = functionName _ 匿名函数:val fun2 = (name:String) => prinln(name) 高阶函数:def bigData(func:(String) => Unit, content: String){func(content)} 返回值是函数