oraclequartz分布式_第三十九章：基于SpringBootamp;Quartz完成定时任务分布式单节点持久化...

定时任务在企业项目比较常用到&＃xff0c;几乎所有的项目都会牵扯该功能模块&＃xff0c;定时任务一般会处理指定时间点执行某一些业务逻辑、间隔时间执行某一些业务逻辑等。我们在之前有讲过SpringBoot是已经集成了定时任务的&＃xff0c;那么我们本章将会采用外置的quartz定时任务框架来完成定时任务的分布式单节点持久化&＃xff0c;我们为什么要持久化定时任务呢&＃xff1f;

在一些项目中定时任务可能是必不可少的&＃xff0c;由于某种特殊的原因定时任务可能丢失&＃xff0c;如重启定时任务服务项目后&＃xff0c;原内存中的定时任务就会被完全释放&＃xff01;那对于我们来说可能是致命的问题。当然也有强制的办法解决这类问题&＃xff0c;但是如果我们把定时任务持久化到数据库&＃xff0c;像维护普通逻辑数据那样维护任务&＃xff0c;就会避免项目中遇到的种种的特殊情况。

本章目标

基于SpringBoot架构整合定时任务框架quartz来完成分布式单节点定时任务持久化&＃xff0c;将任务持久化到数据库&＃xff0c;更好的预防任务丢失。

SpringBoot 企业级核心技术学习专题专题专题名称专题描述001讲解SpringBoot一些企业级层面的核心组件

002Spring Boot 核心技术简书每一篇文章码云对应源码

003对Spring Cloud核心技术全面讲解

004Spring Cloud 核心技术简书每一篇文章对应源码

005全面讲解QueryDSL核心技术以及基于SpringBoot整合SpringDataJPA

006全面讲解SpringDataJPA核心技术

007SpringBoot系统的学习目录&＃xff0c;敬请关注点赞&＃xff01;&＃xff01;!

构建项目

我们使用idea开发工具创建一个SpringBoot项目&＃xff0c;pom.xml依赖配置如下所示&＃xff1a;...省略部分配置    

UTF-8

UTF-8

1.8

1.1.5

2.3.0

org.springframework.boot

spring-boot-starter-data-jpa

org.springframework.boot

spring-boot-starter-web

mysql

mysql-connector-java

runtime

com.alibaba

druid

${druid.version}

org.quartz-scheduler

quartz

${quartz.version}

org.quartz-scheduler

quartz-jobs

${quartz.version}

org.springframework

spring-context-support

org.projectlombok

lombok

org.springframework.boot

spring-boot-starter-test

test

...省略部分配置

我们采用的是quartz官方最新版本2.3.0&＃xff0c;新版本的任务调度框架做出了很多封装&＃xff0c;使用也变得简易明了。

创建初始化完成&＃xff0c;下面我们来创建定时任务相关的Configuration配置。

QuartzConfiguration

