zoukankan      html  css  js  c++  java

  • Java定时任务调度工具Timer Quartz

     

    -----------------------------------Timer

    PS:Timer是 jdk中的；Quartz是第三方的

     

     

    PS：也即是返回执行任务时候的时间

     

    ---------------------------------------------------一个综合的例子

    import java.text.SimpleDateFormat;
import java.util.TimerTask;

public class DancingRobot extends TimerTask{

    @Override
    public void run() {
        // 获取最近一次任务执行的时间，将其格式化
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        System.out.println("最近执行任务的时间："+sdf.format(scheduledExecutionTime()));//获取最近一次任务执行的时间，将其格式化
        System.out.println("开心的跳舞");
    }

}
    import java.util.Timer;
import java.util.TimerTask;

public class WaterRobot extends TimerTask{
    private Timer timer;
    
    
    
    public WaterRobot(Timer timer) {
        this.timer = timer;
    }
    //最大容量为5L
    private Integer bucketCapacity = 0;
    @Override
    public void run() {
        // 灌水直到桶水满为止
        if(bucketCapacity<5){
            System.out.println("机器人加1L水");
            bucketCapacity++;
        }else{
            System.out.println("返回取消的任务数  before："+timer.purge());
            cancel();//停止当前的机器人的执行
            System.out.println("机器人停止加水");
            System.out.println("返回取消的任务数   after："+timer.purge());
            System.out.println("当前水容量："+bucketCapacity+"L");
            try {
                Thread.sleep(2000);
            } catch (Exception e) {
                e.printStackTrace();
            }
            timer.cancel();//停止所有的机器人操作
        }
    
    }

}
    import java.text.SimpleDateFormat;
import java.util.Calendar;
import java.util.Timer;

public class Main {
    
    public static void main(String[] args) {
        
        Timer timer = new Timer();
        //获取当前时间
        Calendar calendar =  Calendar.getInstance();
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        System.out.println("当前时间："+sdf.format(calendar.getTime()));
        
        DancingRobot dr = new DancingRobot();
        WaterRobot wr = new WaterRobot(timer);
        
        timer.schedule(dr, calendar.getTime(), 2000);
        timer.scheduleAtFixedRate(wr, calendar.getTime(), 1000);
    }

/*    当前时间：2018-06-08 18:11:24
    最近执行任务的时间：2018-06-08 18:11:25
    开心的跳舞
    机器人加1L水
    机器人加1L水
    机器人加1L水
    最近执行任务的时间：2018-06-08 18:11:27
    开心的跳舞
    机器人加1L水
    机器人加1L水
    最近执行任务的时间：2018-06-08 18:11:29
    开心的跳舞
    返回取消的任务数  before：0
    机器人停止加水
    返回取消的任务数   after：1
    当前水容量：5L*/


}

    ------------------------------------Quartz 

     -------------------------------------Hello world-----------------------

    package com.beet.test.HelloQuartz;

import java.text.SimpleDateFormat;
import java.util.Date;

import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;

public class HelloJob implements Job{

    public void execute(JobExecutionContext arg0) throws JobExecutionException {
        //打印当前的执行时间  
        Date date = new Date();
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        System.out.println("当前execution时间为："+sdf.format(date));        
        // 编写具体的业务逻辑
        System.out.println("hello world");        
    }

}
    package com.beet.test.HelloQuartz;

import java.text.SimpleDateFormat;
import java.util.Date;

import org.quartz.JobBuilder;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.SimpleScheduleBuilder;
import org.quartz.SimpleTrigger;
import org.quartz.TriggerBuilder;
import org.quartz.impl.StdSchedulerFactory;

public class HelloScheduler {
    public static void main(String[] args) throws SchedulerException {
        //创建一个jobdetail实例，将该实例与hellojob class绑定
        JobDetail jobDetail = JobBuilder.newJob(HelloJob.class).withIdentity("myJob", "group1").build();
        //创建一个Trigger的实例，定义改job立即执行，并且每隔2秒钟重复一次，直到永远
        SimpleTrigger trigger = TriggerBuilder.newTrigger().withIdentity("myTrigger", "group1").startNow().withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(2).repeatForever()).build();
        //创建schedule实例
        StdSchedulerFactory sfact = new StdSchedulerFactory();
        Scheduler scheduler = sfact.getScheduler();
        scheduler.start();
        
