博客
关于我
Spring Boot2.0 集成 Quartz
阅读量:494 次
发布时间:2019-03-07

本文共 3155 字,大约阅读时间需要 10 分钟。

在项目开发中,定时任务是常见需求之一。Spring Boot提供了内置的定时方案,但当任务需求复杂化时,经常需要引入Quartz。以下将从简单到复杂,全面解析两种方案。

Spring Boot内置定时方案

pom.xml配置

仅需引入Spring Boot Starter包即可:

org.springframework.boot
spring-boot-starter

启动类配置

在启动类中添加@EnableScheduling注解:

@SpringBootApplication@EnableSchedulingpublic class Application {    public static void main(String[] args) {        SpringApplication.run(Application.class, args);    }}

定时任务实现

创建实现类并使用@Scheduled注解:

  • 方fixedRate方式:
@Componentpublic class SchedulerTask {    private int count = 0;        @Scheduled(fixedRate = 6000)    private void process() {        System.out.println("this is scheduler task running " + count++);    }}
  • 使用cron表达式:
@Componentpublic class Scheduler2Task {    private static final SimpleDateFormat dateFormat = new SimpleDateFormat("HH:mm:ss");        @Scheduled(cron="*/6 * * * * ?", fixedRate=6000)    public void reportCurrentTime() {        System.out.println("现在时间:" + dateFormat.format(new Date()));    }}

参数说明

  • fixedRate:每隔固定秒数执行任务。
  • fixedDelay:任务完成后等待固定秒数后再执行。
  • initialDelay:第一次调度的延迟间隔。
  • cron表达式:支持灵活时间设置。

Quartz定时方案介绍

Quartz简介

Quartz是一个开源的任务调度框架,支持复杂定时需求且能与Spring无缝集成。

核心概念

  • Job:定时任务接口。
  • JobDetail:任务详细信息。
  • Trigger:触发器,定义调度规则。
  • Scheduler:调度器,管理任务执行。

Spring Boot整合

在Spring Boot中使用Quartz需如下配置:

org.springframework.boot
spring-boot-starter-quartz

简单示例

定义Job并注册Trigger:

public class SampleJob extends QuartzJob {    private String name;    public void setName(String name) {        this.name = name;    }    @Override    protected void executeInternal(JobExecutionContext context) throws JobExecutionException {        System.out.println("Hello " + this.name + "!");    }}

配置JobDetail和Trigger:

@Configurationpublic class SampleScheduler {    @Bean    public JobDetail sampleJobDetail() {        return JobBuilder.newJob(SampleJob.class)                .withIdentity("sampleJob", "group1")                .usingJobData("name", "World")                .build();    }    @Bean    public Trigger sampleJobTrigger() {        SimpleScheduleBuilder scheduleBuilder = SimpleScheduleBuilder.simpleSchedule()                .withIntervalInSeconds(2)                .repeatForever();        return TriggerBuilder.newTrigger()                .forJob(sampleJobDetail())                .withIdentity("sampleTrigger", "group1")                .withSchedule(scheduleBuilder)                .build();    }}

启动定时任务

可以采取以下方式启动:

方式一:在启动类中启动

@SpringBootApplicationpublic class MainApplication extends CommandLineRunner {    @Autowired    privateatabase database;    public static void main(String[] args) {        SpringApplication.run(MainApplication.class, args);    }    @Override    public void run(String[] args) throws Exception {        schedulerService.start();    }}

方式二:集成Spring的@Scheduled注解

public class SchedulerListener {    @Autowired    private SchedulerService schedulerService;    @Scheduled(cron="0 30 11 25 11 ?", enabled=true)    public void schedule() {        schedulerService.start();    }}

总结

对于简单定时需求,Spring Boot内置方案足够;对复杂批量任务处理,经常选择Quartz。Spring Boot 2.0对Quartz的支持使其在项目中的应用更加流畅。

转载地址:http://ergdz.baihongyu.com/

你可能感兴趣的文章
mysqldump 导出数据库中每张表的前n条
查看>>
mysqldump: Got error: 1044: Access denied for user ‘xx’@’xx’ to database ‘xx’ when using LOCK TABLES
查看>>
Mysqldump参数大全(参数来源于mysql5.5.19源码)
查看>>
mysqldump备份时忽略某些表
查看>>
mysqldump实现数据备份及灾难恢复
查看>>
mysqldump数据库备份无法进行操作只能查询 --single-transaction
查看>>
mysqldump的一些用法
查看>>
mysqli
查看>>
MySQLIntegrityConstraintViolationException异常处理
查看>>
mysqlreport分析工具详解
查看>>
MySQLSyntaxErrorException: Unknown error 1146和SQLSyntaxErrorException: Unknown error 1146
查看>>
Mysql_Postgresql中_geometry数据操作_st_astext_GeomFromEWKT函数_在java中转换geometry的16进制数据---PostgreSQL工作笔记007
查看>>
mysql_real_connect 参数注意
查看>>
mysql_secure_installation初始化数据库报Access denied
查看>>
MySQL_西安11月销售昨日未上架的产品_20161212
查看>>
Mysql——深入浅出InnoDB底层原理
查看>>
MySQL“被动”性能优化汇总
查看>>
MySQL、HBase 和 Elasticsearch:特点与区别详解
查看>>
MySQL、Redis高频面试题汇总
查看>>
MYSQL、SQL Server、Oracle数据库排序空值null问题及其解决办法
查看>>