quartz与Spring相关框架的整合方式有很多种&＃xff0c;我们今天采用jobDetail使用Spring Ioc托管方式来完成整合&＃xff0c;我们可以在定时任务实例中使用Spring注入注解完成业务逻辑处理&＃xff0c;下面我先把全部的配置贴出来再逐步分析&＃xff0c;配置类如下所示&＃xff1a;package com.hengyu.chapter39.configuration;import org.quartz.spi.JobFactory;import org.quartz.spi.TriggerFiredBundle;import org.springframework.beans.factory.annotation.Autowire;import org.springframework.beans.factory.config.AutowireCapableBeanFactory;import org.springframework.context.ApplicationContext;import org.springframework.context.ApplicationContextAware;import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration;import org.springframework.core.io.ClassPathResource;import org.springframework.scheduling.annotation.EnableScheduling;import org.springframework.scheduling.quartz.SchedulerFactoryBean;import org.springframework.scheduling.quartz.SpringBeanJobFactory;import javax.sql.DataSource;/**

* quartz定时任务配置

* &＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;

* Created with IntelliJ IDEA.

* User&＃xff1a;恒宇少年

* Date&＃xff1a;2017/11/5

* Time&＃xff1a;14:07

* 码云&＃xff1a;http://git.oschina.net/jnyqy

* &＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;

* &＃64;author  恒宇少年

*/&＃64;Configuration&＃64;EnableSchedulingpublic class QuartzConfiguration{    /**

* 继承org.springframework.scheduling.quartz.SpringBeanJobFactory

* 实现任务实例化方式

*/

public static class AutowiringSpringBeanJobFactory extends SpringBeanJobFactory implements

ApplicationContextAware {        private transient AutowireCapableBeanFactory beanFactory;        &＃64;Override

public void setApplicationContext(final ApplicationContext context) {

beanFactory &＃61; context.getAutowireCapableBeanFactory();

}        /**

* 将job实例交给spring ioc托管

* 我们在job实例实现类内可以直接使用spring注入的调用被spring ioc管理的实例

* &＃64;param bundle

* &＃64;return

* &＃64;throws Exception

*/

&＃64;Override

protected Object createJobInstance(final TriggerFiredBundle bundle) throws Exception {            final Object job &＃61; super.createJobInstance(bundle);            /**

* 将job实例交付给spring ioc

*/

beanFactory.autowireBean(job);            return job;

}

}    /**

* 配置任务工厂实例

* &＃64;param applicationContext spring上下文实例

* &＃64;return

*/

&＃64;Bean

public JobFactory jobFactory(ApplicationContext applicationContext)

{        /**

* 采用自定义任务工厂 整合spring实例来完成构建任务

* see {&＃64;link AutowiringSpringBeanJobFactory}

*/

AutowiringSpringBeanJobFactory jobFactory &＃61; new AutowiringSpringBeanJobFactory();

jobFactory.setApplicationContext(applicationContext);        return jobFactory;

}    /**

* 配置任务调度器

* 使用项目数据源作为quartz数据源

* &＃64;param jobFactory 自定义配置任务工厂

* &＃64;param dataSource 数据源实例

* &＃64;return

* &＃64;throws Exception

*/

&＃64;Bean(destroyMethod &＃61; "destroy",autowire &＃61; Autowire.NO)    public SchedulerFactoryBean schedulerFactoryBean(JobFactory jobFactory, DataSource dataSource) throws Exception    {

SchedulerFactoryBean schedulerFactoryBean &＃61; new SchedulerFactoryBean();        //将spring管理job自定义工厂交由调度器维护

schedulerFactoryBean.setJobFactory(jobFactory);        //设置覆盖已存在的任务

schedulerFactoryBean.setOverwriteExistingJobs(true);        //项目启动完成后&＃xff0c;等待2秒后开始执行调度器初始化

schedulerFactoryBean.setStartupDelay(2);        //设置调度器自动运行

schedulerFactoryBean.setAutoStartup(true);        //设置数据源&＃xff0c;使用与项目统一数据源

schedulerFactoryBean.setDataSource(dataSource);        //设置上下文spring bean name

schedulerFactoryBean.setApplicationContextSchedulerContextKey("applicationContext");        //设置配置文件位置

schedulerFactoryBean.setConfigLocation(new ClassPathResource("/quartz.properties"));        return schedulerFactoryBean;

}

}

AutowiringSpringBeanJobFactory

可以看到上面配置类中&＃xff0c;AutowiringSpringBeanJobFactory我们继承了SpringBeanJobFactory类&＃xff0c;并且通过实现ApplicationContextAware接口获取ApplicationContext设置方法&＃xff0c;通过外部实例化时设置ApplicationContext实例对象&＃xff0c;在createJobInstance方法内&＃xff0c;我们采用AutowireCapableBeanFactory来托管SpringBeanJobFactory类中createJobInstance方法返回的定时任务实例&＃xff0c;这样我们就可以在定时任务类内使用Spring Ioc相关的注解进行注入业务逻辑实例了。

JobFactory

任务工厂是在本章配置调度器时所需要的实例&＃xff0c;我们通过jobFactory方法注入ApplicationContext实例&＃xff0c;来创建一个AutowiringSpringBeanJobFactory对象&＃xff0c;并且将对象实例托管到Spring Ioc容器内。

SchedulerFactoryBean

我们本章采用的是项目内部数据源的方式来设置调度器的jobSotre&＃xff0c;官方quartz有两种持久化的配置方案。