        //打印当前的执行时间  
        Date date = new Date();
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        System.out.println("当前时间为："+sdf.format(date));        
        
        scheduler.scheduleJob(jobDetail, trigger);
    }

}

    当前时间为：2018-06-14 09:57:36
    当前execution时间为：2018-06-14 09:57:36
    hello world
    当前execution时间为：2018-06-14 09:57:38
    hello world
    当前execution时间为：2018-06-14 09:57:40
    hello world
    当前execution时间为：2018-06-14 09:57:42
    hello world
    当前execution时间为：2018-06-14 09:57:44

     

    public class HelloScheduler {
    public static void main(String[] args) throws SchedulerException {
        //创建一个jobdetail实例，将该实例与hellojob class绑定
        JobDetail jobDetail = JobBuilder.newJob(HelloJob.class).withIdentity("myJob", "group1").build();
        System.out.println("jobDetail的名字："+jobDetail.getKey().getName());        
        System.out.println("jobDetail的group："+jobDetail.getKey().getGroup());        
        System.out.println("jobDetail的jobclass："+jobDetail.getJobClass().getName());        
        
        //创建一个Trigger的实例，定义改job立即执行，并且每隔2秒钟重复一次，直到永远
        SimpleTrigger trigger = TriggerBuilder.newTrigger().withIdentity("myTrigger", "group1").startNow().withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(2).repeatForever()).build();
        //创建schedule实例
        StdSchedulerFactory sfact = new StdSchedulerFactory();
        Scheduler scheduler = sfact.getScheduler();
        scheduler.start();
        
        //打印当前的执行时间  
        Date date = new Date();
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        System.out.println("当前时间为："+sdf.format(date));        
        
        scheduler.scheduleJob(jobDetail, trigger);
        
        /*jobDetail的名字：myJob
        jobDetail的group：group1
        jobDetail的jobclass：com.beet.test.HelloQuartz.HelloJob
         
        当前时间为：2018-06-14 10:10:25
        当前execution时间为：2018-06-14 10:10:26
        hello world*/
    }

}

    ---------------------------------------------------------使用JobDataMap传参数

    package com.beet.test.HelloQuartz;

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.TriggerKey;

public class HelloJob implements Job{

    public void execute(JobExecutionContext context) throws JobExecutionException {
        //打印当前的执行时间  
        Date date = new Date();
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
    
        // 编写具体的业务逻辑
        //System.out.println("hello world");        
         JobKey key = context.getJobDetail().getKey();
         TriggerKey trKey = context.getTrigger().getKey();
            JobDataMap dataMap = context.getJobDetail().getJobDataMap();
            JobDataMap tDataMap = context.getTrigger().getJobDataMap();     //从中获取Map
            //String JobMsg = dataMap.getString("message");
            // Float jobFloatValue = dataMap.getFloat("FloatJobValue");
            String triggerMsg = tDataMap.getString("message");
             Float triggerDoubleValue = tDataMap.getFloat("DoubleTriggerValue");
                System.out.println("当前execution时间为："+sdf.format(date));        
         System.out.println("我的job name和group是："+key.getName()+":"+key.getGroup());    
        
         System.out.println("我的trigger name和group是："+trKey.getName()+":"+trKey.getGroup());    
        
        
    
         
        //System.out.println("job message是："+JobMsg);    
         //System.out.println("FloatJobVAlue是："+jobFloatValue);    
         System.out.println("trigger message："+triggerMsg);    
         System.out.println("FloatJobVAlue是："+triggerDoubleValue);    
    }

}
    package com.beet.test.HelloQuartz;

import java.text.SimpleDateFormat;
import java.util.Date;

