Java定时任务详解

2024-02-24 20:57:02 312

定时任务在项目中经常会使用到，本文主要根据博主自己使用定时的经验分如下几点介绍定时任务：

1、Quartz定时任务简介及Spring配置Quartz定时任务

2、SchedulerFactory对定时任务进行增删改查

3、总结

Quartz定时任务简介：

Quartz是项目中经常用到的定时任务之一，是一个完全由java编写的开源作业调度框架，可以与J2EE与J2SE应用程序相结合也可以单独使用，其主要组成部分包括Job、Scheduler、CronExpression，这里就不一一介绍了，下面介绍Spring如何配置Quartz。

配置Quartz需要明白的一点是配置Quartz即配置Job、Scheduler和CronExpression，这三部分配置完成后，就是一个完整的定时任务，配置如下：

配置完成后，就是增加一个为你执行一个任务的Java类。每一个QuartzJob必须有一个实现了org.quartz.Job接口的具体类，代码如下：

publicclassTestQuartzJobextendsQuartzJobBean{
@Override
protectedvoidexecuteInternal(JobExecutionContextarg0)throwsJobExecutionException
{
//获取Job配置的接口
TestServiceImpltestServiceImpl=(TestServiceImpl)arg0.getJobDetail().getJobDataMap().get("testServiceImpl");
//执行业务方法
quartzStart();
}
publicvoidquartzStart(){
//业务方法...
}
}

当然，在Job中其实不用特意的配置接口，使用Spring的注入即可，这里只是把这个配置接口的方法进行说明。

到这里，简单的配置Quartz定时任务已经完成，下面附加一个我在项目中使用Quartz的情形：cronExpression表达式从数据库读取。

当时，我解决这个问题的方法是继承org.springframework.scheduling.quartz.CronTriggerBean，设置cronExpression，具体代码如下：

Trigger的配置要改：

xx.InitCronTriggerFactoryBean代码：

publicclassInitCronTriggerFactoryBeanextendsCronTriggerFactoryBeanimplementsSerializable{

privatestaticfinallongserialVersionUID=1L;

@Resource
privateSysParamServicesysParamService;

privateStringkey;

publicvoidsetKey(Stringkey)
{
this.key=key;

setCronExpression(getCronExpressionFromDB());
}

privateStringgetCronExpressionFromDB()
{
if(StringUtils.isEmpty(key))
return"00/5***?";

SysParamsysParam=newSysParam();

try
{
sysParam=sysParamService.getNameByKey(key);
}
catch(Exceptione)
{
e.printStackTrace();
}

if(sysParam!=null&&!StringUtils.isEmpty(sysParam.getParamValue()))
returnsysParam.getParamValue();

return"00/5***?";
}
}

其中，SysParamService是根据key到数据库查询对应的cronExpression表达式的接口，这个接口除了使用Spring注入，也可以使用set方法设置，如下：

这样，在xx.InitCronTriggerFactoryBean就要加入sysParamService的set方法，此时的xx.InitCronTriggerFactoryBean代码为：

publicclassInitCronTriggerFactoryBeanextendsCronTriggerFactoryBeanimplementsSerializable{
privatestaticfinallongserialVersionUID=1L;
privateSysParamServiceImplsysParamService;
privateStringkey;
publicvoidsetKey(Stringkey)
{
this.key=key;
}
publicvoidsetSysParamService(SysParamServiceImplsysParamService)
{
this.sysParamService=sysParamService;
setCronExpression(getCronExpressionFromDB());
}
privateStringgetCronExpressionFromDB()
{
if(StringUtils.isEmpty(key))
return"000/1**?";
SysParamsysParam=newSysParam();
try
{
sysParam=sysParamServiceImpl.getNameByKey(key);
}
catch(Exceptione)
{
e.printStackTrace();
}
if(sysParam!=null&&!StringUtils.isEmpty(sysParam.getParamValue()))
returnsysParam.getParamValue();
return"000/1**?";
}
}

Quartz定时任务到这里就差不多了，基本的配置和使用就是上面将的，想要深入了解Quartz可以在网上查找更多的资料，并在实践中使用。接下来将讲解在项目中使用的可以随时对定时任务进行增删改查操作的实例。

定时任务的增删改查，其实可以看做是对数据进行增删改查。不过，定时任务的增删改查是操作Job和Trigger，具体代码如下：

定时任务管理器代码：

