Quartz任务调度

Danny1000

1.定义一个任务job
import java.util.Date;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.quartz.Job;
import org.quartz.JobDataMap;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
public class Test_ implements Job {
    private static Log _log = LogFactory.getLog(Test_.class);
    无参构造函数是一定要有的.
    public Test_() {
    }
    public void execute(JobExecutionContext context)                    
        throws JobExecutionException {
        // Say Hello to the World and display the date/time
        _log.info("Hello World! - " + new Date());
               
    }
}


import java.net.URLDecoder;
import java.sql.Timestamp;
import java.util.Calendar;
import java.util.Iterator;
import java.util.Properties;
import java.io.FileInputStream;
import java.io.BufferedInputStream;
import java.io.File;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.SimpleTrigger;
import org.quartz.JobDataMap;
import org.quartz.Trigger;
import org.quartz.impl.StdSchedulerFactory;
import com.dcivision.dms.core.DmsDocumentClearCache;
public class Test {
public static void main(String[] args) throws Exception {  
  //名字是任意的,这是quart数据源的名字.只是为了区分其它数据源.
  String sDSName = "netad";
  Properties prop = new Properties();
  Properties properties = new Properties();
  properties.setProperty("org.quartz.scheduler.instanceName", "Sched1");
  properties.setProperty("org.quartz.scheduler.instanceId", "1");
  properties.setProperty("org.quartz.scheduler.rmi.export", "false");
  properties.setProperty("org.quartz.scheduler.rmi.proxy", "false");
  properties.setProperty("org.quartz.threadPool.class", "org.quartz.simpl.SimpleThreadPool");
  properties.setProperty("org.quartz.threadPool.threadCount", "3");
  properties.setProperty("org.quartz.threadPool.threadPriority","4");
  properties.setProperty("org.quartz.jobStore.class", "org.quartz.impl.jdbcjobstore.JobStoreTX");
  
  properties.setProperty("org.quartz.jobStore.driverDelegateClass", "org.quartz.impl.jdbcjobstore.oracle.OracleDelegate");
  
  properties.setProperty("org.quartz.jobStore.dataSource", sDSName);
  properties.setProperty("org.quartz.jobStore.tablePrefix", "SCHEDULER_");
  properties.setProperty("org.quartz.jobStore.instanceId", "1");
  properties.setProperty("org.quartz.dataSource."+sDSName+".driver", "oracle.jdbc.OracleDriver");
  properties.setProperty("org.quartz.dataSource."+sDSName+".URL", "jdbc:oracle:thin:@//192.168.1.248:1521/PROJECT");
  properties.setProperty("org.quartz.dataSource."+sDSName+".user", "cha_uat");
  properties.setProperty("org.quartz.dataSource."+sDSName+".password", "password");
  properties.setProperty("org.quartz.dataSource."+sDSName+".maxConnections", "3");
  properties.setProperty("org.quartz.dataSource."+sDSName+".minConnections", "1");
  
  
   Scheduler sched =  new StdSchedulerFactory(properties).getScheduler();   
   
       String[] triggerGroups;
       String[] triggers;
   
       triggerGroups = sched.getTriggerGroupNames();
       for (int i = 0; i
      if (true){      
   
         获得当前时间
         Timestamp curTime = Utility.getCurrentTimestamp();
         Calendar triggerTime = Utility.timestampToCalendar(curTime);
         
         //任务要用JobDetail包装.         
         JobDetail jobDetail = new org.quartz.JobDetail                            ("job","jobgroup",Test_.class);
         //触发器.
         Trigger trigger = new SimpleTrigger("tigger","tiggergroup",triggerTime.getTime(), null,SimpleTrigger.REPEAT_INDEFINITELY,1000);

   //关联任务和触发器
   sched.scheduleJob(jobDetail, trigger);
   //点火
   sche.start();
      }
      
         
     
  
}
}


























本文来自ChinaUnix博客，如果查看原文请点：http://blog.chinaunix.net/u1/45398/showart_376175.html