Quartz表达式触发

灰太狼 2022-05-16 12:46 180阅读 0赞

### 引入jar包 ###

<dependency>
        <groupId>org.quartz-scheduler</groupId>
        <artifactId>quartz</artifactId>
        <version>2.2.2</version>
    </dependency>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-context-support</artifactId>
        <version>4.1.3.RELEASE</version>
    </dependency>

### 创建Job ###

public class HelloJob implements Job { 
    
        private static Logger _log = LoggerFactory.getLogger(HelloJob.class);
    
        /** * */
        public HelloJob() {
        }
    
        /** * */
        public void execute(JobExecutionContext context)
            throws JobExecutionException {
            // Say Hello to the World and display the date/time
            _log.info("Hello World! - " + new Date());
        }
    
    }

### 表达式触发器 ###

public class SimpleCronExample {
    
        public void run() throws Exception {
            Logger log = LoggerFactory.getLogger(SimpleCronExample.class);
    
            log.info("------- Initializing ----------------------");
    
            // 定义调度器
            SchedulerFactory sf = new StdSchedulerFactory();
            Scheduler sched = sf.getScheduler();
    
            log.info("------- Initialization Complete -----------");
    
            // 获取当前时间的下一分钟
            Date runTime = evenMinuteDate(new Date());
    
            log.info("------- Scheduling Job -------------------");
    
            // 定义job
            JobDetail job = newJob(HelloJob.class).withIdentity("job1", "group1").build();
    
            // 定义触发器，每2秒执行一次
            Trigger trigger = newTrigger().withIdentity("trigger1", "group1")
                    .withSchedule(cronSchedule("0 0/1 * * * ?")).build();
    
            // 将job注册到调度器
            sched.scheduleJob(job, trigger);
            log.info(job.getKey() + " will run at: " + runTime);
    
            // 启动调度器
            sched.start();
    
            log.info("------- Started Scheduler -----------------");
    
            // 等待1分钟
            log.info("------- Waiting 60 seconds... -------------");
            try {
                Thread.sleep(60L * 1000L);
            } catch (Exception e) {
                //
            }
    
            // 关闭调度器
            log.info("------- Shutting Down ---------------------");
            sched.shutdown(true);
            log.info("------- Shutdown Complete -----------------");
        }
    
        public static void main(String[] args) throws Exception {
    
            SimpleCronExample example = new SimpleCronExample();
            example.run();
    
        }
    
    }