第一种&＃xff1a;采用quartz.properties配置文件配置独立的定时任务数据源&＃xff0c;可以与使用项目的数据库完全独立。

第二种&＃xff1a;采用与创建项目统一个数据源&＃xff0c;定时任务持久化相关的表与业务逻辑在同一个数据库内。

可以根据实际的项目需求采取不同的方案&＃xff0c;我们本章主要是通过第二种方案来进行讲解&＃xff0c;在上面配置类中可以看到方法schedulerFactoryBean内自动注入了JobFactory实例&＃xff0c;也就是我们自定义的AutowiringSpringBeanJobFactory任务工厂实例&＃xff0c;另外一个参数就是DataSource&＃xff0c;在我们引入spring-starter-data-jpa依赖后会根据application.yml文件内的数据源相关配置自动实例化DataSource实例&＃xff0c;这里直接注入是没有问题的。

我们通过调用SchedulerFactoryBean对象的setConfigLocation方法来设置quartz定时任务框架的基本配置&＃xff0c;配置文件所在位置&＃xff1a;resources/quartz.properties &＃61;> classpath:/quartz.properties下。注意&＃xff1a;quartz.properties配置文件一定要放在classpath下&＃xff0c;放在别的位置有部分功能不会生效。

下面我们来看下quartz.properties文件内的配置&＃xff0c;如下所示&＃xff1a;#调度器实例名称org.quartz.scheduler.instanceName &＃61; quartzScheduler#调度器实例编号自动生成org.quartz.scheduler.instanceId &＃61; AUTO#持久化方式配置org.quartz.jobStore.class &＃61; org.quartz.impl.jdbcjobstore.JobStoreTX#持久化方式配置数据驱动&＃xff0c;MySQL数据库org.quartz.jobStore.driverDelegateClass &＃61; org.quartz.impl.jdbcjobstore.StdJDBCDelegate#quartz相关数据表前缀名org.quartz.jobStore.tablePrefix &＃61; QRTZ_#开启分布式部署org.quartz.jobStore.isClustered &＃61; true#配置是否使用org.quartz.jobStore.useProperties &＃61; false#分布式节点有效性检查时间间隔&＃xff0c;单位&＃xff1a;毫秒org.quartz.jobStore.clusterCheckinInterval &＃61; 20000#线程池实现类org.quartz.threadPool.class &＃61; org.quartz.simpl.SimpleThreadPool#执行最大并发线程数量org.quartz.threadPool.threadCount &＃61; 10#线程优先级org.quartz.threadPool.threadPriority &＃61; 5#配置为守护线程&＃xff0c;设置后任务将不会执行#org.quartz.threadPool.makeThreadsDaemons&＃61;true#配置是否启动自动加载数据库内的定时任务&＃xff0c;默认trueorg.quartz.threadPool.threadsInheritContextClassLoaderOfInitializingThread &＃61; true

由于我们下一章需要做分布式多节点自动交付高可用&＃xff0c;本章的配置文件加入了分布式相关的配置。

在上面配置中org.quartz.jobStore.class与org.quartz.jobStore.driverDelegateClass是定时任务持久化的关键配置&＃xff0c;配置了数据库持久化定时任务以及采用MySQL数据库进行连接&＃xff0c;当然这里我们也可以配置其他的数据库&＃xff0c;如下所示&＃xff1a;

PostgreSQL &＃xff1a; org.quartz.impl.jdbcjobstore.PostgreSQLDelegate

Sybase : org.quartz.impl.jdbcjobstore.SybaseDelegate

MSSQL : org.quartz.impl.jdbcjobstore.MSSQLDelegate

HSQLDB : org.quartz.impl.jdbcjobstore.HSQLDBDelegate

Oracle : org.quartz.impl.jdbcjobstore.oracle.OracleDelegate

org.quartz.jobStore.tablePrefix属性配置了定时任务数据表的前缀&＃xff0c;在quartz官方提供的创建表SQL脚本默认就是qrtz_&＃xff0c;在对应的XxxDelegate驱动类内也是使用的默认值&＃xff0c;所以这里我们如果修改表名前缀&＃xff0c;配置可以去掉。

