Quartz中Job相关类的理解和使用

  • Post author:
  • Post category:其他


原链接地址:

https://www.jianshu.com/p/de06cf3c946b

(一)、Job

Job可以理解为就是一个工作任务,代码中就是一个实现了org.quartz.Job或org.quartz.StatefulJob接口的java类。当Scheduler决定运行Job时,execute()方法就会被执行。

具体可以干啥:

1、每天定时发送系统邮件

2、在指定的时刻发送一条短信给用户

3、执行完A任务后希望B任务在10秒后执行

4、。。。

总结就是任何java能做的任务都可以成为一个job。

注意:在

@Quartz集成-项目使用

中已经讲到,org.quartz.Job接口是一个无状态的任务接口,实现此接口的任务每当触发器触发时都会准时执行,调度器并不关心此任务是否有其他实例正在运行,如果任务存在阻塞,可能会导致大量的任务实例并行执行。如果业务中存在不允许并行执行的任务,此时就用到有状态的org.quartz.StatefulJob接口,此接口的任务实现类不能并行执行,必须等上一次触发器触发执行完成后 才可以进行下一次触发执行。

那么Job和StatefulJob在代码上具体有什么区别呢?

它们没有区别,只是名字不同而已,StatefulJob接口继承了Job接口,框架只是通过接口的名字来标识是无状态任务还是有状态任务。

(二)、JobDetail

JobDetail(org.quartz.JobDetail)从字面的意思理解就是任务详情,它包含了任务本身和任务的其他信息。从

@Quartz集成-项目使用

中的代码可以看出,是将一个JobDetail实例通过scheduleJob()方法注册给了调度器,而不是一个Job实现类的实例。注册在调度器上的每一个Job都只会创建一个JobDetail实例,而当真正执行JobDetail中的Job时,调度器才会对此Job实现类进行实例化,并运行它的execute()方法。这样的好处就是我们无需担心线程安全性问题,因为相当于同一时刻仅有一个线程去执行Job实例。

JobDetail的属性介绍:

属性名 详细介绍
name 任务的名称,框架需要通过此名称进行关联,所以需要保证唯一性
group 任务组,默认为“DEFAULT”,取值Scheduler.DEFAULT_GROUP
jobClass Job的实现类类对象,注意不能使用代理类,原因下面介绍
description 任务描述信息,可以用来传递字符串参数,但是尽量不要这么干
jobDataMap 类似Map类,可以通过此类的对象向Job的execute方法中传递业务参数
volatility 重启应用之后是否删除任务的相关信息,默认为false
durability Job执行完后是否继续持久化到数据库,默认为false
shouldRecover 服务器重启后是否忽略过期的任务,默认为false

JobDetail类中主要的几个方法:

构造方法:
public JobDetail(){}
public JobDetail(String name, Class jobClass){}  // 常用
public JobDetail(String name, String group, Class jobClass){} // 常用
public JobDetail(String name, String group, Class jobClass, boolean volatility, boolean durability, boolean recover){}

常用方法:
public String getName(){}      // 获取Job的名称
public JobDataMap getJobDataMap(){}   //获取Job中需要使用到的数据

(三)、JobDataMap

实际开发中的任务业务代码不是简单的打印几句话而已,经常会需要传入各种参数才能完成。我们可以通过哪些办法传递参数到Job的execute()方法中呢?

(1)、通过JobDetail中的jobDataMap属性

JobDataMap最顶层就是实现了java.util.Map接口,所以将它当做Map来使用就可以。但是需要注意的是,org.quartz.jobStore.userProperties默认配置为false,设置为true时表示JobDataMap中的value存放的类型必须是String类型,此配置有利于持久化时不会出现多个类版本。


存放非字符串时会抛出一个异常信息:org.quartz.JobPersistenceException: Couldn’t store job: JobDataMap values must be Strings when the ‘useProperties’ property is set.

解决办法:

1、在quartz.properties配置文件中加入org.quartz.jobStore.userProperties=false或直接删除此条配置取默认值

2、将对象转JSON字符串后存入JobDataMap。

(2)、在execute方法中根据Job的name属性(名称是唯一的)在数据库中查询

数据库表记录如果生成的是UUID,那么可以将Job的类名+UUID作为Job的名称,比如:

TimingSendMessage_4a6c346ea44d4515946b87099275446a,TimingSendMessage是Job实现类的名称,4a6c346ea44d4515946b87099275446a是业务记录的唯一标识,然后在execute()方法中通过JobDetail实例的getName()方法获取到名称,再通过“_”下划线切割,这样就能拿到UUID了,最后通过此UUID在数据库中查询需要的数据。此方法的缺点就是代码看上去很不优雅而且代码理解稍加复杂。

(3)、使用JobDetail的description属性传递简单的String类型参数

