本文地址:http://blog.csdn.net/kongxx/article/details/6860732
前面写了几个文章是关于spring中集成作业调度功能的东西,可以参考
但那些例子都是对静态作业做调度的例子,这里所谓静态作业都是指作业信息和调度信息是写死在spring的配置文件中的,但是真实很多应用的情况都是需要动态的对作业进行调度,比如动态添加或者删除作业,动态的设置作业的trigger等。下面就来看看在spring中怎样实现对动态作业进行调度。
1. 首先是一个任务类,这个类没有实现任何接口,其中包含一个run方法用来运行这个task,代码如下:
package org.garbagecan.springstudy.schedule.quartz;
public class MyTask {
private String name;
public void run() {
System.out.println("Run task: " + name + ".");
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
}
2. 一个Job类,这个类需要继承spring的QuartzJobBean类,来说明当前类是一个Quartz的Job类,类包含了一个Task类的对象实例,在每次Job被调度的时候,将会运行其中的executeInternal方法,代码如下:
package org.garbagecan.springstudy.schedule.quartz;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.springframework.scheduling.quartz.QuartzJobBean;
public class MyJob extends QuartzJobBean {
private MyTask myTask;
protected void executeInternal(JobExecutionContext context)
throws JobExecutionException {
myTask.run();
}
public MyTask getMyTask() {
return myTask;
}
public void setMyTask(MyTask myTask) {
this.myTask = myTask;
}
}
3. Spring配置文件,内容如下
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd"
default-lazy-init="true">
<bean id="scheduler" class="org.springframework.scheduling.quartz.SchedulerFactoryBean" lazy-init="false">
<property name="triggers">
<list>
</list>
</property>
</bean>
</beans>
配置中仅仅配置了一个schedule类的实例,其中的triggers的列表为空。这样在这个schedule启动的时候就不会schedule任何作业。
4. 最后,写一个测试类来测试上面的代码和配置
package org.garbagecan.springstudy.schedule.dynamic;
import org.quartz.CronTrigger;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import java.text.ParseException;
public class Test {
public static void main(String[] args) {
ApplicationContext ctx = new ClassPathXmlApplicationContext("/org/garbagecan/springstudy/schedule/dynamic/spring.xml");
Scheduler scheduler = (Scheduler)ctx.getBean("scheduler");
System.out.println("Scheduling to run tasks.");
for (int i = 0; i < 5; i++) {
try {
JobDetail jobDetail = new JobDetail();
jobDetail.setName("job_" + i);
MyTask myTask = new MyTask();
myTask.setName("task_" + i);
jobDetail.getJobDataMap().put("myTask", myTask);
jobDetail.setJobClass(MyJob.class);
scheduler.addJob(jobDetail, true);
CronTrigger cronTrigger =new CronTrigger("cron_" + i, Scheduler.DEFAULT_GROUP, jobDetail.getName(), Scheduler.DEFAULT_GROUP);
cronTrigger.setCronExpression("0/10 * * * * ?");
scheduler.scheduleJob(cronTrigger);
} catch (ParseException e) {
e.printStackTrace();
} catch (SchedulerException e) {
e.printStackTrace();
}
}
try {
Thread.sleep(60 * 1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("Un-scheduling to run tasks.");
for (int i = 0; i < 5; i++) {
try {
scheduler.unscheduleJob("cron_" + i, Scheduler.DEFAULT_GROUP);
} catch (SchedulerException e) {
e.printStackTrace();
}
}
}
}
4.1 测试类首先创建了5个JobDetail和CronTrigger,每个JobDetail对应一个我们的MyJob和MyTask类实例,每个CronTrigger都是10秒钟运行一次的cron表达式。具体的API可以参考Quartz的官方文档;
4.2 对于每个创建的JobDetail和CronTrigger,都使用Quartz的Scheduler去做调度;
4.3 等待60秒,让上面创建的那些作业运行几次,此时在后台可以看到有message输出;
4.4 Un-schedule上面创建的JobDetail和CronTrigger,此段代码之后,所有的作业都被停止了。
分享到:
相关推荐
里面包含了两个工程项目: 1.Java project工程(含jar包,JDK1.6)。 是spring+quartz的任务调度实例。 2.Java web工程(含jar包,JDK1.7)。 spring+mybatis+quartz任务调度实例
spring+quartz任务调度代码版
Spring+Quartz实现任务调度的小例子.本来不要资源分的,可是CSDN发布资源最低要求填写分值为1分,没办法了。
Spring+Quartz定时调度jar包和文档
该资源描述了用spring+quartz搭建的环境来管理任务调度的基本配置
Spring4.3.15 + Quartz2.2 + Spring MVC管理可以管理任务的暂停,启动、立即执行一次、根据表达式重新调度等功能
Quartz 是个开源的作业调度框架,为在 Java 应用程序中进行作业调度提供了简单却强大的机制。...例如,在使用 WebSphere 应用服务器时,由 Quartz 调度的作业并不能影响服务器的动态缓存和数据源。
最新技术定时器与Spring进行融合,适合开发者进行web技术开发不错的案例。
封装通用的Spring3+Struts2+MyBatis3的CRUD+条件分页查询,Spring+Quartz调度,FunctionCharts图像化工具 <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi=...
spring任务调度(Quartz )非常基础,
spring boot+vue+quartz2.2.3整合定时调度系统持久化道mysql,sql脚本在项目里面。sql文件spring boot+vue+quartz2.2.3整合定时调度系统持久化道mysql
Spring中Quartz任务调度器cronexpression配置说明
Spring Quartz 任务调度实例 可直接运行 可应用服务器启动调用 也可main入口调用 主要用于打jar包用
commons-collections-3.2.2.jar commons-logging-1.2.jar jta-1.1.jar log4j-1.2.14.jar org.springframework....quartz-all-1.8.6.jar slf4j-api-1.5.8.jar slf4j-log4j12.jar 和spring的一些jar包 不一一列出了
集群下应用server定时任务执行研究,一方面是spring+quartz集群支持,另一方面是统一调度server 通过IHS方式解决,保证同一时间只有一台应用server执行定时任务
spring整合quartz定时任务调度..........
基于spring+mybatis的quartz计划任务调度应用。支持mysql,oracle多种数据库。
quartz自动调度的3种调度形式+传参 1.单纯的quartz调度 2.spring+quartz调度
spring3.2.4+quartz2.2.0 定时调度例子,能正常运行的程序
集成了分布式任务调度框架 Quartz ,任务存储于数据库。 使用SpringMVC作为路由控制, 集成 Swagger2 提供实时 RESTful API文档。 数据持久层集成 Mybatis 框架。 使用自定义注解 @TargetDataSource 实现了多数据源...