定时任务调度之Quartz----入门小案例

偏执的太偏执、 2022-06-06 08:25 170阅读 0赞

**代码:**

package com.haige.job;
    
    import java.text.SimpleDateFormat;
    import java.util.Date;
    
    import org.quartz.Job;
    import org.quartz.JobDataMap;
    import org.quartz.JobExecutionContext;
    import org.quartz.JobExecutionException;
    import org.quartz.JobKey;
    import org.quartz.Trigger;
    import org.quartz.TriggerKey;
    
    public class HelloJob implements Job {
        private String message;
        private Float FloatJobValue;
        private Double DoubleTriggerValue;
        
    	public String getMessage() {
    		return message;
    	}
    
    	public void setMessage(String message) {
    		this.message = message;
    	}
    
    	public Float getFloatJobValue() {
    		return FloatJobValue;
    	}
    
    	public void setFloatJobValue(Float floatJobValue) {
    		FloatJobValue = floatJobValue;
    	}
    
    	public Double getDoubleTriggerValue() {
    		return DoubleTriggerValue;
    	}
    
    	public void setDoubleTriggerValue(Double doubleTriggerValue) {
    		DoubleTriggerValue = doubleTriggerValue;
    	}
    
    	/*
    	 *  execute()方法相当于TimerTask中的run()方法
    	 */
    	public void execute(JobExecutionContext context) throws JobExecutionException {
    		// TODO Auto-generated method stub
            //打印当前的执行时间,格式为2017-10-20 12:15:00
    		Date date = new Date();
    		SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
    		System.out.println("任务执行时间为: " + sf.format(date));
    		//编写具体的业务逻辑
    		System.out.println("Hello World !");
    		JobKey key = context.getJobDetail().getKey();
    		System.out.println("My name and group are:" + key.getName() + ":" + key.getGroup());
    		TriggerKey trKey = context.getTrigger().getKey();
    		System.out.println("My Trigger name and group are:" + trKey.getName() + ":" + trKey.getGroup());
    //		JobDataMap dataMap = context.getMergedJobDataMap();
    //		String Msg = dataMap.getString("message");
    //		Float jobFloatValue = dataMap.getFloat("FloatJobValue");
    //		Double triggerDoubleValue = dataMap.getDouble("DoubleTriggerValue");
    		System.out.println("JobFloatValue is:" + FloatJobValue);
    		System.out.println("Msg is:" + message);
    		System.out.println("triggerDoubleValue is:" + DoubleTriggerValue);
    		
    		Trigger currentTrigger = context.getTrigger();
    		System.out.println("Start Time Is:" + sf.format(currentTrigger.getStartTime()));
    		System.out.println("End Time Is:" + sf.format(currentTrigger.getEndTime()));
    		JobKey jobKey = currentTrigger.getJobKey();
    		System.out.println("JobKey 的信息: "+ "JobName--->" +jobKey.getName()
    		                     +",jobGroup--->"+jobKey.getGroup());
    	}
    
    }

package com.haige.scheduler;
    
    import java.text.SimpleDateFormat;
    import java.util.Date;
    
    import org.quartz.CronScheduleBuilder;
    import org.quartz.JobBuilder;
    import org.quartz.JobDetail;
    import org.quartz.Scheduler;
    import org.quartz.SchedulerException;
    import org.quartz.SchedulerFactory;
    import org.quartz.SimpleScheduleBuilder;
    import org.quartz.SimpleTrigger;
    import org.quartz.Trigger;
    import org.quartz.TriggerBuilder;
    import org.quartz.impl.StdSchedulerFactory;
    
    import com.haige.job.HelloJob;
    
    public class HelloScheduler {
    
    	public static void main(String[] args) throws SchedulerException{
    		// TODO Auto-generated method stub
    	   Date date = new Date(); 
    	   SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
    	   System.out.println("系统时间为  :" + sf.format(date));
           //创建一个JobDetail实例,将该实例与Hello class绑定
    	   JobDetail jobDetail = JobBuilder.newJob(HelloJob.class)
    			   .withIdentity("myJob").usingJobData("message", "hello myJob1")
    			   .usingJobData("FloatJobValue", 3.14F).build();
    	   //获取距离当前三秒后的时间
    	   date.setTime(date.getTime()+3000);
    	   //获取当前时间6秒后的时间
    	   Date endDate = new Date();
    	   endDate.setTime(endDate.getTime()+6000);
    	   //创建Trigger实例,定义该Job立即执行,并且每隔两秒钟重复执行一次,知道永远
    	   Trigger trigger = TriggerBuilder
    			   .newTrigger()
    			   .withIdentity("MyTrigger", "group1")
    			   .usingJobData("message", "hello MyTrigger1")
    			   .usingJobData("DoubleTriggerValue", 2.0D)
    			   .withSchedule(CronScheduleBuilder.cronSchedule("0/5 * 19,23 * * ?"))   //CronTrigger的用法(Cron表达式)
    //			   .startNow()
    //			   .startAt(date)
    //			   .endAt(endDate)
    //			   .withSchedule(                                                          //SimpleTrigger的用法
    //					   SimpleScheduleBuilder.simpleSchedule()
    //					   .withIntervalInSeconds(2)                                        //每隔2秒执行一次,直到永远
    //					   .withRepeatCount(SimpleTrigger.REPEAT_INDEFINITELY)              //循环无穷多次
    //					   .repeatForever()                 
    //					   )          
    			   .build();
    	   
    	   //创建Scheduler实例
    	   SchedulerFactory factory = new StdSchedulerFactory();
    	   Scheduler scheduler = factory.getScheduler();
    	   scheduler.start();
           //打印当前的时间,格式为2017-10-20 12:15:00
    	   Date date1 = new Date();
    	   SimpleDateFormat sf1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
    	   System.out.println("系统当前时间为: " + sf1.format(date));
    	   scheduler.scheduleJob(jobDetail, trigger);
    	   //scheduler.shutdown(false)即shutdown()表示直接关闭scheduler
    	   scheduler.shutdown(true);
    	   System.out.println("scheduler 是否结束?" + scheduler.isShutdown());
    	}
    
    }