zoukankan      html  css  js  c++  java
  • Java 定时任务quartz job

    第二步:创建要被定执行的任务类

      这一步也很简单,只需要创建一个实现了org.quartz.Job接口的类,并实现这个接口的唯一一个方法execute(JobExecutionContext arg0) throws JobExecutionException即可。如:

    复制代码
    package com.fync.quartz;
    
    import java.text.SimpleDateFormat;
    import java.util.Date;
    
    import org.quartz.Job;
    import org.quartz.JobExecutionContext;
    import org.quartz.JobExecutionException;
    /**
     * 创建要被定执行的任务类
     * @author long
     *
     */
    public class MyJob implements Job{
    
        public void execute(JobExecutionContext context)
                throws JobExecutionException {
            SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");
            System.out.println(sdf.format(new Date()));
        }
    
    }
    复制代码

    第三步:创建任务调度,并执行

    复制代码
    package com.fync.quartz;
    
    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.Trigger;
    import org.quartz.TriggerBuilder;
    import org.quartz.impl.StdSchedulerFactory;
    
    /**
     * 创建任务调度,并执行
     * @author long    
     *
     */
    public class MainScheduler {
        
        //创建调度器
        public static Scheduler getScheduler() throws SchedulerException{
            SchedulerFactory schedulerFactory = new StdSchedulerFactory();
            return schedulerFactory.getScheduler();
        }
        
        
        public static void schedulerJob() throws SchedulerException{
            //创建任务
            JobDetail jobDetail = JobBuilder.newJob(MyJob.class).withIdentity("job1", "group1").build();
            //创建触发器 每3秒钟执行一次
            Trigger trigger = TriggerBuilder.newTrigger().withIdentity("trigger1", "group3")
                                .withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(3).repeatForever())
                                .build();
            Scheduler scheduler = getScheduler();
            //将任务及其触发器放入调度器
            scheduler.scheduleJob(jobDetail, trigger);
            //调度器开始调度任务
            scheduler.start();
            
        }
        
        public static void main(String[] args) throws SchedulerException {
            MainScheduler mainScheduler = new MainScheduler();
            mainScheduler.schedulerJob();
        }
    
    } 
    复制代码
  • 相关阅读:
    6.Redis 哈希(Hash)的命令
    5.redis中String类型数据操作的命令
    4.redis中的key命令
    3.redis客户端连接服务器
    Bomblab
    leetcode multiply-strings
    datalab
    leetcode max-points-on-a-line
    os
    python 实现简单的端口扫描器
  • 原文地址:https://www.cnblogs.com/jiang--nan/p/8664899.html
Copyright © 2011-2022 走看看