org.quartz.jobStore.isClustered属性配置了开启定时任务分布式功能&＃xff0c;再开启分布式时对应属性org.quartz.scheduler.instanceId 改成Auto配置即可&＃xff0c;实例唯一标识会自动生成&＃xff0c;这个标识具体生成的内容&＃xff0c;我们一会在运行的控制台就可以看到了&＃xff0c;定时任务分布式准备好后会输出相关的分布式节点配置信息。

准备测试

我们先来创建一个简单的商品数据表&＃xff0c;建表SQL如下所示&＃xff1a;DROP TABLE IF EXISTS &＃96;basic_good_info&＃96;;

CREATE TABLE &＃96;basic_good_info&＃96; (

&＃96;BGI_ID&＃96; int(11) NOT NULL AUTO_INCREMENT COMMENT &＃39;商品编号&＃39;,

&＃96;BGI_NAME&＃96; varchar(20) DEFAULT NULL COMMENT &＃39;商品名称&＃39;,

&＃96;BGI_PRICE&＃96; decimal(8,2) DEFAULT NULL COMMENT &＃39;单价&＃39;,

&＃96;BGI_UNIT&＃96; varchar(10) DEFAULT NULL COMMENT &＃39;单位&＃39;,

PRIMARY KEY (&＃96;BGI_ID&＃96;)

) ENGINE&＃61;InnoDB AUTO_INCREMENT&＃61;8 DEFAULT CHARSET&＃61;utf8 COMMENT&＃61;&＃39;商品基本信息&＃39;;

GoodEntity

我们先来针对表basic_good_info创建一个实体&＃xff0c;并且添加JPA相关的配置&＃xff0c;如下所示&＃xff1a;package com.hengyu.chapter39.good.entity;import lombok.Data;import javax.persistence.*;import java.math.BigDecimal;/**

* &＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;

*

* &＃64;author 恒宇少年

* Created with IntelliJ IDEA.

* Date&＃xff1a;2017/11/5

* Time&＃xff1a;14:59

* 码云&＃xff1a;http://git.oschina.net/jnyqy

* &＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;

*/&＃64;Entity&＃64;Table(name &＃61; "basic_good_info")

&＃64;Data

public class GoodInfoEntity

{    /**

* 商品编号

*/

&＃64;Id

&＃64;GeneratedValue

&＃64;Column(name &＃61; "bgi_id")

private Long id;    /**

* 商品名称

*/

&＃64;Column(name &＃61; "bgi_name")

private String name;    /**

* 商品单位

*/

&＃64;Column(name &＃61; "bgi_unit")

private String unit;    /**

* 商品单价

*/

&＃64;Column(name &＃61; "bgi_price")

private BigDecimal price;

}

下面我们根据商品实体来创建JPA接口&＃xff0c;如下所示&＃xff1a;/**

* &＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;

* Created with IntelliJ IDEA.

* Date&＃xff1a;2017/11/5

* Time&＃xff1a;14:55

* 码云&＃xff1a;http://git.oschina.net/jnyqy

* &＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;

* &＃64;author 恒宇少年

*/public interface GoodInfoRepository

extends JpaRepository{

}

接下来我们再来添加一个商品添加的控制器方法&＃xff0c;如下所示&＃xff1a;/**

* &＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;

*

* &＃64;author 恒宇少年

* Created with IntelliJ IDEA.

* Date&＃xff1a;2017/11/5

* Time&＃xff1a;15:02

* 码云&＃xff1a;http://git.oschina.net/jnyqy

* &＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;

*/&＃64;RestController&＃64;RequestMapping(value &＃61; "/good")public class GoodController{    /**

* 商品业务逻辑实现

*/

&＃64;Autowired

private GoodInfoService goodInfoService;    /**

* 添加商品

* &＃64;return

*/

&＃64;RequestMapping(value &＃61; "/save")    public Long save(GoodInfoEntity good) throws Exception    {        return goodInfoService.saveGood(good);

}

}

