欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

Quartz使用指南(三)-----标识符、 作业和作业详情(Identifiers&Jobs&JobDetails)

程序员文章站 2022-05-07 14:09:45
...

 

           标识符(Identifiers

注册进Quartz Scheduler中的JobTrigger是通过name来标识的,为了后期的维护,JobTrigger能够按类划分为group,在一个group中每个JobTriggername必须为唯一的,即JobTrigger的标识是由各自的name+group组成的。

作业和作业详情(Jobs&JobDetails

Jobs的实现相对来说比较容易,只需要理解Job的性质、Job接口中的execute(…)方法和JobDetails

我们真正需要实现的类实际上是Job的内容,通过JobDetail类向Quartz传递有关该Job的各种属性值。

接下来介绍有关Job的性质和JobQuartz中的生命周期,以下是前面提到的代码:

JobDetail jobDetail = new JobDetail("myJob",             // job name
                                      sched.DEFAULT_GROUP, // job group
                                      DumbJob.class);        // the java class to execute
SimpleTrigger trigger = new SimpleTrigger("myTrigger",
                                            sched.DEFAULT_GROUP,
                                            new Date(),
                                            null,
                                            0,
                                            0L);
sched.scheduleJob(jobDetail, trigger);

有关DumbJob.class的代码如下:

public class DumbJob implements Job {
    public DumbJob() {
    }
    public void execute(JobExecutionContext context)
      throws JobExecutionException
    {
      System.err.println("DumbJob is executing.");
    }
  }

可以看到我们向Scheduler的实例sched中加入了JobDetail类的实例jobDetail,同时在jobDetail中注入了我们需要执行的类DumbJob.classsched每次在调用执行execute(…)法前都会对所调用的类DumbJob.class创建一个新的实例,这样就使得Job必须有一个没有参数的构造函数,并且在Job类中定义的成员变量每次都会被初始化。

哪我们如何为Job类提供属性或配置信息呢?如何跟踪两个执行任务之间的状态呢?Quartz提供了JobDataMap来实现,JobDataMapJobDetail 对象的一部分。

Job实例运行期间对应的JobDataMap中能够容纳任意多的对象,JobDataMap是对Java Map接口的实现,并增加一些对于原始类型存储和检索的方法。

下列是向JobDataMap对象存储数据的一些代码:

jobDetail.getJobDataMap().put("jobSays", "Hello World!");
  jobDetail.getJobDataMap().put("myFloatValue", 3.141f);
  jobDetail.getJobDataMap().put("myStateData", new ArrayList());

下列是在Job执行过程中获取JobDataMap有关数据的例子:

public class DumbJob implements Job {
    public DumbJob() {
    }
    public void execute(JobExecutionContext context) throws JobExecutionException
    {
      String instName = context.getJobDetail().getName();//获取Job实例的name
      String instGroup = context.getJobDetail().getGroup();//获取Job实例的group
      JobDataMap dataMap = context.getJobDetail().getJobDataMap();//获取JobDataMap对象
      String jobSays = dataMap.getString("jobSays");//获取JobDataMap中对象jobSays的值
      float myFloatValue = dataMap.getFloat("myFloatValue");//获取JobDataMap中对象myFloatValue的值
      ArrayList state = (ArrayList)dataMap.get("myStateData");
      state.add(new Date());//获取JobDataMap中对象myStateData的值
      System.err.println("Instance " + instName + " of DumbJob says: " + jobSays);
    }
  }

 

       有状态vs.无状态的作业(Stateful vs. Non-Stateful Jobs

这部分介绍Job的状态,即有关JobDataMap内容,Job实例可以分为:有状态和无状态;无状态Job只在注册进Scheduler时才有JobDataMap数据,无状态Job运行结束后不保存JobDataMap数据,这样意味着在无状态Job运行过程中修改过的JobDataMap数据在无状态Job再次运行时将无法得到;而有状态Job与之相反,有状态Job每次运行结束时将存储有状态JobJobDataMap数据,但是有状态Job为了保证JobDataMap的数据的一致性,有状态Job无法并行运行,当Trigger需要再次触发执行一个正在运行的Job时,Trigger会自动的延迟触发,直到正在运行的Job运行结束后才再次触发该Job

我们需要有状态Job时必须实现StatefulJob接口,而不是上面的例子中的Job接口。

      作业的其他属性(Other Attributes Of Jobs

以下对Job实例的其他属性进行介绍:

 l   持久性(Durability):如果Job是非持久性的,一旦没有活动的Trigger与之相关联时,该Job会自动从Scheduler中删除掉;

 l   易挥发性(Volatility):如果Job是易挥发的,当与之相关联的Schuduler停止之后,不会通过JobStore对该Job进行保存;

 l   可恢复性(RequestsRecovery):如果Job是可恢复的,该Job运行期间与之关联的Scheduler非正常停止(由于进程停止或机器关闭等引起)时,当该Scheduler再次启动时,该Job会重新执行一次;

 l   obListener:一个Job可以被关联到一个或多个JobListener,当该Job执行时,与之关联的JobListener会得到通知;

       作业接口中的execute()方法(The Job.execute(…) Method

Execute方法只允许有一种类型的异常(包括RuntimeException)可以抛出,该异常就是JobExecutionException;因此我们必须把execute方法的所有内容放在try-catch语句中。当需要了解如何处理异常时,我们还必须阅读有关JobExecutionExceptionJavaDoc文档。