定时任务Quartz框架的使用

1
import org.quartz.JobExecutionContext;
2
import org.quartz.JobExecutionException;
3
import org.springframework.beans.factory.annotation.Autowired;
4
import org.springframework.scheduling.quartz.QuartzJobBean;
5
import org.springframework.stereotype.Component;
6
import java.util.Date;
7

8
@Component
9
public class MyJob extends QuartzJobBean {
10

11
    // 继承 QuartzJobBean 后，直接使用 @Autowired 注入，非常优雅！
12
    @Autowired
13
    private OrderService orderService;
14

15
    @Override
16
    protected void executeInternal(JobExecutionContext context) throws JobExecutionException {
17
        System.out.println("定时任务执行了：" + new Date());
18
        // 直接调用你的业务逻辑
19
        orderService.doSomething();
20
    }
21
}

1
@Configuration
2
public class QuartzConfig {
3

4
    @Bean
5
    public JobDetail myJobDetail() {
6
        // 创建JobDetail，指定任务类
7
        return JobBuilder.newJob(MyJob.class)
8
                .withIdentity("myJob", "group1")  // 任务名称和分组
9
                .storeDurably()                    // 即使没有Trigger也保留在调度器中
10
                .build();
11
    }
12

13
    @Bean
14
    public Trigger myJobTrigger() {
15
        // 创建触发器，每10秒执行一次
16
        return TriggerBuilder.newTrigger()
17
                .forJob(myJobDetail())             // 关联上面的 JobDetail
18
                .withIdentity("myTrigger", "group1")
19
                .withSchedule(SimpleScheduleBuilder.simpleSchedule()
20
                        .withIntervalInSeconds(10)  // 每10秒执行
21
                        .repeatForever())           // 无限重复
22
                .build();
23
    }
24
}