publicclassQuartzManager{

privatestaticfinalLoggerlogger=LogPresident.getRootLogger();

privatestaticSchedulerFactoryschedulerFactory=newStdSchedulerFactory();

privatestaticMapjobKeyMap=newHashMap();

/**
*增加一个定时任务
*@authorzhiyuan.wu
*@date2017年3月30日
*@paramjobName
*@paramtriggerName
*@paramcls
*@paramdate
*/
@SuppressWarnings({"rawtypes","unchecked"})
publicstaticvoidaddJob(StringjobName,StringtriggerName,Classcls,Datedate)
{
try
{
Schedulerscheduler=schedulerFactory.getScheduler();

//job
JobDetailjobDetail=JobBuilder.newJob(cls).withIdentity(jobName,Scheduler.DEFAULT_GROUP).build();

//触发器
SimpleTriggertrigger=(SimpleTrigger)TriggerBuilder.newTrigger().withIdentity(triggerName,Scheduler.DEFAULT_GROUP).startAt(date).build();

scheduler.scheduleJob(jobDetail,trigger);

//启动
scheduler.start();

jobKeyMap.put(jobDetail.getKey().getName(),jobDetail.getKey());
}
catch(Exceptione)
{
logger.error("--------添加定时任务出错："+e.getMessage(),e);
}
}

/**
*删除对应的定时任务
*@authorzhiyuan.wu
*@date2017年3月29日
*@paramjobKey
*/
publicstaticvoidremoveJob(JobKeyjobKey)
{
Schedulerscheduler;
try
{
scheduler=schedulerFactory.getScheduler();
scheduler.deleteJob(jobKey);

jobKeyMap.remove(jobKey.getName());
}
catch(SchedulerExceptione)
{
logger.error("--------删除定时任务出错："+e.getMessage(),e);
}
}

/**
*启动所有定时任务
*@authorzhiyuan.wu
*@date2017年3月29日
*/
publicstaticvoidstartJobs()
{
try
{
Schedulersched=schedulerFactory.getScheduler();
sched.start();
}
catch(Exceptione)
{
logger.error("--------启动所有定时任务出错："+e.getMessage(),e);
}
}

/**
*停止所有定时任务
*@authorzhiyuan.wu
*@date2017年3月29日
*/
publicstaticvoidshutdownJobs()
{
try
{
Schedulersched=schedulerFactory.getScheduler();

if(!sched.isShutdown())
{
sched.shutdown();
}
}
catch(Exceptione)
{
logger.error("--------停止所有定时任务出错："+e.getMessage(),e);
}
}

/**
*修改定时任务
*@authorzhiyuan.wu
*@date2017年3月29日
*@paramjobKey
*@paramjobName
*@paramtriggerName
*@paramcls
*@paramdate
*/
@SuppressWarnings("rawtypes")
publicstaticvoidmodifyJobTime(JobKeyjobKey,StringjobName,StringtriggerName,Classcls,Datedate)
{
try
{
removeJob(jobKey);

addJob(jobName,triggerName,cls,date);
}
catch(Exceptione)
{
logger.error("--------修改定时任务出错："+e.getMessage(),e);
}
}

/**
*打印当前定时任务的jobName
*@authorzhiyuan.wu
*@date2017年3月29日
*@throwsSchedulerException
*/
publicstaticvoidprintJobName()throwsSchedulerException
{
for(StringjobName:jobKeyMap.keySet())
{
logger.info("--------jobName:"+jobName);
}
}
}

Job代码：

publicclassTestJobimplementsJob{

privatestaticfinalLoggerlogger=LogPresident.getRootLogger();

publicvoidexecute(JobExecutionContextcontext)throwsJobExecutionException
{
JobKeyjobKey=context.getJobDetail().getKey();

logger.info("--------定时任务开始执行："+jobKey.getName());

//业务方法...
//移除定时任务
QuartzManager.removeJob(jobKey);
}
}

增加一个定时任务代码：

QuartzManager.addJob(JobName,TriggerName,TestJob.class,Date);

这样，在到达时间Date时，定时任务将会执行。不过这样增加的任务是保存在内存中，项目重启将会丢失定时任务，所以，最好增加一个类，在项目启动时将会扫描数据库，将未执行的定时任务重新加载到内存中去。

定时任务在项目中运用需要根据业务具体调整，但只要弄清楚定时任务的原理和实现，那么就可以在项目中灵活运它用来具体的业务，希望这篇文章可以让大家快速了解和运用定时任务，并运用到实践中。

以上就是本文的全部内容，希望本文的内容对大家的学习或者工作能带来一定的帮助，同时也希望多多支持毛票票!

Java定时任务详解

热门推荐

随机推荐