Spring boot集成quartz并实现任务调度
最近在实现任务调度服务，使用 quartz调度框架，由于使用的spring boot版本为1.5.10，该版本并没有提供quartz的starter，在集成的时候还是遇到了很多问题。本文并不会详细介绍quartz框架，请自行查阅相关资料。如果对Spring boot不太熟悉，可以看前边几篇关于spring boot的文章。 1. quartz简介 1.1. 核心概念 scheduler：任务调度器，相当于指挥中心，负责管理和调度job，由SchedulerFactory创建和关闭，创建后需要通过starter()方法来启动调度。 trigger：触发器，定义job的触发时机，通过TriggerBuilder来创建，有SimpleTrigger和CronTrigger，前者可以定义在某一个时刻触发或者周期性触发，后者使用cron表达式来定义触发时间。 Job：具体的调度业务逻辑实现，也就是任务，具体任务需要实现org.quartz.Job接口。 JobDetail：org.quartz.JobDetail用来描述Job实例的属性，并且可以通过JobDataMap传递给Job实例数据，通过JobBuilder来创建。 1.2. quartz配置 quartz框架默认会通过quartz.properties文件来加载配置信息，有几个重要的配置项： org.quartz.scheduler.*：调度器相关配置 org.quartz.threadPool.*：线程池相关配置 org.quartz.jobStore.*：quartz数据存储相关配置，在quartz中，有三种存储类型： RAMJobStore：基于内存存储job JobStoreCMT：基于数据库的数据存储，并且受运行的java容器的事务控制 JobStoreTX：基于数据库的数据存储，不受事务控制 org.quartz.dataSource.*：配置数据库存储quartz数据时的数据源信息 org.quartz.plugin.*：quartz插件相关配置 quartz简单介绍这么多，更多信息请看 这里。 2. Spring boot与quartz集成 前边说过，我使用的spring boot版本为1.5.10，没有quartz的starter，所以需要自己编码实现。同时，我还需要对quartz做持久化处理，需要在mysql库中导入quartz的建表脚本。集成步骤如下： 1、引入依赖 引入quartz的依赖包，quartz-jobs根据实际需要决定是否引入。 <dependency> <groupId>org.quartz-scheduler</groupId> <artifactId>quartz</artifactId> <version>2.2.3</version> </dependency> <dependency> <groupId>org.quartz-scheduler</groupId> <artifactId>quartz-jobs</artifactId> <version>2.2.3</version> </dependency> 2、创建表 在下载的quartz包中有建表脚本，我的为quartz-2.2.3，建表脚本在/docs/dbTables下边，导入tables_mysql_innodb.sql即可。 3、配置文件 在resources目下新建一个quartz.properties配置文件，我的配置如下： #============================================================================ # Configure Main Scheduler Properties #============================================================================ org.quartz.scheduler.instanceName:event-scheduler org.quartz.scheduler.instanceId:AUTO org.quartz.scheduler.skipUpdateCheck:true #============================================================================ # Configure ThreadPool #============================================================================ org.quartz.threadPool.class:org.quartz.simpl.SimpleThreadPool org.quartz.threadPool.threadCount:5 org.quartz.threadPool.threadPriority:5 #============================================================================ # Configure JobStore #============================================================================ org.quartz.jobStore.misfireThreshold:60000 org.quartz.jobStore.class:org.quartz.impl.jdbcjobstore.JobStoreTX org.quartz.jobStore.driverDelegateClass:org.quartz.impl.jdbcjobstore.StdJDBCDelegate org.quartz.jobStore.useProperties:false org.quartz.jobStore.tablePrefix:QRTZ_ org.quartz.jobStore.isClustered:false #============================================================================ # Configure Datasources #============================================================================ org.quartz.dataSource.ds.maxConnections:7 #============================================================================ # Configure Plugins #============================================================================ org.quartz.plugin.triggHistory.class: org.quartz.plugins.history.LoggingTriggerHistoryPlugin ...