import org.quartz.JobBuilder;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.SimpleScheduleBuilder;
import org.quartz.SimpleTrigger;
import org.quartz.TriggerBuilder;
import org.quartz.impl.StdSchedulerFactory;

public class HelloScheduler {
    public static void main(String[] args) throws SchedulerException {
        //创建一个jobdetail实例，将该实例与hellojob class绑定
        JobDetail jobDetail = JobBuilder.newJob(HelloJob.class).withIdentity("myJob", "group1").usingJobData("message", "hello myJob1").usingJobData("FloatJobValue", 3.14f).build();
        System.out.println("jobDetail的名字："+jobDetail.getKey().getName());        
        System.out.println("jobDetail的group："+jobDetail.getKey().getGroup());        
        System.out.println("jobDetail的jobclass："+jobDetail.getJobClass().getName());        
        
        //创建一个Trigger的实例，定义改job立即执行，并且每隔2秒钟重复一次，直到永远
        SimpleTrigger trigger = TriggerBuilder.newTrigger().withIdentity("myTrigger", "group1").usingJobData("message", "hello myTrigger").usingJobData("DoubleTriggerValue", 2.0D).startNow().withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(2).repeatForever()).build();
        //创建schedule实例
        StdSchedulerFactory sfact = new StdSchedulerFactory();
        Scheduler scheduler = sfact.getScheduler();
        scheduler.start();
        
        //打印当前的执行时间  
        Date date = new Date();
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        System.out.println("当前时间为："+sdf.format(date));        
        
        scheduler.scheduleJob(jobDetail, trigger);
        
        /*jobDetail的名字：myJob
        jobDetail的group：group1
        jobDetail的jobclass：com.beet.test.HelloQuartz.HelloJob
         
        当前时间为：2018-06-14 10:10:25
        当前execution时间为：2018-06-14 10:10:26
        hello world*/
    }

}

     

     

    package com.beet.test.HelloQuartz;

import java.text.SimpleDateFormat;
import java.util.Date;

import org.quartz.JobBuilder;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.SimpleScheduleBuilder;
import org.quartz.SimpleTrigger;
import org.quartz.TriggerBuilder;
import org.quartz.impl.StdSchedulerFactory;

public class HelloScheduler {
    public static void main(String[] args) throws SchedulerException {
        //创建一个jobdetail实例，将该实例与hellojob class绑定
        JobDetail jobDetail = JobBuilder.newJob(HelloJob.class).withIdentity("myJob", "group1").build();
    /*    System.out.println("jobDetail的名字："+jobDetail.getKey().getName());        
        System.out.println("jobDetail的group："+jobDetail.getKey().getGroup());        
        System.out.println("jobDetail的jobclass："+jobDetail.getJobClass().getName());        */
        
        //打印当前的执行时间  
        Date date = new Date();
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        System.out.println("当前时间为："+sdf.format(date));        
        date.setTime(date.getTime()+3000);//开始3s后执行
        
        Date endDate = new Date();
        endDate.setTime(endDate.getTime()+6000);
        //创建一个Trigger的实例，定义改job立即执行，并且每隔2秒钟重复一次，直到永远
        SimpleTrigger trigger = TriggerBuilder.newTrigger().withIdentity("myTrigger", "group1").startAt(date).endAt(endDate).withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(2).repeatForever()).build();
        //创建schedule实例
        StdSchedulerFactory sfact = new StdSchedulerFactory();
        Scheduler scheduler = sfact.getScheduler();
        scheduler.start();
        
        
        
        scheduler.scheduleJob(jobDetail, trigger);
        
