标识符&＃xff08;Identifiers&＃xff09;

注册进Quartz Scheduler中的Job和Trigger是通过name来标识的&＃xff0c;为了后期的维护&＃xff0c;Job和Trigger能够按类划分为group&＃xff0c;在一个group中每个Job和Trigger的name必须为唯一的&＃xff0c;即Job和Trigger的标识是由各自的name&＃43;group组成的。

作业和作业详情&＃xff08;Jobs&JobDetails&＃xff09;

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

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

接下来介绍有关Job的性质和Job在Quartz中的生命周期&＃xff0c;以下是前面提到的代码&＃xff1a;

JobDetail jobDetail &＃61; new JobDetail("myJob",             // job name

                                      sched.DEFAULT_GROUP, // job group

                                      DumbJob.class);        // the java class to execute

SimpleTrigger trigger &＃61; new SimpleTrigger("myTrigger",

                                            sched.DEFAULT_GROUP,

                                            new Date(),

                                            null,

                                            0,

                                            0L);

sched.scheduleJob(jobDetail, trigger);

有关DumbJob.class的代码如下&＃xff1a;

public class DumbJob implements Job {

    public DumbJob() {

    }

    public void execute(JobExecutionContext context)

      throws JobExecutionException

    {

      System.err.println("DumbJob is executing.");

    }

  }

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

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

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

下列是向JobDataMap对象存储数据的一些代码&＃xff1a;

jobDetail.getJobDataMap().put("jobSays", "Hello World!");

  jobDetail.getJobDataMap().put("myFloatValue", 3.141f);

  jobDetail.getJobDataMap().put("myStateData", new ArrayList());

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

public class DumbJob implements Job {

    public DumbJob() {

    }

    public void execute(JobExecutionContext context) throws JobExecutionException

    {

      String instName &＃61; context.getJobDetail().getName();//获取Job实例的name

      String instGroup &＃61; context.getJobDetail().getGroup();//获取Job实例的group

      JobDataMap dataMap &＃61; context.getJobDetail().getJobDataMap();//获取JobDataMap对象

      String jobSays &＃61; dataMap.getString("jobSays");//获取JobDataMap中对象jobSays的值

      float myFloatValue &＃61; dataMap.getFloat("myFloatValue");//获取JobDataMap中对象myFloatValue的值

      ArrayList state &＃61; (ArrayList)dataMap.get("myStateData");

      state.add(new Date());//获取JobDataMap中对象myStateData的值

      System.err.println("Instance " &＃43; instName &＃43; " of DumbJob says: " &＃43; jobSays);

    }

  }

       有状态vs.无状态的作业&＃xff08;Stateful vs. Non-Stateful Jobs&＃xff09;

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

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

      作业的其他属性&＃xff08;Other Attributes Of Jobs&＃xff09;

以下对Job实例的其他属性进行介绍&＃xff1a;

 l   持久性&＃xff08;Durability&＃xff09;&＃xff1a;如果Job是非持久性的&＃xff0c;一旦没有活动的Trigger与之相关联时&＃xff0c;该Job会自动从Scheduler中删除掉&＃xff1b;

 l   易挥发性&＃xff08;Volatility&＃xff09;&＃xff1a;如果Job是易挥发的&＃xff0c;当与之相关联的Schuduler停止之后&＃xff0c;不会通过JobStore对该Job进行保存&＃xff1b;

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

 l   obListener&＃xff1a;一个Job可以被关联到一个或多个JobListener&＃xff0c;当该Job执行时&＃xff0c;与之关联的JobListener会得到通知&＃xff1b;

       作业接口中的execute(…)方法&＃xff08;The Job.execute(…) Method&＃xff09;

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