您的位置 首页 java

spring+springmvc+hibernate实现可重置时间的quartz定时器

  1. 代码地址(包含相关jar包) : 密码:7ut1
  2. 主要jar包
  3. quartz -2.2.3.jar
  4. 相关文件介绍(基于两个定时器)
  5. 3.1applicationContext-Infrastructure.xml配置文件

<?xml version=”1.0″ encoding=”UTF-8″?>

<beans xmlns=”” xmlns:xsi=””

xmlns:tx=”” xmlns:aop=””

xmlns:context=””

xsi:schemaLocation=”

“>

<!– 测试job –>

<!– 配置bean的顺序不能换,否则可能报错 FactoryBean which is currently in creation returned null from getObject–>

<!– 任务触发器 –>

<!–

cronExpression知识:

1格式:秒(0-59) 分(0-59) 时(0-23) 日(1-31) 月(1-12) 星期(1-7) 年(空值 1970-2009)

2*:用于所有字段中,表示每秒每分钟每小时每天…

3?:用于日、星期,表示没有意义占位符

4-:用于所有字段中,表示一个范围,如小时中10-12表示10,11,12

5,:用于所有字段中,表示列表值,小时中10,11,12表示10时、11时、12时

6x/y:用于所有字段中,秒中10/5 表示第10秒起每隔 5秒执行一次

–>

<!– 1定时器bean类定义 –>

<bean id=”flexTimeJob” class=”cn.com.timer.infrastructure.quartz.test.FlexTimeJob”>

<!– 指定定时器调度工厂 –>

<property name=”scheduler” ref=”flexTimeSchedulerFactory” />

<!– 向定时器注入bean –>

</bean>

<!– 2任务定义 –>

<bean id=”flexTimeJobDetail”

class=”org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean”>

<!– 任务所在的类 –>

<property name=”targetObject” ref=”flexTimeJob” />

<!– 任务所对应的方法名 –>

<property name=”targetMethod” value=”executeInternal” />

<property name=”concurrent” value=”false” />

</bean>

<!– 3任务触发器 –>

<bean id=”flexTimeJobTrigger”

class=”org.springframework.scheduling.quartz.Cron trigger FactoryBean”>

<property name=”jobDetail” ref=”flexTimeJobDetail”/>

<property name=”cronExpression” value=”0 50 8 ? * *”/> <!– 默认每天凌晨0点整打印 –>

<!– <property name=”cronExpression” value=”0/5 * * ? * *”/> –> <!– 默认每隔五秒执行一次FlexTimeJob的executeInternal方法 –>

<property name=”startDelay” value=”0″/> <!– 延迟10秒(10000毫秒)启动 –>

</bean>

<!– 4调度工厂,触发器集合 –>

<bean id=”flexTimeSchedulerFactory” class=”org.springframework.scheduling.quartz.SchedulerFactoryBean”>

<property name=”triggers”>

<list>

<ref bean=”flexTimeJobTrigger”/>

</list>

</property>

</bean>

<!– 正式每天23:59:59执行从mongodb查询到数据并写入数据库的job –>

<!– 1定时器bean类定义 –>

<bean id=”timerJob” class=”cn.com.timer.infrastructure.quartz.test.TimerJob”>

<!– 指定定时器调度工厂 –>

<property name=”scheduler” ref=”timerSchedulerFactory” />

<!– 向定时器注入bean –>

</bean>

<!– 2任务定义 –>

<bean id=”timerJobDetail”

class=”org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean”>

<!– 任务所在的类 –>

<property name=”targetObject” ref=”timerJob” />

<!– 任务所对应的方法名 –>

<property name=”targetMethod” value=”executeInternal” />

<property name=”concurrent” value=”false” />

</bean>

<!– 3任务触发器 –>

<bean id=”timerJobTrigger”

class=”org.springframework.scheduling.quartz.CronTriggerFactoryBean”>

<property name=”jobDetail” ref=”timerJobDetail”/>

<property name=”cronExpression” value=”30 48 8 ? * *”/> <!– 默认每天凌晨0点整打印 –>

<!– <property name=”cronExpression” value=”0/5 * * ? * *”/> –> <!– 默认每隔五秒执行一次FlexTimeJob的executeInternal方法 –>

<property name=”startDelay” value=”0″/> <!– 延迟10秒(10000毫秒)启动 –>

</bean>

<!– 4调度工厂,触发器集合 –>

<bean id=”timerSchedulerFactory” class=”org.springframework.scheduling.quartz.SchedulerFactoryBean”>

<property name=”triggers”>

<list>

<ref bean=”timerJobTrigger”/>

</list>

</property>

</bean>

