什么是quartz？

Quartz是一个完全由 Java 编写的开源任务调度框架。

我们经常会遇到一些问题：

想每个月27号，提醒信用卡还款；

想每隔1小时，提醒一下，累了，站起来活动一下；

想每个月定时发送邮件，等等。

总结起来就是，在一个有规律的时间点做某件事。

quartz可满足复杂触发条件下的定时任务调度，比如每月的周一和周五 10点 15分执行。

quartz集群可保证系统的高可用性，即使一个节点崩了，也能保证任务的执行。

集群环境下，一个任务某个时间点只会在一个节点上运行。

核心概念

Job表示一个工作，要执行的具体内容JobDetail表示任务的定义，Job 是任务的执行逻辑Trigger代表一个调度参数的配置，什么时候去调Scheduler代表一个调度容器，一个调度容器中可以注册多个 JobDetail 和 Trigger。当 Trigger 与 JobDetail 组合，就可以被 Scheduler 容器调度了。

quartz集群应用

集群中的节点放在不同的服务器上，称为水平集群。

节点放在同一台机器上，称为垂直集群，存在着单点故障问题。

Quartz可以借助关系数据库和JDBC作业存储支持集群。

数据库脚本

链接：/s/1BpDTVRwtN6_VVJqTx9flNQ

提取码：49ie

搭建spring boot环境

以定时发送邮件为例，每隔1分钟发送一次，邮件发送功能忽略，不是本例重点。

开发工具：Intellij IDEA

添加maven 依赖

配置

配置application.yml

server: port: ${PORT:8090}spring: application: name: learn-quartz datasource: druid:url: ${MYSQL_URL:jdbc:mysql://192.168.0.113:3306/quartz?characterEncoding=utf-8&useSSL=false}username: rootpassword: 123456driverClassName: com.mysql.cj.jdbc.DriverinitialSize: 5 #初始建立连接数量minIdle: 5 #最小连接数量maxActive: 20 #最大连接数量maxWait: 10000 #获取连接最大等待时间，毫秒testOnBorrow: true #申请连接时检测连接是否有效testOnReturn: false #归还连接时检测连接是否有效timeBetweenEvictionRunsMillis: 60000 #配置间隔检测连接是否有效的时间(单位是毫秒)minEvictableIdleTimeMillis: 300000 #连接在连接池的最小生存时间(毫秒) quartz: job-store-type: jdbc #数据库方式 jdbc:initialize-schema: never #不初始化表结构 properties:org: quartz:scheduler: instanceId: AUTO #默认主机名和时间戳生成实例ID,可以是任何字符串，但对于所有调度程序来说，必须是唯一的 对应qrtz_scheduler_state INSTANCE_NAME字段 instanceName: clusteredScheduler #quartzSchedulerjobStore: class: org.quartz.impl.jdbcjobstore.JobStoreTX #持久化配置 driverDelegateClass: org.quartz.impl.jdbcjobstore.StdJDBCDelegate #我们仅为数据库制作了特定于数据库的代理 useProperties: false #以指示JDBCJobStore将JobDataMaps中的所有值都作为字符串，因此可以作为名称 - 值对存储而不是在BLOB列中以其序列化形式存储更多复杂的对象。从长远来看，这是更安全的，因为您避免了将非String类序列化为BLOB的类版本问题。 tablePrefix: QRTZ_ #数据库表前缀 misfireThreshold: 60000 #在被认为“失火”之前，调度程序将“容忍”一个Triggers将其下一个启动时间通过的毫秒数。默认值(如果您在配置中未输入此属性)为60000(60秒)。 clusterCheckinInterval: 5000 #设置此实例“检入”*与群集的其他实例的频率(以毫秒为单位)。影响检测失败实例的速度。 isClustered: true #打开群集功能threadPool: #连接池 class: org.quartz.simpl.SimpleThreadPool threadCount: 10 threadPriority: 5 threadsInheritContextClassLoaderOfInitializingThread: true

定义Job

public class EmailJob extends QuartzJobBean { @Value("${server.port}") String port; @Override protected void executeInternal(JobExecutionContext jobExecutionContext) throws JobExecutionException { String time = DateUtil.now(); System.out.println(time + " send email,server port:" + port); }}

配置QuartzConfig.java

@Configurationpublic class QuartzConfig { @Bean public JobDetail jobSendEmailDetails() { return JobBuilder.newJob(EmailJob.class).withIdentity("emailJobId").storeDurably().build(); } /*** 1分钟1次，会平均分配到每个节点上* @return*/ @Bean public Trigger jobOrderCheckTrigger() { return TriggerBuilder.newTrigger().forJob(jobSendEmailDetails()).withIdentity("sendEmailTriggerId").withSchedule(CronScheduleBuilder.cronSchedule("0 0/1 * * * ?")).build(); }}

创建2个应用

选择Edit Configurations, 在spring boot目录下创建quartz1和quartz2, VM options中分别输入-DPORT=8090和-DPORT=8091, 启动两个实例，同一个任务会在两个实例中轮流执行，效果图：

quartz1

quartz2