在请求商品添加方法时&＃xff0c;我们调用了GoodInfoService内的saveGood方法&＃xff0c;传递一个商品的实例作为参数。我们接下来看看该类内相关代码&＃xff0c;如下所示&＃xff1a;/**

* 商品业务逻辑

* &＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;

*

* &＃64;author 恒宇少年

* Created with IntelliJ IDEA.

* Date&＃xff1a;2017/11/5

* Time&＃xff1a;15:04

* 码云&＃xff1a;http://git.oschina.net/jnyqy

* &＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;

*/&＃64;Service&＃64;Transactional(rollbackFor &＃61; Exception.class)public class GoodInfoService{    /**

* 注入任务调度器

*/

&＃64;Autowired

private Scheduler scheduler;    /**

* 商品数据接口

*/

&＃64;Autowired

private GoodInfoRepository goodInfoRepository;    /**

* 保存商品基本信息

* &＃64;param good 商品实例

* &＃64;return

*/

public Long saveGood(GoodInfoEntity good) throws Exception    {

goodInfoRepository.save(good);        return good.getId();

}

我们只是作为保存商品的操作&＃xff0c;下面我们来模拟一个需求&＃xff0c;在商品添加完成后1分钟我们通知后续的逻辑进行下一步处理&＃xff0c;同时开始商品库存定时检查的任务。

定义商品添加定时任务

我们先来创建一个任务实例&＃xff0c;并且继承org.springframework.scheduling.quartz.QuartzJobBean抽象类&＃xff0c;重写父抽象类内的executeInternal方法来实现任务的主体逻辑。如下所示&＃xff1a;/**

* 商品添加定时任务实现类

* &＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;

* Created with IntelliJ IDEA.

* User&＃xff1a;恒宇少年

* Date&＃xff1a;2017/11/5

* Time&＃xff1a;14:47

* 码云&＃xff1a;http://git.oschina.net/jnyqy

* &＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;

* &＃64;author 恒宇少年

*/public class GoodAddTimer

extends QuartzJobBean{    /**

* logback

*/

static Logger logger &＃61; LoggerFactory.getLogger(GoodAddTimer.class);    /**

* 定时任务逻辑实现方法

* 每当触发器触发时会执行该方法逻辑

* &＃64;param jobExecutionContext 任务执行上下文

* &＃64;throws JobExecutionException

*/

&＃64;Override

protected void executeInternal(JobExecutionContext jobExecutionContext) throws JobExecutionException {

logger.info("商品添加完成后执行任务&＃xff0c;任务时间&＃xff1a;{}",new Date());

}

在任务主体逻辑内&＃xff0c;我们只是做了一个简单的输出任务执行的时间&＃xff0c;下面我们再来创建库存定时检查任务。

定义商品库存检查任务

同样需要继承org.springframework.scheduling.quartz.QuartzJobBean抽象类实现抽象类内的executeInternal方法&＃xff0c;如下所示&＃xff1a;/**

* 商品库存检查定时任务

* &＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;

*

* &＃64;author 恒宇少年

* Created with IntelliJ IDEA.

* Date&＃xff1a;2017/11/5

* Time&＃xff1a;15:47

* 码云&＃xff1a;http://git.oschina.net/jnyqy

* &＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;

*/public class GoodStockCheckTimer

extends QuartzJobBean{    /**

* logback

*/

static Logger logger &＃61; LoggerFactory.getLogger(GoodStockCheckTimer.class);    &＃64;Override

protected void executeInternal(JobExecutionContext jobExecutionContext) throws JobExecutionException {

logger.info("执行库存检查定时任务&＃xff0c;执行时间&＃xff1a;{}",new Date());

}

}

都是简单的做了下日志的输出&＃xff0c;下面我们需要重构GoodInfoService内的saveGood方法&＃xff0c;对应的添加上面两个任务的创建。

设置商品添加任务到调度器

在GoodInfoService类内添加buildCreateGoodTimer方法用于实例化商品添加任务&＃xff0c;如下所示&＃xff1a;/**

* 构建创建商品定时任务

*/

public void buildCreateGoodTimer() throws Exception    {        //设置开始时间为1分钟后

long startAtTime &＃61; System.currentTimeMillis() &＃43; 1000 * 60;        //任务名称

String name &＃61; UUID.randomUUID().toString();        //任务所属分组

String group &＃61; GoodAddTimer.class.getName();        //创建任务

JobDetail jobDetail &＃61; JobBuilder.newJob(GoodAddTimer.class).withIdentity(name,group).build();        //创建任务触发器

Trigger trigger &＃61; TriggerBuilder.newTrigger().withIdentity(name,group).startAt(new Date(startAtTime)).build();        //将触发器与任务绑定到调度器内

scheduler.scheduleJob(jobDetail, trigger);

}

在上面方法中我们定义的GoodAddTimer实例只运行一次&＃xff0c;在商品添加完成后延迟1分钟进行调用任务主体逻辑。其中任务的名称以及任务的分组是为了区分任务做的限制&＃xff0c;在同一个分组下如果加入同样名称的任务&＃xff0c;则会提示任务已经存在&＃xff0c;添加失败的提示。

我们通过JobDetail来构建一个任务实例&＃xff0c;设置GoodAddTimer类作为任务运行目标对象&＃xff0c;当任务被触发时就会执行GoodAddTimer内的executeInternal方法。

一个任务需要设置对应的触发器&＃xff0c;触发器也分为很多种&＃xff0c;该任务中我们并没有采用cron表达式来设置触发器&＃xff0c;而是调用startAt方法设置任务开始执行时间。

最后将任务以及任务的触发器共同交付给任务调度器&＃xff0c;这样就完成了一个任务的设置。

设置商品库存检查到任务调度器

在GoodInfoService类内添加buildGoodStockTimer方法用于实例化商品添加任务&＃xff0c;如下所示&＃xff1a;/**

* 构建商品库存定时任务

* &＃64;throws Exception

*/

public void buildGoodStockTimer() throws Exception    {        //任务名称

String name &＃61; UUID.randomUUID().toString();        //任务所属分组

String group &＃61; GoodStockCheckTimer.class.getName();

CronScheduleBuilder scheduleBuilder &＃61; CronScheduleBuilder.cronSchedule("0/30 * * * * ?");        //创建任务

JobDetail jobDetail &＃61; JobBuilder.newJob(GoodStockCheckTimer.class).withIdentity(name,group).build();        //创建任务触发器

Trigger trigger &＃61; TriggerBuilder.newTrigger().withIdentity(name,group).withSchedule(scheduleBuilder).build();        //将触发器与任务绑定到调度器内

scheduler.scheduleJob(jobDetail, trigger);

}

该任务的触发器我们采用了cron表达式来设置&＃xff0c;每隔30秒执行一次任务主体逻辑。任务触发器在创建时cron表达式可以搭配startAt方法来同时使用。

下面我们修改GoodInfoService内的saveGood方法&＃xff0c;分别调用设置任务的两个方法&＃xff0c;如下所示&＃xff1a;/**

* 保存商品基本信息

* &＃64;param good 商品实例

* &＃64;return

*/

public Long saveGood(GoodInfoEntity good) throws Exception    {

goodInfoRepository.save(good);        //构建创建商品定时任务

buildCreateGoodTimer();        //构建商品库存定时任务

buildGoodStockTimer();        return good.getId();

}

下面我们就来测试下任务是否可以顺序的被持久化到数据库&＃xff0c;并且是否可以在重启服务后执行重启前添加的任务。

测试

下面我们来启动项目&＃xff0c;启动成功后&＃xff0c;我们来查看控制台输出的分布式节点的信息&＃xff0c;如下所示&＃xff1a;2017-11-05 18:09:40.052  INFO 7708 --- [           main] c.hengyu.chapter39.Chapter39Application  : 【【【【【【定时任务分布式节点 - 1 已启动】】】】】】2017-11-05 18:09:42.005  INFO 7708 --- [lerFactoryBean]] o.s.s.quartz.SchedulerFactoryBean        : Starting Quartz Scheduler now, after delay of 2 seconds2017-11-05 18:09:42.027  INFO 7708 --- [lerFactoryBean]] o.s.s.quartz.LocalDataSourceJobStore     : ClusterManager: detected 1 failed or restarted instances.2017-11-05 18:09:42.027  INFO 7708 --- [lerFactoryBean]] o.s.s.quartz.LocalDataSourceJobStore     : ClusterManager: Scanning for instance "yuqiyu1509876084785"&＃39;s failed in-progress jobs.