</beans>

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37
  • 38
  • 39
  • 40
  • 41
  • 42
  • 43
  • 44
  • 45
  • 46
  • 47
  • 48
  • 49
  • 50
  • 51
  • 52
  • 53
  • 54
  • 55
  • 56
  • 57
  • 58
  • 59
  • 60
  • 61
  • 62
  • 63
  • 64
  • 65
  • 66
  • 67
  • 68
  • 69
  • 70
  • 71
  • 72
  • 73
  • 74
  • 75
  • 76
  • 77
  • 78
  • 79
  • 80
  • 81
  • 82
  • 83
  • 84
  • 85
  • 86
  • 87
  • 88
  • 89
  • 90
  • 91
  • 92

3.2定时器FlexTimeJob(实现重置定时时间)

package cn.com.timer.infrastructure.quartz.test;

import java.util.Date;

import org.quartz.CronScheduleBuilder;

import org.quartz.CronTrigger;

import org.quartz.Scheduler;

import org.quartz.TriggerKey;

public class FlexTimeJob {

/**

* 调度工厂,可取得所属的触发器

*/

private Scheduler scheduler;

/**

* 定时任务执行的方法

*/

protected void executeInternal(){

System.out.println(new Date());

System.out.println(“hello FlexTimeJob!”);

}

/**

* 重置定时时间任务的方法

*/

public void resetTime(String time)throws Exception{

String cronExpression = transformTime(time);// 时间格式如:13:30

TriggerKey triggerKey = TriggerKey.triggerKey(“flexTimeJobTrigger”,Scheduler.DEFAULT_GROUP);

CronTrigger trigger = (CronTrigger)scheduler.getTrigger(triggerKey);

String originConExpression = trigger.getCronExpression();

if(!originConExpression.equalsIgnoreCase(cronExpression)){

CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(cronExpression);

//按新的cronExpression表达式重新构建trigger

trigger = trigger.getTriggerBuilder().withIdentity(triggerKey)

.withSchedule(scheduleBuilder).build();

//按新的trigger重新设置job执行

scheduler.rescheduleJob(triggerKey, trigger);

}

}

/**

* 将时间转换为cron表达式

* @param time 时间字符串,格式如:13:30

* @return

*/

private String transformTime(String time){

StringBuffer result = new StringBuffer();

String[] arr = time.split(” “);

String[] timeArr = arr[0].split(“:”);

result. append (“0 “+timeArr[1]+” “+timeArr[0]);

result.append(” ? * *”);

return result.toString();

}

public Scheduler getScheduler() {

return scheduler;

}

public void setScheduler(Scheduler scheduler) {

this.scheduler = scheduler;

}

}

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37
  • 38
  • 39
  • 40
  • 41
  • 42
  • 43
  • 44
  • 45
  • 46
  • 47
  • 48
  • 49
  • 50
  • 51
  • 52
  • 53
  • 54
  • 55
  • 56
  • 57
  • 58
  • 59
  • 60
  • 61
  • 62
  • 63
  • 64
  • 65

3.2定时器TimerJob

package cn.com.timer.infrastructure.quartz.test;

import java.util.Date;

import org.quartz.Scheduler;

public class TimerJob {

/**

* 调度工厂,可取得的触发器

*/

private Scheduler scheduler;

/**

* 定时任务执行的方

*/

protected void executeInternal(){

System.out.println(new Date());

System.out.println(“hello TimerJob!”);

}

public Scheduler getScheduler() {

return scheduler;

}

public void setScheduler(Scheduler scheduler) {

this.scheduler = scheduler;

}

}

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28

3.3重置定时执行时间的jsp

<!DOCTYPE html PUBLIC “-//W3C//DTD XHTML 1.0 Transitional//EN”>

<%@ page language=”java” contentType=”text/html; charset=UTF-8″ pageEncoding=”UTF-8″%>

<%

String path = request .getContextPath();

String basePath = request.getScheme() + “://” + request.getServerName() + “:” + request.getServerPort()

+ path + “/”;

%>

<html>

<head>

<meta http-equiv=”Content-Type” content=”text/html; charset=UTF-8″>

<title>测试</title>

</head>

<body>

~~~~~~~~~~~~~~~~~~~~~~可重置时间定时器~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

<br><br>

<input type=”text” name=”time” id=”time”> 时间格式如:13:30

<br><br>

<button type=”button” onclick=”resetTime();”>设置</button>

<br><br><br>

<script src=”<%=basePath%>Scripts/jqueryV2.2.3.min.js”></script>

<script type=”text/javascript”>

function resetTime(){

$.ajax({

url:”/police_system/test1/flexTimeJob!reset.action?time=”+$(‘#time’).val(),

async:true,

success:function(data){

alert(data)

}

});

}

</script>

</body>

</html>

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37

4.访问地址:

文章来源:智云一二三科技

文章标题:spring+springmvc+hibernate实现可重置时间的quartz定时器

文章地址:https://www.zhihuclub.com/176312.shtml

关于作者: 智云科技

热门文章

网站地图