        /*jobDetail的名字：myJob
        jobDetail的group：group1
        jobDetail的jobclass：com.beet.test.HelloQuartz.HelloJob
         
        当前时间为：2018-06-14 10:10:25
        当前execution时间为：2018-06-14 10:10:26
        hello world*/
    }

}
    package com.beet.test.HelloQuartz;

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{

    public void execute(JobExecutionContext context) throws JobExecutionException {
        //打印当前的执行时间  
        Date date = new Date();
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        System.out.println("当前execution时间为："+sdf.format(date));        
        // 编写具体的业务逻辑
    //    System.out.println("hello world");        
        
        Trigger trigger = context.getTrigger();
        System.out.println("start time is "+trigger.getStartTime());        
        System.out.println("end time is "+trigger.getEndTime());        
        
    }

}

    当前时间为：2018-06-14 14:14:32
     
    当前execution时间为：2018-06-14 14:14:35
    start time is Thu Jun 14 14:14:35 CST 2018
    end time is Thu Jun 14 14:14:38 CST 2018
    当前execution时间为：2018-06-14 14:14:37
    start time is Thu Jun 14 14:14:35 CST 2018
    end time is Thu Jun 14 14:14:38 CST 2018

     

     

    package com.beet.test.HelloQuartz;

import java.text.SimpleDateFormat;
import java.util.Date;

import org.quartz.JobBuilder;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.SimpleScheduleBuilder;
import org.quartz.SimpleTrigger;
import org.quartz.TriggerBuilder;
import org.quartz.impl.StdSchedulerFactory;

public class HelloScheduler {
    public static void main(String[] args) throws SchedulerException {
        //创建一个jobdetail实例，将该实例与hellojob class绑定
        JobDetail jobDetail = JobBuilder.newJob(HelloJob.class).withIdentity("myJob", "group1").build();
    /*    System.out.println("jobDetail的名字："+jobDetail.getKey().getName());        
        System.out.println("jobDetail的group："+jobDetail.getKey().getGroup());        
        System.out.println("jobDetail的jobclass："+jobDetail.getJobClass().getName());        */
        
        //打印当前的执行时间  
        Date date = new Date();
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        System.out.println("当前时间为："+sdf.format(date));        
        date.setTime(date.getTime()+3000);//开始3s后执行
        
        Date endDate = new Date();
        endDate.setTime(endDate.getTime()+6000);
        //创建一个Trigger的实例，定义改job立即执行，并且每隔2秒钟重复一次，直到永远                                                                   被endDate 覆盖掉了执行计划
        SimpleTrigger trigger = TriggerBuilder.newTrigger().withIdentity("myTrigger", "group1").startAt(date).endAt(endDate).withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(2).repeatForever()).build();
        //创建schedule实例                                                                                定时                                       定频率
        StdSchedulerFactory sfact = new StdSchedulerFactory();
        Scheduler scheduler = sfact.getScheduler();
        scheduler.start();
        
        
        
        scheduler.scheduleJob(jobDetail, trigger);
        
        /*jobDetail的名字：myJob
        jobDetail的group：group1
        jobDetail的jobclass：com.beet.test.HelloQuartz.HelloJob
         
        当前时间为：2018-06-14 10:10:25
        当前execution时间为：2018-06-14 10:10:26
        hello world*/
    }

}

    PS:
    ,表示或的关系
    -,至 5-7 五到七
    *，每秒钟
    /， 每分钟没小时    0/5 没隔5分钟（..）出发一次
    ？,不关心
    #,代表第..         6#3 每月第三周的周五（6代表周五）
    L,代表最后

    在线地址

    package com.beet.test.HelloQuartz;

import java.text.SimpleDateFormat;
import java.util.Date;

import org.quartz.CronScheduleBuilder;
import org.quartz.CronTrigger;
import org.quartz.JobBuilder;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.SimpleScheduleBuilder;
import org.quartz.TriggerBuilder;
import org.quartz.impl.StdSchedulerFactory;