2017-11-05 18:09:42.031  INFO 7708 --- [lerFactoryBean]] o.s.s.quartz.LocalDataSourceJobStore     : ClusterManager: ......Freed 1 acquired trigger(s).

2017-11-05 18:09:42.033  INFO 7708 --- [lerFactoryBean]] org.quartz.core.QuartzScheduler          : Scheduler schedulerFactoryBean_$_yuqiyu1509876579404 started.

定时任务是在项目启动后2秒进行执行初始化&＃xff0c;并且通过ClusterManager来完成了instance的创建&＃xff0c;创建的节点唯一标识为yuqiyu1509876084785。

编写商品控制器请求方法测试用例&＃xff0c;如下所示&＃xff1a;&＃64;RunWith(SpringRunner.class)&＃64;SpringBootTestpublic class Chapter39ApplicationTests {    /**

* 模拟mvc测试对象

*/

private MockMvc mockMvc;    /**

* web项目上下文

*/

&＃64;Autowired

private WebApplicationContext webApplicationContext;    /**

* 所有测试方法执行之前执行该方法

*/

&＃64;Before

public void before() {        //获取mockmvc对象实例

mockMvc &＃61; MockMvcBuilders.webAppContextSetup(webApplicationContext).build();

}    /**

* 测试添加商品

* &＃64;throws Exception

*/

&＃64;Test

public void addGood() throws Exception    {

MvcResult result &＃61; mockMvc.perform(MockMvcRequestBuilders.post("/good/save")

.param("name","西瓜")

.param("unit","斤")

.param("price","12.88")

)

.andDo(MockMvcResultHandlers.print())

.andExpect(MockMvcResultMatchers.status().is(200))

.andReturn();

result.getResponse().setCharacterEncoding("UTF-8");

System.out.println(result.getResponse().getContentAsString());

}

测试用例相关文章请访问第三十五章&＃xff1a;SpringBoot与单元测试的小秘密&＃xff0c;我们来执行addGood测试方法&＃xff0c;查看控制台输出&＃xff0c;如下所示&＃xff1a;....省略部分输出Hibernate: insert into basic_good_info (bgi_name, bgi_price, bgi_unit) values (?, ?, ?)

2017-11-05 18:06:35.699 TRACE 7560 --- [           main] o.h.type.descriptor.sql.BasicBinder      : binding parameter [1] as [VARCHAR] - [西瓜]2017-11-05 18:06:35.701 TRACE 7560 --- [           main] o.h.type.descriptor.sql.BasicBinder      : binding parameter [2] as [NUMERIC] - [12.88]2017-11-05 18:06:35.701 TRACE 7560 --- [           main] o.h.type.descriptor.sql.BasicBinder      : binding parameter [3] as [VARCHAR] - [斤]....省略部分输出

8

....省略部分输出

可以看到我们的商品已被成功的写入到数据库并且输出的主键值&＃xff0c;我们的任务是否也成功的被写入到数据库了呢&＃xff1f;我们来查看qrtz_job_details表内任务列表&＃xff0c;如下所示&＃xff1a;schedulerFactoryBean    7567c9d7-76f5-47f3-bc5d-b934f4c1063b    com.hengyu.chapter39.timers.GoodStockCheckTimer     com.hengyu.chapter39.timers.GoodStockCheckTimer 0   0   0   0   0xACED0005737200156F72672E71756172747A2E4A6F62446174614D61709FB083E8BFA9B0CB020000787200266F72672E71756172747A2E7574696C732E537472696E674B65794469727479466C61674D61708208E8C3FBC55D280200015A0013616C6C6F77735472616E7369656E74446174617872001D6F72672E71756172747A2E7574696C732E4469727479466C61674D617013E62EAD28760ACE0200025A000564697274794C00036D617074000F4C6A6176612F7574696C2F4D61703B787000737200116A6176612E7574696C2E486173684D61700507DAC1C31660D103000246000A6C6F6164466163746F724900097468726573686F6C6478703F40000000000010770800000010000000007800schedulerFactoryBean    e5e08ab0-9be3-43fb-93b8-b9490432a5d7    com.hengyu.chapter39.timers.GoodAddTimer        com.hengyu.chapter39.timers.GoodAddTimer    0   0   0   0   0xACED0005737200156F72672E71756172747A2E4A6F62446174614D61709FB083E8BFA9B0CB020000787200266F72672E71756172747A2E7574696C732E537472696E674B65794469727479466C61674D61708208E8C3FBC55D280200015A0013616C6C6F77735472616E7369656E74446174617872001D6F72672E71756172747A2E7574696C732E4469727479466C61674D617013E62EAD28760ACE0200025A000564697274794C00036D617074000F4C6A6176612F7574696C2F4D61703B787000737200116A6176612E7574696C2E486173684D61700507DAC1C31660D103000246000A6C6F6164466163746F724900097468726573686F6C6478703F40000000000010770800000010000000007800

任务已经被成功的持久化到数据库内&＃xff0c;等待1分钟后查看控制台输出内容如下所示&＃xff1a;2017-11-05 18:12:30.017  INFO 7708 --- [ryBean_Worker-1] c.h.c.timers.GoodStockCheckTimer         : 执行库存检查定时任务&＃xff0c;执行时间&＃xff1a;Sun Nov 05 18:12:30 CST 2017

2017-11-05 18:13:00.009  INFO 7708 --- [ryBean_Worker-2] c.h.c.timers.GoodStockCheckTimer         : 执行库存检查定时任务&＃xff0c;执行时间&＃xff1a;Sun Nov 05 18:13:00 CST 2017

2017-11-05 18:13:02.090  INFO 7708 --- [ryBean_Worker-3] c.hengyu.chapter39.timers.GoodAddTimer   : 商品添加完成后执行任务&＃xff0c;任务时间&＃xff1a;Sun Nov 05 18:13:02 CST 2017

根据输出的内容来判定完全吻合我们的配置参数&＃xff0c;库存检查为30秒执行一次&＃xff0c;而添加成功后的提醒则是1分钟后执行一次。执行完成后就会被直接销毁&＃xff0c;我们再来查看数据库表qrtz_job_details&＃xff0c;这时就可以看到还剩下1个任务。

重启服务任务是否自动执行&＃xff1f;

下面我们把项目重启下&＃xff0c;然后观察控制台的输出内容&＃xff0c;如下所示&＃xff1a;2017-11-05 18:15:54.018  INFO 7536 --- [           main] c.hengyu.chapter39.Chapter39Application  : 【【【【【【定时任务分布式节点 - 1 已启动】】】】】】2017-11-05 18:15:55.975  INFO 7536 --- [lerFactoryBean]] o.s.s.quartz.SchedulerFactoryBean        : Starting Quartz Scheduler now, after delay of 2 seconds2017-11-05 18:15:56.000  INFO 7536 --- [lerFactoryBean]] org.quartz.core.QuartzScheduler          : Scheduler schedulerFactoryBean_$_yuqiyu1509876953202 started.2017-11-05 18:16:15.999  INFO 7536 --- [_ClusterManager] o.s.s.quartz.LocalDataSourceJobStore     : ClusterManager: detected 1 failed or restarted instances.2017-11-05 18:16:16.000  INFO 7536 --- [_ClusterManager] o.s.s.quartz.LocalDataSourceJobStore     : ClusterManager: Scanning for instance "yuqiyu1509876579404"&＃39;s failed in-progress jobs.

2017-11-05 18:16:16.005  INFO 7536 --- [_ClusterManager] o.s.s.quartz.LocalDataSourceJobStore     : ClusterManager: ......Freed 1 acquired trigger(s).

2017-11-05 18:16:16.041  INFO 7536 --- [ryBean_Worker-1] c.h.c.timers.GoodStockCheckTimer         : 执行库存检查定时任务&＃xff0c;执行时间&＃xff1a;Sun Nov 05 18:16:16 CST 2017

可以看到成功的自动执行了我们在重启之前配置的任务。

总结

本章主要讲解了SpringBoot整合quartz定时任务框架&＃xff0c;完成了分布式单节点任务持久化&＃xff0c;下一章我们会讲解任务参数传递以及分布式多节点任务自动负载。

作者&＃xff1a;恒宇少年

链接&＃xff1a;https://www.jianshu.com/p/d52d62fb2ac6