spring boot 集成quartz（使用spring boot、quartz）

一直使用spring boot 和quartz ，从来没做过总结，现在总结一下，同时让自己重新学习，并想跟大家分享，处女作，有什么不规范的请大家多留言交流。

一、使用工具及框架

idea 2017.3，spring boot,quartz

二、创建项目

1.spring boot项目 （直接访问http://start.spring.io/也可以自动用生成，本文使用idea）

1.1 file->new->project

1.2 选择next，见到下图

按照说明填写自己的项目信息，然后点next

1.3 选择适合自己项目依赖，本项目选择web项目,选择一些模板

1.4 一直下一步，创建完成

打开已经创建好的模块，发现spring boot会自动生成一个启动类，并有一个main函数，点击启动

启动之后可以看到如下日志，jvm running for xxx表示项目可以启动,默认是8080端口，" Tomcat started on port(s): 8080 (http) with context path "表示启动的端口号，或者访问127.0.0.1:8080,如果不报连接拒绝则代表可以正常访问

2 集成quartz，使用quartz，就要理解里面的声明
scheduler：任务调度器
trigger：任务触发器，用于定义任务调度时间规则
job：待执行的任务，即被调度的任务
misfire：没有启动，指本应该被执行但实际没有被执行的任务调度

2.1首先在pom文件加上quartz依赖，将下面maven依赖添加到 dependencies节点里面

    org.springframework
    spring-tx



    org.springframework
    spring-context-support

 
    org.quartz-scheduler
    quartz
    2.2.1

添加之后如下，点击import Changes导入jar包

2.2 配置定时器
一般spring常用的定时任务框架有:
2.2.1 Spring Schedule 这是spring自带的任务框架 优点就是配置简单，依赖少，缺点就是
同一个task，如果前一个还没跑完后面一个就不会触发，不同的task也不能同时运行。因为scheduler的默认线程数为1，配置pool-size为2的话，会导致同一个task前一个还没跑完后面又被触发的问题，不支持集群等。想了解的同学可以看下面代码

package com.imooc.quartz.task;

import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import java.util.Date;


@Component
@EnableScheduling //必须加噢
public class SpringScheduleTask {

    
    @Scheduled(cron = "0 0/1 * * * ?")
    public void reptilian(){
 System.out.println("执行调度任务："+new Date());
    }
}

2.2.2 Quartz 优点太多了，最主要有负载均衡，容错率高等特点，具体可以参考别人的分享
使首先先要创建一个任务调度器，触发器等 代码如下

package com.imooc.quartz.config;

import com.imooc.quartz.task.QuartzTask;
import org.quartz.JobDetail;
import org.quartz.Trigger;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.quartz.CronTriggerFactoryBean;
import org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean;
import org.springframework.scheduling.quartz.SchedulerFactoryBean;


@Configuration
public class QuartzConfiguration {

    
    @Bean(name = "reptilianJob")
    public MethodInvokingJobDetailFactoryBean detailFactoryBean(QuartzTask quartzTask) {

 MethodInvokingJobDetailFactoryBean jobDetail = new MethodInvokingJobDetailFactoryBean();

 // 是否并发执行
 jobDetail.setConcurrent(false);

 // 设置任务的名字
 jobDetail.setName("reptilianJob");

 // 设置任务的分组，在多任务的时候使用
 jobDetail.setGroup("reptilianJobGroup");

 // 需要执行的对象
 jobDetail.setTargetObject(quartzTask);

 
 jobDetail.setTargetMethod("reptilian");
 return jobDetail;
    }

    
    @Bean(name = "jobTrigger")
    public CronTriggerFactoryBean cronJobTrigger(JobDetail reptilianJob){

 CronTriggerFactoryBean tigger = new CronTriggerFactoryBean();

 tigger.setJobDetail(reptilianJob);

 //cron表达式，每1分钟执行一次
 tigger.setCronexpression("0 0/1 * * * ?");
 tigger.setName("reptilianTrigger");
 return tigger;
    }

    
    @Bean(name = "scheduler")
    public SchedulerFactoryBean schedulerFactory(Trigger jobTrigger) {

 SchedulerFactoryBean factoryBean = new SchedulerFactoryBean();

 // 用于quartz集群,QuartzScheduler 启动时更新己存在的Job
 factoryBean.setOverwriteExistingJobs(true);

 // 延时启动，应用启动1秒后
 factoryBean.setStartupDelay(1);

 // 注册触发器
 factoryBean.setTriggers(jobTrigger);
 return factoryBean;
    }

}

创建需要执行的业务逻辑类

package com.imooc.quartz.task;

import org.springframework.stereotype.Service;

import java.util.Date;


@Service
public class QuartzTask {

    
    public void reptilian(){
 System.out.println("执行业务处理逻辑："+new Date());
    }
}

最后结果图如下

本文章抛砖引玉，大家有什么见解可以留言，谢谢