直接调用setDescription(String description)方法,然后在execute()方法中通过get方法获取。虽然这样做可以达到目的,但是最好不要这样,因为你写的代码可能最后只有你自己懂或自己都忘了干了什么。

(四)、开发中的一些小技巧和注意事项

(1)、Job的execute()方法中需要使用到Spring管理的依赖bean

Spring帮忙管理bean的好处就是自己不用new对象啦,但是前面的文章提到过,Job的实例是在真正调度JobDetail中的Job实现类时进行实例化的,此对象由框架本身进行管理,所以实例化的对象并没有交给Spring来管理,所以通过@Autowired注入时,会有点麻烦。

  • 方法1、通过实现了org.springframework.context.ApplicationContextAware接口的java类来获取,具体实现代码这里不讲述了。获取示例:
ITaskStoreService taskStoreService = SpringContextHolder.getBean("taskStoreService");
  • 通过@Autowired注解注入
package com.quartz.task;

import org.quartz.Job;
import org.quartz.JobDetail;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import com.xk.quartz.entity.TaskStore;
import com.xk.quartz.service.impl.ITaskStoreService;

// 注意加上注解让Spring扫描到此Job类
@Component
public class DefaultJob implements Job{

    // 需要注入的依赖bean
    private static ITaskStoreService taskStoreService;

    // 定义一个set方法
    @Autowired
    public void setTaskStoreService(ITaskStoreService taskStoreService) {
        DefaultJob.taskStoreService = taskStoreService;
    }
        
    @Override
    public void execute(JobExecutionContext context) throws JobExecutionException {
        JobDetail jobDetail = context.getJobDetail();
        String name = jobDetail.getName();
        // 使用依赖的bean
        TaskStore store = taskStoreService.selectById(name);
        System.out.println(store);
    }
}

(2)、Job的execute()方法不会被Spring进行事物管理,如何保证一致性?

用上面一段代码稍作修改做以下示例:

@Override
public void execute(JobExecutionContext context) throws JobExecutionException {
      JobDetail jobDetail = context.getJobDetail();
      String name = jobDetail.getName();
      // 查询记录
      TaskStore store = taskStoreService.selectById(name);
      // 更新记录
      store.setUpdateDate(new Date());
      taskStoreService.updateById(store);
      // 删除记录
      taskStoreService.deleteById("表记录的id");
}

从代码可以看出,execute()方法既进行了更新和删除,如果删除方法因为网络等原因删除失败,那么更新是不会回滚的。在execute()方法加上@Transactional也没有用,还是上面说的原因,Job每次在需要执行的时候才进行实例化,不被Spring管理。此时我们可以这样,将更新和删除两段代码封装到TaskStoreService服务的同一个方法中,然后在方法上加上@Transactional交给Spring来管理事物,最后在execute()方法中调用封装后的方法。

@Transactional
public void updateAndDelete(TaskStore store, String delId) {
    // 更新
    store.setUpdateDate(new Date());
    taskStoreService.updateById(store); 
    // 删除
    taskStoreService.deleteById(store);
}

(3)、如何监控所有的Job运行和日志的打印?

可以通过Quartz提供的监听器来实现,本章节提供另外一种自定义方式。Quartz提供的监听器后面的章节中会讲到。

首先实现org.quartz.Job接口的一个抽象基类,然后重写execute(JobExecutionContext context)方法,再在基类中定义一个抽象方法businessWorking(JobExecutionContext context) ,名字可以自己根据情况取,最后在execute方法中调用businessWorking方法。下面贴上代码:

package com.quartz.task;

import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;

/**
 *  基础Job抽象类
 */
public abstract class AbsQuartzJob implements Job{

    @Override
    public void execute(JobExecutionContext context) throws JobExecutionException {
        // Job运行前监控
        System.out.println("execute before");
        
        // 调用业务代码
        this.businessWorking(context);
        
        // Job运行后监控
        System.out.println("execute after");
    }

    /** 业务代码抽象方法  */
    public abstract void businessWorking(JobExecutionContext context);
}

开发中的业务Job类直接继承AbsQuartzJob抽象类,业务代码写在继承类的businessWorking()方法中。代码示例:

package com.quartz.task;

import org.quartz.JobExecutionContext;

/** 
 * 业务job
 */
public class BusinessJob extends AbsQuartzJob{

    @Override
    public void businessWorking(JobExecutionContext context) {
        // TODO 业务代码
    }
}

这里有人可能会问,为什么不使用JDK或CGLIB动态代理呢?我本人之前也这样实现过,但是有个致命的问题,那就是JobDetail被持久化之后会保存到数据库中,所以Job实现类的包路径+类名也会存在数据库中,当项目重启后,所有动态代理的类都自动被虚拟机清除了,此时Quartz框架启动后会加载被持久化的Job,当去访问Job的实现类时,发现已经找不到此实现类了。启动直接报错!所以上面的实现方式可能是相对方便好用一点的方法了。