public class HelloScheduler {
    public static void main(String[] args) throws SchedulerException {
        //创建一个jobdetail实例，将该实例与hellojob class绑定
        JobDetail jobDetail = JobBuilder.newJob(HelloJob.class).withIdentity("myJob", "group1").build();
    /*    System.out.println("jobDetail的名字："+jobDetail.getKey().getName());        
        System.out.println("jobDetail的group："+jobDetail.getKey().getGroup());        
        System.out.println("jobDetail的jobclass："+jobDetail.getJobClass().getName());        */
        
        //打印当前的执行时间  
        Date date = new Date();
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        System.out.println("当前时间为："+sdf.format(date));        
        date.setTime(date.getTime()+3000);//开始3s后执行
        
        Date endDate = new Date();
        endDate.setTime(endDate.getTime()+6000);
        //创建一个Trigger的实例，定义改job立即执行，并且每隔2秒钟重复一次，直到永远
        CronTrigger trigger = (CronTrigger) TriggerBuilder.newTrigger().withIdentity("myTrigger", "group1").withSchedule(CronScheduleBuilder.cronSchedule("* * * * * ? *")).build();
        //创建schedule实例
        StdSchedulerFactory sfact = new StdSchedulerFactory();
        Scheduler scheduler = sfact.getScheduler();
        scheduler.start();
        scheduler.scheduleJob(jobDetail, trigger);
    
    }

}
    package com.beet.test.HelloQuartz;

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{

    public void execute(JobExecutionContext context) throws JobExecutionException {
        //打印当前的执行时间  
        Date date = new Date();
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        System.out.println("当前execution时间为："+sdf.format(date));        
        // 编写具体的业务逻辑
         System.out.println("hello world");        
        
        /*Trigger trigger = context.getTrigger();
        System.out.println("start time is "+trigger.getStartTime());        
        System.out.println("end time is "+trigger.getEndTime());        */
        
    }

}

    PS： 这两种方式推荐使用std的方式。

    package com.beet.test.HelloQuartz;

import java.text.SimpleDateFormat;
import java.util.Date;

import org.quartz.CronScheduleBuilder;
import org.quartz.CronTrigger;
import org.quartz.JobBuilder;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.SimpleScheduleBuilder;
import org.quartz.TriggerBuilder;
import org.quartz.impl.StdSchedulerFactory;

public class HelloScheduler {
    public static void main(String[] args) throws SchedulerException, InterruptedException {
        //创建一个jobdetail实例，将该实例与hellojob class绑定
        JobDetail jobDetail = JobBuilder.newJob(HelloJob.class).withIdentity("myJob", "group1").build();
    /*    System.out.println("jobDetail的名字："+jobDetail.getKey().getName());        
        System.out.println("jobDetail的group："+jobDetail.getKey().getGroup());        
        System.out.println("jobDetail的jobclass："+jobDetail.getJobClass().getName());        */
        
        //打印当前的执行时间  
        Date date = new Date();
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        System.out.println("当前时间为："+sdf.format(date));        
        date.setTime(date.getTime()+3000);//开始3s后执行
        
        Date endDate = new Date();
        endDate.setTime(endDate.getTime()+6000);
        //创建一个Trigger的实例，定义改job立即执行，并且每隔2秒钟重复一次，直到永远
        CronTrigger trigger = (CronTrigger) TriggerBuilder.newTrigger().withIdentity("myTrigger", "group1").withSchedule(CronScheduleBuilder.cronSchedule("* * * * * ? *")).build();
        //创建schedule实例
        StdSchedulerFactory sfact = new StdSchedulerFactory();
        Scheduler scheduler = sfact.getScheduler();
        scheduler.start();
        Date scheduleDate = scheduler.scheduleJob(jobDetail, trigger);
        System.out.println("开始执行时间为："+sdf.format(scheduleDate));        
        //scheudle执行2s挂起
        Thread.sleep(2000);
        scheduler.standby();//挂起
        //挂起3s重新启动
        Thread.sleep(3000);
        scheduler.start();
    }

}
  • 相关阅读:
    HAProxy的安装与使用
    使用 Minikube 安装 Kubernetes
    史上最详细的Docker安装手册
    Kubernetes(K8s) 安装（使用kubeadm安装Kubernetes集群）
    Docker 学习线路
    Docker Machine的使用
    Asp.Net Core 发布到 Docker（Linux Centos 虚拟机，使用Dockerfile）
    Centos 8 上安装 Consul
    Centos 8 安装 Consul-Template
    Centos 8 安装 Nginx
  • 原文地址：https://www.cnblogs.com/bee-home/p/9154848.html
Copyright © 2011-2022 走看看