`
no_bao
  • 浏览: 309488 次
  • 性别: Icon_minigender_1
  • 来自: 济南
社区版块
存档分类
最新评论

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

阅读更多

 

           标识符(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文档。

分享到:
评论

相关推荐

Global site tag (gtag.js) - Google Analytics