简单quartz案例

灰太狼 2022-04-17 05:43 274阅读 0赞

需要导入的包：

<dependency>
          <groupId>org.projectlombok</groupId>
          <artifactId>lombok</artifactId>
          <version>1.18.4</version>
          <scope>provided</scope>
        </dependency>

<dependency>
          <groupId>org.quartz-scheduler</groupId>
          <artifactId>quartz</artifactId>
          <version>2.2.1</version>
        </dependency>

<dependency>
          <groupId>org.quartz-scheduler</groupId>
          <artifactId>quartz-jobs</artifactId>
          <version>2.2.1</version>
        </dependency>

工具类
    private static final Logger log = org.slf4j.LoggerFactory.getLogger(Demo1.class);
    
    public static void main(String[] args) throws Exception {
            //1.创建Scheduler的工厂
            SchedulerFactory sf = new StdSchedulerFactory();
            //2.从工厂中获取调度器实例
            Scheduler scheduler = sf.getScheduler();
    
            //3.创建JobDetail
            JobDetail jb = JobBuilder.newJob(测试类名:test.class)
                    .withDescription("this is a ram job") //job的描述
                    .withIdentity("ramJob", "ramGroup") //job 的name和group
                    .build();
            //向任务传递数据
            JobDataMap jobDataMap = jb.getJobDataMap();
            jobDataMap.putAsString("orderId", 100100);
    
            //任务运行的时间，SimpleSchedle类型触发器有效
            long time = System.currentTimeMillis() + 3 * 1000L; //3秒后启动任务
            Date statTime = new Date(time);
    
            //4.创建Trigger
            //使用SimpleScheduleBuilder或者CronScheduleBuilder
            Trigger t = TriggerBuilder.newTrigger()
                    .withDescription("")
                    .withIdentity("ramTrigger", "ramTriggerGroup")
                    .startAt(statTime)  //默认当前时间启动
                    .withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(3).withRepeatCount(3))//间隔3秒，重复3次
                    //.withSchedule(CronScheduleBuilder.cronSchedule("0/3 * * * * ?")) //3秒执行一次
                    .build();
    
            //5.注册任务和定时器
            scheduler.scheduleJob(jb, t);
    
            //6.启动 调度器
            scheduler.start();
          
        }

测试类  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxMjUxNzE0_size_16_color_FFFFFF_t_70]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxMjUxNzE0_size_16_color_FFFFFF_t_70]: /images/20220417/2615255ed8454c04ae84c6ad8c08a357.png