- 浏览: 57122 次
- 性别:
- 来自: 福州
最新评论
【1】.配置定时器
<bean id="supplyBidInfoDetail" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
<property name="targetObject">
<ref bean="supplyBidInfo"/>
</property>
<property name="targetMethod">
<value>doAutoJob</value>
</property>
</bean>
<bean id="supplyBidInfoTrigger" class="org.springframework.scheduling.quartz.CronTriggerBean">
<property name="jobDetail">
<ref bean="supplyBidInfoDetail"/>
</property>
<property name="cronExpression">
<value>0 0 0 * * ?</value><!-- 每天晚上0点执行一次 -->
</property>
</bean>
//如果全部定时任务都要动态生成,可以只配置这一个即可
<bean id="schedulerFactoryBean" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
<property name="triggers">
<list>
<ref bean="supplyBidInfoTrigger"/>
</list>
</property>
</bean>
【2】.定时器工具类
/**
*
*
* Description: 计时器工具类
*
* <pre>
* Modification History:
* Date Author Version Description
* ------------------------------------------------------------------
* 2013-7-19 lanzhongliang 1.0 1.0 Version
* </pre>
*/
@Repository("scheduleInfoManager")
@Scope("prototype")
public class ScheduleInfoManager {
private static Scheduler scheduler;// 调度器
static {
scheduler = (StdScheduler) Environment.getInstance().getBean("schedulerFactoryBean");
}
/**
*
*
* Description: 启动一个自定义的job
*
* @param schedulingJob
* 自定义的job
* @param paramsMap
* 传递给job执行的数据
* @param isStateFull
* 是否是一个同步定时任务,true:同步,false:异步
* @return 成功则返回true,否则返回false
* @Author lanzhongliang
* @Create 2013-7-19 下午03:57:22
*/
public static boolean enableCronSchedule(ScheduleJobEntity schedulingJob, JobDataMap paramsMap, boolean isStateFull) {
if (schedulingJob == null) {
return false;
}
try {
CronTrigger trigger = (CronTrigger) scheduler.getTrigger(schedulingJob.getTriggerName(), schedulingJob.getJobGroup());
if (null == trigger) {// 如果不存在该trigger则创建一个
JobDetail jobDetail = null;
if (isStateFull) {
jobDetail = new JobDetail(schedulingJob.getJobId(), schedulingJob.getJobGroup(), schedulingJob.getStateFulljobExecuteClass());
} else {
jobDetail = new JobDetail(schedulingJob.getJobId(), schedulingJob.getJobGroup(), schedulingJob.getJobExecuteClass());
}
jobDetail.setJobDataMap(paramsMap);
trigger = new CronTrigger(schedulingJob.getTriggerName(), schedulingJob.getJobGroup(), schedulingJob.getCronExpression());
scheduler.scheduleJob(jobDetail, trigger);
} else {// Trigger已存在,那么更新相应的定时设置
trigger.setCronExpression(schedulingJob.getCronExpression());
scheduler.rescheduleJob(trigger.getName(), trigger.getGroup(), trigger);
}
} catch (Exception e) {
e.printStackTrace();
return false;
}
return true;
}
/**
*
*
* Description: 禁用一个job
*
* @param jobId
* 需要被禁用的job的ID
* @param jobGroupId
* 需要被禁用的jobGroupId
* @return 成功则返回true,否则返回false
* @Author lanzhongliang
* @Create 2013-7-19 下午04:03:24
*/
public static boolean disableSchedule(String jobId, String jobGroupId) {
if (StringUtil.isBlank(jobId) || StringUtil.isBlank(jobGroupId)) {
return false;
}
try {
Trigger trigger = getJobTrigger(jobId, jobGroupId);
if (null != trigger) {
scheduler.deleteJob(jobId, jobGroupId);
}
} catch (Exception e) {
e.printStackTrace();
return false;
}
return true;
}
/**
*
* Description: 得到job的详细信息
*
* @param jobId
* job的ID
* @param jobGroupId
* job的组ID
* @return job的详细信息,如果job不存在则返回null
* @Author lanzhongliang
* @Create 2013-7-19 下午04:07:08
*/
public static JobDetail getJobDetail(String jobId, String jobGroupId) {
if (StringUtil.isBlank(jobId) || StringUtil.isBlank(jobGroupId)) {
return null;
}
try {
return scheduler.getJobDetail(jobId, jobGroupId);
} catch (SchedulerException e) {
e.printStackTrace();
return null;
}
}
/**
*
*
* Description: 得到job对应的Trigger
*
* @param jobId
* job的ID
* @param jobGroupId
* job的组ID
* @return job的Trigger,如果Trigger不存在则返回null
* @Author lanzhongliang
* @Create 2013-7-19 下午04:09:00
*/
public static Trigger getJobTrigger(String jobId, String jobGroupId) {
if (jobId.equals("") || jobGroupId.equals("") || null == jobId || jobGroupId == null) {
return null;
}
try {
return scheduler.getTrigger(jobId + "Trigger", jobGroupId);
} catch (SchedulerException e) {
e.printStackTrace();
return null;
}
}
}
【3】.封装的定时任务实体类
/**
*
*
* Description:任务实体类
*
* <pre>
* Modification History:
* Date Author Version Description
* ------------------------------------------------------------------
* 2013-7-19 lanzhongliang 1.0 1.0 Version
* </pre>
*/
public class ScheduleJobEntity {
public static final int JS_ENABLED = 0; // 任务启用状态
public static final int JS_DISABLED = 1; // 任务禁用状态
public static final int JS_DELETE = 2; // 任务已删除状态
private String jobId; // 任务的Id,一般为所定义Bean的ID
private String jobName; // 任务的描述
private String jobGroup; // 任务所属组的名称
private int jobStatus; // 任务的状态,0:启用;1:禁用;2:已删除
private String cronExpression; // 定时任务运行时间表达式
private String memos; // 任务描述
private Class<?> stateFulljobExecuteClass;// 同步的执行类,需要从StatefulMethodInvokingJob继承
private Class<?> jobExecuteClass;// 异步的执行类,需要从MethodInvokingJob继承
/**
* 得到该job的Trigger名字
*
* @return
*/
public String getTriggerName() {
return this.getJobId() + "Trigger";
}
public String getJobId() {
return jobId;
}
public void setJobId(String jobId) {
this.jobId = jobId;
}
public String getJobName() {
return jobName;
}
public void setJobName(String jobName) {
this.jobName = jobName;
}
public String getJobGroup() {
return jobGroup;
}
public void setJobGroup(String jobGroup) {
this.jobGroup = jobGroup;
}
public int getJobStatus() {
return jobStatus;
}
public void setJobStatus(int jobStatus) {
this.jobStatus = jobStatus;
}
public String getCronExpression() {
return cronExpression;
}
public void setCronExpression(String cronExpression) {
this.cronExpression = cronExpression;
}
public String getMemos() {
return memos;
}
public void setMemos(String memos) {
this.memos = memos;
}
public Class<?> getStateFulljobExecuteClass() {
return stateFulljobExecuteClass;
}
public void setStateFulljobExecuteClass(Class<?> stateFulljobExecuteClass) {
this.stateFulljobExecuteClass = stateFulljobExecuteClass;
}
public Class<?> getJobExecuteClass() {
return jobExecuteClass;
}
public void setJobExecuteClass(Class<?> jobExecuteClass) {
this.jobExecuteClass = jobExecuteClass;
}
}
【4】.定时任务执行类,通过反射机制操纵业务执行类
/**
*
*
* Description:同步定时任务执行类
*
* <pre>
* Modification History:
* Date Author Version Description
* ------------------------------------------------------------------
* 2013-7-19 lanzhongliang 1.0 1.0 Version
* </pre>
*/
public class SynchroExecuteJobAction extends StatefulMethodInvokingJob {
@Override
protected void executeInternal(JobExecutionContext context) throws JobExecutionException {
try {
String methodName = context.getJobDetail().getJobDataMap().getString("method_name");
// 通过获取参数:方法名,通过反射机制执行相应方法
ScheduleExecute s = new ScheduleExecute();
s.getClass().getMethod(methodName, JobExecutionContext.class).invoke(s, context);
} catch (Exception e) {
e.printStackTrace();
}
}
}
/**
*
*
* Description:异步定时任务执行类
*
* <pre>
* Modification History:
* Date Author Version Description
* ------------------------------------------------------------------
* 2013-7-22 lanzhongliang 1.0 1.0 Version
* </pre>
*/
public class AsynchroExecuteJobAction extends MethodInvokingJob {
@Override
protected void executeInternal(JobExecutionContext context) throws JobExecutionException {
try {
String methodName = context.getJobDetail().getJobDataMap().getString("method_name");
// 通过获取参数:方法名,通过反射机制执行相应方法
ScheduleExecute s = new ScheduleExecute();
s.getClass().getMethod(methodName, JobExecutionContext.class).invoke(s, context);
} catch (Exception e) {
e.printStackTrace();
}
}
}
【5】.定时任务具体业务执行类
/**
*
*
* Description:定时任务逻辑执行类
*
* <pre>
* Modification History:
* Date Author Version Description
* ------------------------------------------------------------------
* 2013-7-22 lanzhongliang 1.0 1.0 Version
* </pre>
*/
public class ScheduleExecute {
private Logger logger = LogDefault.getLogger(getClass());
private BidInfoService bidInfoService;
public ScheduleExecute(){
bidInfoService = (BidInfoService)Environment.getInstance().getBean("bidInfoService");
}
/**
*
* Description: 自动补充到期招投标所需金额定时任务执行方法
*
* @return void
* @throws Exception
* @Author lanzhongliang
* @Create 2013-7-22 下午04:16:08
*/
public void supplyBidQuartz(JobExecutionContext context) {
try {
logger.info("【动态定时任务】执行将到期借款标金额补全【开始】");
JobDataMap jobDataMap = context.getJobDetail().getJobDataMap();
Integer bidId = jobDataMap.getInt("bid_id");
String retStr = bidInfoService.updateBidInfoQuartz(bidId);
if ("F".equals(retStr)) {
logger.info("【动态定时任务】执行将到期借款标金额补全【失败】");
}
logger.info("【动态定时任务】执行将到期借款标金额补全【结束】");
} catch (Exception e) {
e.printStackTrace();
return;
}
}
}
<bean id="supplyBidInfoDetail" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
<property name="targetObject">
<ref bean="supplyBidInfo"/>
</property>
<property name="targetMethod">
<value>doAutoJob</value>
</property>
</bean>
<bean id="supplyBidInfoTrigger" class="org.springframework.scheduling.quartz.CronTriggerBean">
<property name="jobDetail">
<ref bean="supplyBidInfoDetail"/>
</property>
<property name="cronExpression">
<value>0 0 0 * * ?</value><!-- 每天晚上0点执行一次 -->
</property>
</bean>
//如果全部定时任务都要动态生成,可以只配置这一个即可
<bean id="schedulerFactoryBean" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
<property name="triggers">
<list>
<ref bean="supplyBidInfoTrigger"/>
</list>
</property>
</bean>
【2】.定时器工具类
/**
*
*
* Description: 计时器工具类
*
* <pre>
* Modification History:
* Date Author Version Description
* ------------------------------------------------------------------
* 2013-7-19 lanzhongliang 1.0 1.0 Version
* </pre>
*/
@Repository("scheduleInfoManager")
@Scope("prototype")
public class ScheduleInfoManager {
private static Scheduler scheduler;// 调度器
static {
scheduler = (StdScheduler) Environment.getInstance().getBean("schedulerFactoryBean");
}
/**
*
*
* Description: 启动一个自定义的job
*
* @param schedulingJob
* 自定义的job
* @param paramsMap
* 传递给job执行的数据
* @param isStateFull
* 是否是一个同步定时任务,true:同步,false:异步
* @return 成功则返回true,否则返回false
* @Author lanzhongliang
* @Create 2013-7-19 下午03:57:22
*/
public static boolean enableCronSchedule(ScheduleJobEntity schedulingJob, JobDataMap paramsMap, boolean isStateFull) {
if (schedulingJob == null) {
return false;
}
try {
CronTrigger trigger = (CronTrigger) scheduler.getTrigger(schedulingJob.getTriggerName(), schedulingJob.getJobGroup());
if (null == trigger) {// 如果不存在该trigger则创建一个
JobDetail jobDetail = null;
if (isStateFull) {
jobDetail = new JobDetail(schedulingJob.getJobId(), schedulingJob.getJobGroup(), schedulingJob.getStateFulljobExecuteClass());
} else {
jobDetail = new JobDetail(schedulingJob.getJobId(), schedulingJob.getJobGroup(), schedulingJob.getJobExecuteClass());
}
jobDetail.setJobDataMap(paramsMap);
trigger = new CronTrigger(schedulingJob.getTriggerName(), schedulingJob.getJobGroup(), schedulingJob.getCronExpression());
scheduler.scheduleJob(jobDetail, trigger);
} else {// Trigger已存在,那么更新相应的定时设置
trigger.setCronExpression(schedulingJob.getCronExpression());
scheduler.rescheduleJob(trigger.getName(), trigger.getGroup(), trigger);
}
} catch (Exception e) {
e.printStackTrace();
return false;
}
return true;
}
/**
*
*
* Description: 禁用一个job
*
* @param jobId
* 需要被禁用的job的ID
* @param jobGroupId
* 需要被禁用的jobGroupId
* @return 成功则返回true,否则返回false
* @Author lanzhongliang
* @Create 2013-7-19 下午04:03:24
*/
public static boolean disableSchedule(String jobId, String jobGroupId) {
if (StringUtil.isBlank(jobId) || StringUtil.isBlank(jobGroupId)) {
return false;
}
try {
Trigger trigger = getJobTrigger(jobId, jobGroupId);
if (null != trigger) {
scheduler.deleteJob(jobId, jobGroupId);
}
} catch (Exception e) {
e.printStackTrace();
return false;
}
return true;
}
/**
*
* Description: 得到job的详细信息
*
* @param jobId
* job的ID
* @param jobGroupId
* job的组ID
* @return job的详细信息,如果job不存在则返回null
* @Author lanzhongliang
* @Create 2013-7-19 下午04:07:08
*/
public static JobDetail getJobDetail(String jobId, String jobGroupId) {
if (StringUtil.isBlank(jobId) || StringUtil.isBlank(jobGroupId)) {
return null;
}
try {
return scheduler.getJobDetail(jobId, jobGroupId);
} catch (SchedulerException e) {
e.printStackTrace();
return null;
}
}
/**
*
*
* Description: 得到job对应的Trigger
*
* @param jobId
* job的ID
* @param jobGroupId
* job的组ID
* @return job的Trigger,如果Trigger不存在则返回null
* @Author lanzhongliang
* @Create 2013-7-19 下午04:09:00
*/
public static Trigger getJobTrigger(String jobId, String jobGroupId) {
if (jobId.equals("") || jobGroupId.equals("") || null == jobId || jobGroupId == null) {
return null;
}
try {
return scheduler.getTrigger(jobId + "Trigger", jobGroupId);
} catch (SchedulerException e) {
e.printStackTrace();
return null;
}
}
}
【3】.封装的定时任务实体类
/**
*
*
* Description:任务实体类
*
* <pre>
* Modification History:
* Date Author Version Description
* ------------------------------------------------------------------
* 2013-7-19 lanzhongliang 1.0 1.0 Version
* </pre>
*/
public class ScheduleJobEntity {
public static final int JS_ENABLED = 0; // 任务启用状态
public static final int JS_DISABLED = 1; // 任务禁用状态
public static final int JS_DELETE = 2; // 任务已删除状态
private String jobId; // 任务的Id,一般为所定义Bean的ID
private String jobName; // 任务的描述
private String jobGroup; // 任务所属组的名称
private int jobStatus; // 任务的状态,0:启用;1:禁用;2:已删除
private String cronExpression; // 定时任务运行时间表达式
private String memos; // 任务描述
private Class<?> stateFulljobExecuteClass;// 同步的执行类,需要从StatefulMethodInvokingJob继承
private Class<?> jobExecuteClass;// 异步的执行类,需要从MethodInvokingJob继承
/**
* 得到该job的Trigger名字
*
* @return
*/
public String getTriggerName() {
return this.getJobId() + "Trigger";
}
public String getJobId() {
return jobId;
}
public void setJobId(String jobId) {
this.jobId = jobId;
}
public String getJobName() {
return jobName;
}
public void setJobName(String jobName) {
this.jobName = jobName;
}
public String getJobGroup() {
return jobGroup;
}
public void setJobGroup(String jobGroup) {
this.jobGroup = jobGroup;
}
public int getJobStatus() {
return jobStatus;
}
public void setJobStatus(int jobStatus) {
this.jobStatus = jobStatus;
}
public String getCronExpression() {
return cronExpression;
}
public void setCronExpression(String cronExpression) {
this.cronExpression = cronExpression;
}
public String getMemos() {
return memos;
}
public void setMemos(String memos) {
this.memos = memos;
}
public Class<?> getStateFulljobExecuteClass() {
return stateFulljobExecuteClass;
}
public void setStateFulljobExecuteClass(Class<?> stateFulljobExecuteClass) {
this.stateFulljobExecuteClass = stateFulljobExecuteClass;
}
public Class<?> getJobExecuteClass() {
return jobExecuteClass;
}
public void setJobExecuteClass(Class<?> jobExecuteClass) {
this.jobExecuteClass = jobExecuteClass;
}
}
【4】.定时任务执行类,通过反射机制操纵业务执行类
/**
*
*
* Description:同步定时任务执行类
*
* <pre>
* Modification History:
* Date Author Version Description
* ------------------------------------------------------------------
* 2013-7-19 lanzhongliang 1.0 1.0 Version
* </pre>
*/
public class SynchroExecuteJobAction extends StatefulMethodInvokingJob {
@Override
protected void executeInternal(JobExecutionContext context) throws JobExecutionException {
try {
String methodName = context.getJobDetail().getJobDataMap().getString("method_name");
// 通过获取参数:方法名,通过反射机制执行相应方法
ScheduleExecute s = new ScheduleExecute();
s.getClass().getMethod(methodName, JobExecutionContext.class).invoke(s, context);
} catch (Exception e) {
e.printStackTrace();
}
}
}
/**
*
*
* Description:异步定时任务执行类
*
* <pre>
* Modification History:
* Date Author Version Description
* ------------------------------------------------------------------
* 2013-7-22 lanzhongliang 1.0 1.0 Version
* </pre>
*/
public class AsynchroExecuteJobAction extends MethodInvokingJob {
@Override
protected void executeInternal(JobExecutionContext context) throws JobExecutionException {
try {
String methodName = context.getJobDetail().getJobDataMap().getString("method_name");
// 通过获取参数:方法名,通过反射机制执行相应方法
ScheduleExecute s = new ScheduleExecute();
s.getClass().getMethod(methodName, JobExecutionContext.class).invoke(s, context);
} catch (Exception e) {
e.printStackTrace();
}
}
}
【5】.定时任务具体业务执行类
/**
*
*
* Description:定时任务逻辑执行类
*
* <pre>
* Modification History:
* Date Author Version Description
* ------------------------------------------------------------------
* 2013-7-22 lanzhongliang 1.0 1.0 Version
* </pre>
*/
public class ScheduleExecute {
private Logger logger = LogDefault.getLogger(getClass());
private BidInfoService bidInfoService;
public ScheduleExecute(){
bidInfoService = (BidInfoService)Environment.getInstance().getBean("bidInfoService");
}
/**
*
* Description: 自动补充到期招投标所需金额定时任务执行方法
*
* @return void
* @throws Exception
* @Author lanzhongliang
* @Create 2013-7-22 下午04:16:08
*/
public void supplyBidQuartz(JobExecutionContext context) {
try {
logger.info("【动态定时任务】执行将到期借款标金额补全【开始】");
JobDataMap jobDataMap = context.getJobDetail().getJobDataMap();
Integer bidId = jobDataMap.getInt("bid_id");
String retStr = bidInfoService.updateBidInfoQuartz(bidId);
if ("F".equals(retStr)) {
logger.info("【动态定时任务】执行将到期借款标金额补全【失败】");
}
logger.info("【动态定时任务】执行将到期借款标金额补全【结束】");
} catch (Exception e) {
e.printStackTrace();
return;
}
}
}
发表评论
-
Quartz 在 Spring 中如何动态配置时间
2014-01-07 23:35 1492在项目中有一个需求,需要灵活配置调度任务时间,并能自由启动或停 ... -
Quartz cron 表达式用法
2014-01-06 23:25 995Quartz中时间表达式的设置-----cron表达式 时 ... -
Quartz任务监控管理 (1)
2014-01-06 22:53 4051Quartz任务监控管理,类似Windows任务管理器,可以获 ... -
quatrz 任务监控管理 (2)
2014-01-06 22:48 2005在《Quartz 任务监控管理 (1)》http://www. ...
相关推荐
spring+springMVC+mybatis+quartz动态定时任务
上一次传错了资源了,这个是正确的,包含quartz动态定时任务的
利用quartz动态操作定时任务,所有配置信息扔到数据库合理管理,同时把运行日志自动添加数据库表中。
springboot+quartz 动态化配置,可在页面操作,查看、添加、修改、删除,暂停等操作
传统Spring+Quartz实现的定时器一般都是通过配置文件中配置的,这就意味着如果我们修改了定时任务的时间,就得重新启动一下Tomcat,而且每次新建一个任务就得在spring中添加相关的配置信息,非常麻烦。基于上面的...
通过spring mvc整合qutarz , 结合数据库实现动态添加定时任务,管理定时任务等操作。
Springboot整合Quartz实现定时任务数据库动态配置,新增任务、修改cron表达式、暂停任务、恢复任务、删除任务等操作
java spring quartz 实现的动态定时任务,可以动态添加高度任务
动态管理了定时任务的添加、修改、删除等操作,可扩展性强
Quartz1.7 动态添加、修改和删除定时任务(非spring集成版)
SpringBoot整合Quartz实现动态定时任务,在页面动态展示,添加,暂停,删除定时任务. 并整合了MyBatis-plus, 感兴趣的小伙伴 可以试试
Spring普通定时任务和动态设置定时任务.本资源仅供Spring有关的框架学习使用
Quartz 是个开源的作业调度框架,为在 Java 应用程序中进行作业调度提供了简单却强大的机制。Quartz框架包含了调度器监听、作业和触发器监听。你可以配置作业和触发器监听为全局监听或者是特定于作业和触发器的监听...
添加定时任务 编辑定时任务-修改定时规则 特点: 基于quartz集群,轻量扩展。可快速改造现有项目 完全动态管理,可自定义任何XxxService.xxx()服务方法为定时任务,简化定时任务开发配置过程 实现功能: 整体性:定时...
SpringBoot集成Quartz定时任务(包含对任务的添加、暂停、删除、继续等)
主要包含springmvc的基本配置内容,及spring定时任务quartz的配置与动态修改。
5.添加定时任务:不再使用作业自动调度框架Quartz实现作业调度,使用spring框架自带的调度器进行作业调度,简化了配置。@Scheduled是单线程的,每次最多只有一个作业在运行,如果调度时间到了作业还没执行完,就会...
1.在Spring Boot中,你可以使用@Scheduled注解来创建定时任务。将@Scheduled注解与方法一起使用,指定任务执行的时间表达式。 2.使用Spring的TaskScheduler: Spring提供了TaskScheduler接口和相关实现,用于任务...
本案例采用SpringBoot+Quartz实现了多个定时任务同时调度执行,运行测试通过,案例只编写了2个任务,如果要加更多任务,按注释添加即可。
5.添加定时任务:不再使用作业自动调度框架Quartz实现作业调度,使用spring框架自带的调度器进行作业调度,简化了配置。@Scheduled是单线程的,每次最多只有一个作业在运行,如果调度时间到了作