如何做一个时间可控制的定时任务

问答首页 → Java企业应用

0 0

如何做一个时间可控制的定时任务0

有一个需求一个页面配置时间，后台根据页面配置的时间定时运行任务。比如说在页面上配置15分钟。在后台就要每15分钟运行这个方法。这样如何实现呢？spring quartz的好像都是写死的时间。求一个完整的例子或者是思路谢谢！！

问题补充：有人吗？

2013年8月27日 20:12

597272095
0
0 0 6

3个答案按时间排序按投票排序

0 0

spring quartz 是可以实现的

package com.cnpc.framework.util.quartz;

import java.util.Date;
import java.util.List;

import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.SimpleTrigger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.BeansException;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;

import com.cnpc.classify.scan.dao.ScanTaskDao;
import com.cnpc.classify.scan.model.ScanTask;

import common.Logger;

public class TimerJob implements ApplicationContextAware {
	//获得工厂
		Logger log=(Logger) LoggerFactory.getLogger(TimerJob.class);
		private Scheduler scheduler;      
	    public void setScheduler(Scheduler scheduler) {      
	        this.scheduler = scheduler;      
	    }  
	    
		//删除任务
	    public void revokeTask(Integer id){
	    	try {
	    		//移除触发器
	    		SimpleTrigger simpleTrigger = (SimpleTrigger)scheduler.getTrigger("my_" + id, Scheduler.DEFAULT_GROUP);
	    	    if(null != simpleTrigger){
	    	    	scheduler.unscheduleJob(simpleTrigger.getName(), Scheduler.DEFAULT_GROUP);
	    	    }
			} catch (SchedulerException e) {
				e.printStackTrace();
			}
	    }
	    
	  //下达任务
	  	public boolean insertTrigger(Integer scanTask,Date d) {
	  		Integer id=scanTask;
	  		Date dtime = d;
	  		log.info("ID:"+id);
			
	  		long repeatInterval =0L;
	  		//long repeatInterval =scanTask.getTimeSpace().getTime(); //测试 时使用的间隔时间
	  		//验证是否有任务
	  		try {
	  			SimpleTrigger checkSimpleTrigger = (SimpleTrigger)scheduler.getTrigger("my_" + id, Scheduler.DEFAULT_GROUP);
	  			 if(null != checkSimpleTrigger){
	  		    	return false;
	  		    }
	  		} catch (SchedulerException e1) {
	  			e1.printStackTrace();
	  		}
	  		if(null!=dtime){
	  			try {
	  				//动态及动态产生一个人任务  跟一个触发器 交由Scheduler工厂管理
	  				 //1.新建一个任务  2.分配入默认的组 3.执行工作的BEAN 需实现JOB 接口  并实现execute方法
	  				 JobDetail jobDetail =  new JobDetail("reportJob_" + id, Scheduler.DEFAULT_GROUP,MyJob.class);   
	  				 
	  				 //执行0次，每0L秒执行一次  null为结束时间 dtime为开始时间更多详情请官网 查询 或者GOOGLE
	  				 //复杂的定时任务
	  				 SimpleTrigger trigger = new SimpleTrigger("trigger_" + id,Scheduler.DEFAULT_GROUP,dtime,null,0,0L);
	  				 
	  	             scheduler.getContext().put("applicationContext",applicationContext);
	  	           
	  	             
	  	             //启动新增定时器任务    
	  	             scheduler.scheduleJob(jobDetail, trigger); 
	  	             scheduler.start();
	  				return true;
	  			} catch (Exception e) {
	  				revokeTask(id);
	  				e.printStackTrace();
	  			}
	  		}
	  		return false;
	  	}
		
		//初始化数据库任务
		public void initJobTrigger(){
			  
		}
		
		private ApplicationContext applicationContext=null;
		@Override
		public void setApplicationContext(ApplicationContext arg0)
				throws BeansException {
			this.applicationContext=arg0;
			
		}
}

<bean id="scanPushTask" class="com.cnpc.framework.util.quartz.ScanPushTask">
		<property name="scheduler" ref="schedulerFactory" />
		<property name="scanTaskDao" ref="scanTaskDao" />
	</bean>
	<!-- test impl -->
	<bean id="soatest" class="com.cnpc.framework.util.quartz.SOAManagerImpl">
	</bean>
	
	
	<bean autowire="no" id="schedulerFactory"
		class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
		<property name="triggers">
			<list>
				<ref local="initTrigger" />
				 <!--<ref local="initTriggerTimer" />-->
				<ref local="cronTriggerClassifyInfoClear" />
				<ref local="cronTriggerAddPartition" />
				<ref local="cronTriggerclassifyWebManagerJob" />
			</list>
		</property>
		<property name="taskExecutor" ref="executor" />
	</bean>
	
	<!-- 配置定时任务,用于初始化定时器 -->
	<bean id="executionJobDetail"
		class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
		<property name="targetObject">
			<ref bean="scanPushTask" />
		</property>
		<property name="targetMethod">
			<value>initJobTrigger</value>
		</property>
		<property name="concurrent" value="true" />
	</bean>
	<bean id="initTrigger" class="org.springframework.scheduling.quartz.CronTriggerBean">
		<property name="jobDetail">
			<ref bean="executionJobDetail" />
		</property>
		<property name="cronExpression">
			<value>* * * * * ?</value>
		</property>
		<!-- 以毫秒为单位，启动后一分钟触发 -->
		<property name="startDelay">
			<value>60000</value>
		</property>
	</bean>
	
	<!-- 线程池配置 -->
	<bean id="executor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
		 <property name="corePoolSize" value="10" />
		 <property name="maxPoolSize" value="100" />
		 <property name="queueCapacity" value="500" />
	</bean>

2013年8月28日 13:39

gs053485
30
0 0 0